本期推荐的 LiteFlow是一个轻量，快速，稳定可编排的组件式流程引擎。

LiteFlow的架构

LiteFlow框架的作用

LiteFlow就是为解耦复杂逻辑而生，如果你要对复杂业务逻辑进行新写或者重构，用LiteFlow最合适不过。它是一个轻量，快速的组件式流程引擎框架，组件编排，帮助解耦业务代码，让每一个业务片段都是一个组件，并支持热加载规则配置，实现即时修改。

使用LiteFlow，你需要去把复杂的业务逻辑按代码片段拆分成一个个小组件，并定义一个规则流程配置。这样，所有的组件，就能按照你的规则配置去进行复杂的流转。

LiteFlow适用于哪些场景

LiteFlow适用于拥有复杂逻辑的业务，比如说价格引擎，下单流程等，这些业务往往都拥有很多步骤，这些步骤完全可以按照业务粒度拆分成一个个独立的组件，进行装配复用变更。使用LiteFlow，你会得到一个灵活度高，扩展性很强的系统。因为组件之间相互独立，也可以避免改一处而动全身的这样的风险。

项目特性

• 复杂业务的解耦编排利器，为所有组件提供统一化的实现方式
• 基于规则文件来编排流程，支持xml,json,yml三种规则文件写法方式
• 框架中提供本地文件配置源，zk配置源的实现
• 框架提供自定义配置源，只需实现一个接口，即可从任何地方加载配置源
• 支持SpringBoot的自动装配，也支持Spring的配置和非Spring的项目
• 提供串行和并行2种模式，提供常见常见的表达式语句
• 可以定义脚本语言节点，支持QLExpress和Groovy两种脚本
• 组件可以支持重试，每个组件均可自定义重试配置和指定异常
• 提供无级嵌套的显式子流程模式，隐式子流程模式
• 数据槽隔离机制，在多并发下上下文独立而稳定
• 支持优雅平滑热刷新特性
• 对系统损耗极低，可以稳定运行在核心业务大规模的微服务中
• 自带简单的监控，能够知道每个组件的运行耗时排行

集成SpringBoot

LiteFlow提供了
liteflow-spring-boot-starter依赖包，提供自动装配功能

<dependency>
  <groupId>com.yomahub</groupId>
  <artifactId>liteflow-spring-boot-starter</artifactId>
  <version>2.6.10</version>
</dependency>

配置-组件的定义

在依赖了以上jar包后。 你需要定义并实现一些组件，确保SpringBoot会扫描到这些组件并注册进上下文

@Component("a")
public class ACmp extends NodeComponent {

    @Override
    public void process() {
        //do your business
    }
}

SpringBoot配置文件

liteflow.rule-source=config/flow.xml
#-----------------以下非必须-----------------
#liteflow是否开启，默认为true
liteflow.enable=true
#liteflow的banner是否开启，默认为true
liteflow.print-banner=true
#zkNode的节点，只有使用zk作为配置源的时候才起作用
liteflow.zk-node=/lite-flow/flow
#slot的数量，默认值为1024
liteflow.slot-size=1024
#并行节点的线程池Builder，LiteFlow提供了默认的Builder
liteflow.thread-executor-class=com.yomahub.liteflow.thread.LiteFlowDefaultExecutorBuilder
#异步线程最长的等待时间秒(只用于when)，默认值为16
liteflow.when-max-wait-seconds=20
#异步线程池最大线程数，默认为16
liteflow.when-max-workers=16
#异步线程池等待队列数，默认为512
liteflow.when-queue-limit=512
#是否在启动的时候就解析规则，默认为true
liteflow.parse-on-start=true
#全局重试次数，默认为0
liteflow.retry-count=0
#是否支持不同类型的加载方式混用，默认为false
liteflow.support-multiple-type=false
#是否开启监控log打印，默认值为false
liteflow.monitor.enable-log=true
#监控队列存储大小，默认值为200
liteflow.monitor.queue-limit=300
#监控一开始延迟多少执行，默认值为300000毫秒，也就是5分钟
liteflow.monitor.delay=10000
#监控日志打印每过多少时间执行一次，默认值为300000毫秒，也就是5分钟
liteflow.monitor.period=10000

规则文件的定义

同时，你得在resources下的config/flow.xml中定义规则：

<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="chain1">
        <then value="a,b,c"/>
        <when value="d,e"/>
    </chain>
</flow>

执行

然后你就可以在任意的类中拿到flowExecutor，进行执行链路

@Component
public class MainTest{
    
    @Resource
    private FlowExecutor flowExecutor;
    
    @Test
    public void testConfig(){
        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
    }
}

性能表现

LiteFlow绝大部分工作都是在启动时完成，包括解析规则，注册组件，组装元信息。而执行链路时几乎对系统没有额外的消耗。框架在设计之初就是为公司的核心业务量身打造，在性能表现问题上格外注意。所以也对核心代码进行了性能方面的优化。

实际表现中，LiteFlow执行效率很高，在公司级核心业务上面，50多个业务组件组成的链路，在实际压测中单点达到了1500的TPS，也经历过双11，明星顶流带货等大流量的考验。

测试示例

业务为一个价格计算引擎，有11个业务节点，业务逻辑丰富，只不过数据为mock，不走数据库IO。

基于这个Demo业务进行了压测，压测机器为mac m1 pro ，压测工具为apache jmeter，压测结果为：

100并发

300并发