题外话：
最近喜欢上骑摩托车了，不是多大排量的摩托车，小排量踏板，当骑车的时候真的可以获得快乐抛却烦恼，八九十的速度也是可以到的，但是还是要管住右手，慢慢骑。希望以后可以换个自己喜欢的巡航，骑帅不骑快。
背景：
最近在做大数据平台，数据治理相关，大数据量数据的清洗、转换、补全、融合等操作处理，最开始的设计的是不同数据任务，但是这样的话就比较固化，可拓展性不强。基于对数据平台的产品化考虑，决定将数据的流式任务处理具象成流程化处理。
在码云及git上面看了些开源项目，研究了一下，感觉使用场景匹配度不是太高，并且代码及功能有些重，决定还是使用LiteFlow自己开发相应的流程组件，最终实现数据流程任务的可编排。

学习LiteFlow

具体可以查看下官方文档：LiteFlow官方文档，该说不说这个文档实在是太全面了，讲解也比较详细。
从HelloWorld到安装运行，从规则文件到各种组件，然后是数据上下文、动态构造及各种高级特性，接下来简单说一下一般场景下使用到的重要功能点：

spring boot整合LiteFlow

依赖

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

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

配置

组件定义

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

@Component("a")
public class ACmp extends NodeComponent {@Overridepublic void process() {//do your business}
}

以此类推再分别定义b,c组件：

@Component("b")
public class BCmp extends NodeComponent {@Overridepublic void process() {//do your business}
}

@Component("c")
public class CCmp extends NodeComponent {@Overridepublic void process() {//do your business}
}

spring boot配置文件

然后，在你的SpringBoot的application.properties或者application.yml里添加配置(这里以properties为例，yml也是一样的)

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

规则文件的定义

同时，你得在resources下的config/flow.el.xml中定义规则，SpringBoot在启动时会自动装载规则文件。

<?xml version="1.0" encoding="UTF-8"?>
<flow><chain name="chain1">THEN(a, b, c);</chain>
</flow>

执行

可以在Springboot任意被Spring托管的类中拿到flowExecutor，进行执行链路：

@Component
public class YourClass{@Resourceprivate FlowExecutor flowExecutor;public void testConfig(){LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");}
}

组件

包括：普通组件、选择组件、条件组件、次数循环组件、条件循环组件、迭代循环组件及退出循环组件。
以普通组件为例：
普通组件节点需要继承NodeComponent，可用于THEN和WHEN关键字中。需要实现process方法：

@LiteflowComponent("a")
public class ACmp extends NodeComponent {@Overridepublic void process() {System.out.println("ACmp executed!");}
}

@LiteflowComponent继承自@Component，如果你在spring体系的环境里，组件里可以任意注入spring的bean进行使用。@LiteflowComponent的参数a，就是你在写EL规则时需要用到组件ID。

组件中会有需要可以覆盖重写的方法， 具体就不罗列了，可以看下liteflow官方文档。

EL规则

LiteFlow在2.8.X版本中设计了非常强大的规则表达式。一切复杂的流程在LiteFlow表达式的加持下，都异常丝滑简便。
你只需要很短的时间即可学会如何写一个很复杂流程的表达式。简单列举下串行及并行的EL规则表达式写法：

串行

关键字：THEN，必须大写

<chain name="chain1">THEN(a, b, c, d);
</chain>

<chain name="chain1">THEN(a, b, c, d);
</chain>

上面两种写法是等价的。

并行

关键字：WHEN，必须大写。

<chain name="chain1">WHEN(a, b, c);
</chain>

可以串行。并行组合：

<chain name="chain1">THEN(a,WHEN(b, c, d),e);
</chain>

动态构建组件

一般业务场景其实并不会是固定的流程，而是动态的，后端搭配前端完成流程编排，像上面一样固定的组件其实实际使用场景较少，适用于固定流程的。但是如果流程不固定的话，就需要用到动态构建组件了。
贴一下官方代码吧：

//构建一个普通组件
LiteFlowNodeBuilder.createCommonNode().setId("a").setName("组件A").setClazz("com.yomahub.liteflow.test.builder.cmp.ACmp").build();//构建一个普通条件组件
LiteFlowNodeBuilder.createSwitchNode().setId("a").setName("组件A").setClazz("com.yomahub.liteflow.test.builder.cmp.ACmp").build();

动态构建普通组件，首先要定义好ACmp类，通过LiteFlowNodeBuilder.createCommonNode()方法链式构建组件，其中setId、setName、setClazz都是可以动态指定的。

这里的节点类（ACmp），不需要你去声明@LiteflowComponent或者@Component，如果项目是spring体系的话，LiteFlow框架会自动的把节点类注入到spring上下文中。
所以你仍旧可以在这个类(ACmp)里使用@Autowired和@Resource等等之类的spring任何注解，也就是说可以正常使用业务service。

贴一个ACmp代码吧：

/*** @Description demo* @Author: phli* @CreateTime: 2023/9/13 17:05*/
public class ACmp extends NodeComponent {@Resourceprivate RestTemplate restTemplate;@Overridepublic void process() throws Exception {//自己的业务代码Object object = restTemplate.postForObject("", null, Object.class);}@Overridepublic void onSuccess() throws Exception {super.onSuccess();}@Overridepublic void onError(Exception e) throws Exception {super.onError(e);}
}

简单说一下：process就是该组件的执行逻辑方法，onSuccess方法即为流程的成功事件回调，onError就是流程的失败事件回调。一些组件中会用到的内置方法（我用到的）：

• 获取组件id：getNodeId；
• 获取组件别名；getName；
• 获取流程的初始参数：getChainName；
• 获取流程的初始参数：getRequestData；

动态构建chain（流程）

上面讲过我们可以再规则配置文件中，会通过：

flowExecutor.execute2Resp("chain1", "arg");//chain1
<?xml version="1.0" encoding="UTF-8"?>
<flow><chain name="chain1">THEN(a, b, c);</chain>
</flow>

执行chainName为”chain1“的流程。上面说过这种方式都比较死板，基本没有拓展性，我们还可以通过代码来构建chain：

LiteFlowChainELBuilder.createChain().setChainId("chainA").setChainName("chain2").setEL("THEN(a, b, WHEN(c, d))"
).build();

构建chain的前提是先要构建组件，不然流程创建会出错，提示找不到组件。chainId、chainName及EL都可以动态指定。

值得提一下的是，由于用构造模式是一个链路一个链路的添加，如果你用了子流程，如果chain1依赖chain2，那么chain2要先构建。否则会报错。

销毁chain

可以通过以下代码销毁chain：

FlowBus.removeChain("你的流程ID")

高级特性

包括但不限于：前后置组件、组件回滚、组件切面、异步线程池、组件监控、替补组件、组件重试等等。具体就不展开说了，可以看下官方文档，真的很全：

整个流程节点如果多的话，执行比较慢可以将放到异步逻辑里面。