文章目录一、概述二、组件开发全指南2.1 六种组件类型总览2.2 普通组件（NodeComponent）2.3 布尔组件（NodeBooleanComponent）2.4 选择组件（NodeSwitchComponent）2.5 迭代组件（NodeIteratorComponent）2.6 FOR 控制组件（NodeForComponent）2.7 WHILE 条件循环三、声明式组件与脚本组件3.1 声明式组件开发3.2 脚本组件：11 种语言全面支持四、规则文件编写与 EL Builder4.1 三种格式：XML / JSON / YAML4.2 编程式构建：EL Builder五、经典编排模式5.1 管道/过滤器模式（Pipeline）5.2 并行汇聚模式（Fork-Join）5.3 责任链模式（Chain of Responsibility）5.4 策略模式 + 路由5.5 补偿事务模式（Saga）5.6 熔断降级模式5.7 批处理模式六、数据传递与生命周期6.1 五种数据传递方式6.2 多上下文管理6.3 生命周期6.4 全局切面（CmpAroundAspect）6.5 isEnd() 终止流程七、异常处理与重试7.1 组件内 try-catch7.2 RETRY 重试7.3 CATCH 异常捕获降级7.4 isContinueOnError() 并行容错7.5 TIMEOUT 超时控制八、规则热刷新机制8.1 原理概述8.2 文件监听模式8.3 Copy-on-Write 并发安全机制九、规则持久化与多源管理9.1 六种规则存储源9.2 典型配置示例十、监控体系10.1 内置命令行监控10.2 步骤追踪10.3 集成 Prometheus / Micrometer10.4 FlowEventPublisher 事件机制十一、性能优化策略11.1 解析模式选择11.2 Chain 缓存11.3 Slot 池与线程池调优11.4 性能基准参考十二、AI Agent 编排（v2.16.0 重磅特性）12.1 核心理念12.2 架构概览12.3 快速上手：DeepSeek Agent12.4 多 Agent 协作12.5 条件路由 Agent12.6 会话管理与 Memory12.7 支持的 LLM 平台十三、SPI 扩展机制十四、企业级部署方案14.1 Spring Boot 生产环境完整配置14.2 多环境配置策略14.3 Kubernetes 部署14.4 规则版本管理与灰度发布14.5 高可用架构十五、安全最佳实践15.1 规则安全检查15.2 基于角色的组件访问控制15.3 输入校验与日志脱敏十六、测试策略16.1 测试模块概览16.2 集成测试模板十七、常见问题排查手册17.1 问题分类速查17.2 排查 Checklist17.3 常见反模式十八、综合实战案例18.1 电商订单完整处理流程18.2 数据同步批处理18.3 动态审批工作流十九、总结附录：EL 表达式快速参考卡一、概述LiteFlow 是开源的轻量级流程编排引擎，至今已在 GitHub 上获得广泛关注。它的核心理念是将复杂的业务逻辑拆解为一个个独立的"组件"，再通过简洁的 EL 表达式将这些组件"编排"成完整的业务流程。v2.16.0 版本更是引入了 AI Agent 编排能力，使得 LiteFlow 不再局限于传统业务流程，甚至可以直接用于构建 LLM 驱动的智能体应用。本文将 Tutorial 2（组件开发与规则编排）和 Tutorial 3（高级特性与企业级最佳实践）两篇实战手册的核心内容融合为一体，按"组件开发 → 规则编排 → 高级特性 → 企业级实战"的逻辑线索递进讲解，帮助你从零掌握 LiteFlow 的全栈开发能力。二、组件开发全指南2.1 六种组件类型总览LiteFlow 提供了六种内置组件基类，覆盖了流程编排中几乎所有的执行语义：组件基类核心方法返回值典型用途NodeComponentprocess()void通用业务逻辑NodeBooleanComponentprocessBoolean()booleanIF 条件判断NodeSwitchComponentprocessSwitch()StringSWITCH 多路路由NodeIteratorComponentprocessIterator()Iterator迭代器循环NodeForComponentprocessFor()int循环次数控制NodeBooleanComponent（WHILE 场景）processBoolean()booleanWHILE 条件循环2.2 普通组件（NodeComponent）这是最常用的组件类型，用于执行任意业务逻辑：@Component("orderCheck")publicclassOrderCheckComponentextendsNodeComponent{@Overridepublicvoidprocess()throwsException{// 获取流程入参OrderDTOorder=this.getRequestData();// 获取上下文OrderContextctx=this.getFirstContextBean();if(order==null||StringUtils.isBlank(order.getOrderId())){thrownewRuntimeException("订单信息不完整");}if(order.getAmount().compareTo(BigDecimal.ZERO)=0){thrownewRuntimeException("订单金额必须大于0");}ctx.setOrderValid(true);ctx.addMessage("订单校验通过: "+order.getOrderId());}@OverridepublicbooleanisAccess(){// 准入检查：已校验过则跳过OrderContextctx=this.getFirstContextBean();returnctx!=null!Boolean.TRUE.equals(ctx.isOrderValid());}@OverridepublicvoidonSuccess()throwsException{System.out.println("[orderCheck] 执行成功");}@OverridepublicvoidonError(Exceptione)throwsException{System.err.println("[orderCheck] 执行失败: "+e.getMessage());}}核心 API 速查（均来自NodeComponent.java源码）：方法说明getRequestData()获取流程入参getFirstContextBean()获取默认上下文getContextBean(ClassT)按类型获取上下文getContextBean(String)按 ID 获取上下文getSlot()获取当前 SlotgetChainId()当前 chainIdgetNodeId()当前 nodeIdgetLoopIndex()循环索引getCurrLoopObj()循环当前对象setStepData(Object)设置步骤数据invoke2Resp(id, data)调用子 chain2.3 布尔组件（NodeBooleanComponent）用于 IF 条件分支判断，核心方法processBoolean()返回 true/false 决定分支走向：@Component("isVipUser")publicclassIsVipUserComponentextendsNodeBooleanComponent{@OverridepublicbooleanprocessBoolean()throwsException{Useruser=this.getRequestData();UserContextuserCtx=this.getContextBean(UserContext.class);booleanisVip=user!=nulluser.getLevel()=3;if(userCtx!=null){userCtx.setVip(isVip);}returnisVip;}}配合规则文件：chainname="vipProcessChain"IF(isVipUser, vipHandler, normalHandler);/chain支持 AND/OR/NOT 布尔组合：chainname="complexIf"IF( AND(isVip, hasPermission), THEN(vipAccess, logVip), OR(THEN(normalAccess, checkLimit), defaultHandler) );/chain2.4 选择组件（NodeSwitchComponent）用于 SWITCH 多路路由，processSwitch()返回目标节点的 nodeId：@Component("paymentRouter")publicclassPaymentRouterComponentextendsNodeSwitchComponent{@OverridepublicStringprocessSwitch()throwsException{OrderDTOorder=this.getRequestData();StringpayType=order.getPayType();switch(payType){case"ALIPAY":return"alipayHandler";case"WECHAT":return"wechatPayHandler";case"CREDIT":return"creditCardHandler";case"BALANCE":return"balancePayHandler";default:return"defaultPayHandler";}}}配合规则文件：chainname="paymentChain"SWITCH(paymentRouter).TO( alipayHandler, wechatPayHandler, creditCardHandler, balancePayHandler, DEFAULT(defaultPayHandler) );/chain注意:processSwitch()返回的字符串必须在.TO()列表中，否则会抛出异常。若定义DEFAULT，未匹配时走默认节点。2.5 迭代组件（NodeIteratorComponent）用于 ITERATOR 循环遍历集合：@Component("orderIterator")publicclassOrderIteratorComponentextendsNodeIteratorComponent{@OverridepublicIterator?processIterator()throwsException{BatchOrderRequestrequest=this.getRequestData();ListOrderDTOorders=request.getOrders();System.out.println("[orderIterator] 共 "+orders.size()+" 条订单待处理");returnorders.iterator();}}规则文件：chainname="batchProcessChain"THEN( prepareBatch, ITERATOR(orderIterator).DO( THEN(validateOrder, processOrder, saveResult) ), summarizeResult );/chain循环体内获取当前元素：@Component("processOrder")publicclassProcessOrderComponentextendsNodeComponent{@Overridepublicvoidprocess()throwsException{OrderDTOcurrentOrder=this.getCurrLoopObj();// 当前元素intindex=this.getLoopIndex();// 当前索引OrderDTOprevOrder=this.getPreLoopObj();// 上一轮元素intprevIndex2=this.getPreNLoopIndex(2);// 前 N 次循环索引}}2.6 FOR 控制组件（NodeForComponent）用于控制循环次数：@Component("retryCountDecider")publicclassRetryCountDeciderComponentextendsNodeForComponent{@OverridepublicintprocessFor()throwsException{RetryContextctx=this.getContextBean(RetryContext.class);returnctx.getMaxRetry();}}规则文件支持固定次数和动态次数：!-- 固定次数 --chainname="fixedRetryChain"FOR(3).DO(retryOperation);/chain!-- 动态次数（由组件决定）--chainname="dynamicRetryChain"FOR(retryCountDecider).DO(retryOperation);/chain!-- FOR + THEN 组合 --chainname="forWithMultipleSteps"FOR(5).THEN(initLoop, doWork, cleanupLoop);/chain2.7 WHILE 条件循环@Component("hasMoreData")publicclassHasMoreDataComponentextendsNodeBooleanComponent{@OverridepublicbooleanprocessBoolean()throwsException{DataContextctx=this.getContextBean(DataContext.class);booleanmore=ctx.getCurrentOffset()ctx.getTotalCount();if(!more){System.out.println("[hasMoreData] 数据已全部处理完毕");}returnmore;}}规则文件：chainname="dataSyncChain"WHILE(hasMoreData).DO( THEN(fetchPage, processData, updateOffset) ).breakIfMax(100);!-- 最大循环 100 次，防止死循环 --/chain三、声明式组件与脚本组件3.1 声明式组件开发声明式组件让你不继承任何基类即可创建组件，完全摆脱类继承约束：@LiteflowCmpDefine(NodeTypeEnum.COMMON)// 声明为普通组件publicclassDeclarativeCheckComponent{@LiteflowMethod(LiteFlowMethodEnum.PROCESS)publicvoidprocess(NodeComponentbindCmp){ObjectrequestData=bindCmp.getRequestData();OrderContextctx=bindCmp.getFirstContextBean();bindCmp.setStepData("checkResult: OK");}@LiteflowMethod(LiteFlowMethodEnum.IS_ACCESS)publicbooleanisAccess(NodeComponentbindCmp){OrderContextctx=bindCmp.getFirstContextBean();returnctx!=nullctx.isEnabled();}@LiteflowMethod(LiteFlowMethodEnum.ON_ERROR)publicvoidonError(NodeComponentbindCmp,Exceptione){System.err.println("[DeclarativeCheck] 出错: "+e.getMessage());}}声明式布尔组件和选择组件：@LiteflowCmpDefine(NodeTypeEnum.BOOLEAN)publicclassDeclarativeBooleanComponent{@LiteflowMethod(LiteFlowMethodEnum.PROCESS_BOOLEAN)publicbooleanprocessBoolean(NodeComponentbindCmp){Useruser=bindCmp.getRequestData();returnuser!=nulluser.isActive();}}@LiteflowCmpDefine(NodeTypeEnum.SWITCH)publicclassDeclarativeSwitchComponent{@LiteflowMethod(LiteFlowMethodEnum.PROCESS_SWITCH)publicStringprocessSwitch(NodeComponentbindCmp){OrderDTOorder=bindCmp.getRequestData();returnorder.getType()+"Handler";}}生命周期方法映射表：枚举值对应方法适用组件类型PROCESSprocess()COMMONPROCESS_BOOLEANprocessBoolean()BOOLEANPROCESS_SWITCHprocessSwitch()SWITCHPROCESS_ITERATORprocessIterator()ITERATORPROCESS_FORprocessFor()FORIS_ACCESSisAccess()所有BEFORE_PROCESSbeforeProcess()所有AFTER_PROCESSafterProcess()所有ON_SUCCESSonSuccess()所有ON_ERRORonError()所有IS_ENDisEnd()所有IS_CONTINUE_ON_ERRORisContinueOnError()