当前位置：首页 > news >正文

Solon 集成 LiteFlow：轻量级工作流引擎的极简实践指南

news 2025/7/29 12:44:49

在复杂的业务场景中，工作流引擎是解耦业务逻辑、提升可维护性的核心组件。传统的BPM引擎（如 Activiti、Flowable）虽功能强大，但学习曲线陡峭且资源消耗较大。LiteFlow 作为一款国产轻量级规则引擎/流程引擎，以其零学习成本、高可扩展性和极致性能成为微服务架构下的理想选择。本文将详细讲解 Solon 集成 LiteFlow 的全过程，助你轻松驾驭轻量级流程编排。

一、LiteFlow核心优势

轻量嵌入：仅需2个核心JAR包，无数据库依赖
规则驱动：基于EL表达式的链式规则配置，变更实时生效
组件化设计：业务逻辑封装为可复用组件，支持热插拔
高性能：无反射执行，单线程每秒可处理万级任务
多类型支持：顺序流、条件分支、循环、嵌套、异步并行

二、Solon 集成实战

准备：添加依赖包

<!-- pom.xml 依赖 -->
<dependencies><dependency><groupId>com.yomahub</groupId><artifactId>liteflow-solon-plugin</artifactId><version>最新版</version></dependency>
</dependencies>

步骤1：定义流程组件

import com.yomahub.liteflow.core.NodeComponent;
import org.noear.solon.annotation.Managed;// 普通组件示例
@Managed("paymentAction")
public class PaymentAction extends NodeComponent {@Overridepublic void process() {PaymentContext context = this.getContextBean(PaymentContext.class);// 执行支付逻辑System.out.println("处理支付, 订单:" + context.getOrderId());}
}// 条件组件示例（用于分支判断）
@Managed("userCheck")
public class UserCheck extends NodeComponent {@Overridepublic void process() {UserContext context = this.getContextBean(UserContext.class);if(context.isVip()) {this.setIsEnd(true);  // 终止流程}}
}

步骤2：配置流程规则

resources/flow.yml 配置EL表达式规则：

liteflow:rule-source: config/flow.el.xml

resources/config/flow.el.xml：

<?xml version="1.0" encoding="UTF-8"?>
<flow><chain name="orderProcess">THEN(initOrder, WHEN(checkInventory, checkUserCredit),SWITCH(choosePayWay).TO(CASE(aliPay).DO(aliPayAction),CASE(wechatPay).DO(wechatPayAction)),AFTER(paymentAction).WHEN(userCheck));</chain>
</flow>

步骤3：初始化上下文并执行流程

import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import org.noear.solon.annotation.*;@Controller
public class OrderController {@Injectprivate FlowExecutor flowExecutor;@Post@Mapping("/submitOrder")public String submitOrder(@Body OrderDTO order) {OrderContext context = new OrderContext();context.setOrderId(order.getId());context.setAmount(order.getAmount());LiteflowResponse response = flowExecutor.execute2Resp("orderProcess", context, OrderContext.class);return response.isSuccess() ? "订单成功" : "流程失败";}
}

三、高级特性应用

异步并行执行

<!-- 配置并行节点 -->
<chain name="parallelChain">THEN(a, WHEN(b, c, d),  <!-- b,c,d并行执行 -->e);
</chain>

嵌套子流程

<chain name="mainFlow">THEN(prepare, SUB(orderProcess), notify);
</chain>

组件降级处理

import com.yomahub.liteflow.core.NodeComponent;
import org.noear.solon.annotation.Managed;@Managed("paymentAction")
public class PaymentAction extends NodeComponent {@InjectFallbackService fallbackService;@Overridepublic void process() {...}@Overridepublic void onError() {// 支付失败时执行补偿逻辑fallbackService.compensate();}
}

规则热更新

import com.yomahub.liteflow.flow.FlowBus;
import org.noear.solon.annotation.Managed;
import org.noear.solon.core.bean.LifecycleBean;// 动态添加规则
FlowBus.addChain("newChain", "THEN(a,b,c)");// 监听规则变化
@Managed
public class FlowConfig implements LifecycleBean {@Overridepublic void postStart() throws Throwable {FileWatcher.watch(Paths.get("config/flow"),() -> FlowBus.reloadRule());}
}

四、监控与调试

流程跟踪

LiteflowResponse response = flowExecutor.execute2Resp("orderProcess", context, OrderContext.class,// 开启执行链路跟踪SlotCallbackBuilder.builder().build()
);System.out.println(response.getExecuteStepStr());

输出示例：initOrder[✓] => checkInventory[✓] => checkUserCredit[✓] => ...

可视化监控（需企业版）

liteflow:monitor:enable-log: truequeue-limit: 200delay: 30period: 120

五、最佳实践建议

上下文设计原则

使用独立Context对象传递流程数据
避免在组件中操作数据库事务（应在Service层控制）

组件规范

单个组件代码不超过200行
组件命名采用"业务域+操作"格式（如：stockDeduct）

异常处理

业务异常通过 throw BusinessException 中断流程
系统异常自动触发 onError 回调

规则管理进阶

// 从数据库加载规则
@Managed
public class DBRuleLoader implements RuleSource {@Overridepublic String loadRules() {return ruleMapper.selectByApp("order-service");}
}