springboot整合规则引擎(liteflow)使用
java整合规则引擎,实现组件封装调用!!LiteFlow是一个流程编排框架,可将公共代码封装为组件并按需组合。它支持通过XML配置流程链,实现组件间的参数共享
·
规则引擎,定义业务执行逻辑,把公共组件抽出来进行封装。
作用:
- 可以将公有代码抽为组件
- 根据不同的模式走不同的组件流程
- 参数可以在组件之间共享
1、导入依赖
<dependency>
<groupId>com.yomahub</groupId>
<artifactId>liteflow-spring-boot-starter</artifactId>
<version>2.13.1</version>
</dependency>
2、组件定义
@LiteflowComponent("a")
public class ACmp extends NodeComponent {
// 走这个流程 通过默认上下文方式
@Override
public void process() {
User user = this.getContextBean(User.class);
user.setRealName(user.getRealName()+"A");
System.out.println(user);
System.out.println("AAA");
//do your business
}
}
@LiteflowComponent("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
User user = this.getContextBean(User.class);
user.setRealName(user.getRealName()+"B");
System.out.println(user);
System.out.println("BBB");
//do your business
}
// 走这个流程 注解方式
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS,nodeType = NodeTypeEnum.COMMON, nodeId = "b")
public void processB(NodeComponent bindCmp,@LiteflowFact("user") User user) {
// User user = bindCmp.getContextBean(User.class);
user.setRealName(user.getRealName()+"B2");
System.out.println(user);
System.out.println("BBB2");
}
}
@LiteflowComponent("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
User user = this.getContextBean(User.class);
user.setRealName(user.getRealName()+"C");
System.out.println(user);
System.out.println("CCC");
}
// 走这个流程 NodeComponent获取方式
@LiteflowMethod(value = LiteFlowMethodEnum.PROCESS,nodeType = NodeTypeEnum.COMMON, nodeId = "c")
public void processB(NodeComponent bindCmp) {
User user = bindCmp.getContextBean(User.class);
user.setRealName(user.getRealName()+"C2");
System.out.println(user);
System.out.println("CCC");
}
}
3、配置yml、xml
yml
liteflow.rule-source=config/flow.xml
xml配置链路组件
可以定义多条链路,每条链路执行顺序可以定义,就是把需要执行的组件以及顺序排列好,后面业务可以直接调用,同时可以根据需求定义。目前是最简单的一条完整执行链路。
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<chain name="chain1">
THEN(a, c, b);
</chain>
</flow>
4、执行调用
启动类加扫描
@SpringBootApplication
//把你定义的组件扫入Spring上下文中
@ComponentScan({"com.xxx.xxx.cmp"})
public class LiteflowExampleApplication {
public static void main(String[] args) {
SpringApplication.run(LiteflowExampleApplication.class, args);
}
}
业务类调用
@Component
public class FlowService{
@Resource
private FlowExecutor flowExecutor;
public void testConfig(){
System.out.println("start------------------");
User user = new User();
user.setRealName("张三");
user.setAddIp("1.2.3.4");
user.setAddress("中国四川成都");
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg111111", user);
System.out.println("end-----------------------");
}
}
5、测试结果
控制台打印参数顺序:
user的RealName为:AC2B2 ,流程是先a 再c 再b

魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。
更多推荐
所有评论(0)