LiteFlow组件式流程引擎框架

前言

产品的需求:

以东哥家的京东为例,我现在进了一批只需998的好家伙.每次618要进行大促销668,双十一888,双十二180.

初级开发

看到需求大喊一句,这么简单看不起我?于是一顿操作猛如虎.写道:

      if ("618".equals(day)){
            System.out.println("668");
        }else if ("11.11".equals(day)){
            System.out.println("888");
        }else if ("12.12".equals(day)){
            System.out.println("180");
        }else{
            System.out.println("998");
        }

中级开发

好家伙,你这是ifelse一哥呀 于是乎上来一套策略

public interface NodeComponent {
  void  process() ;
}

@Component
public class AComponent extends NodeComponent {
    @Override
    public void process() {
        /**
         * 这里逻辑省略
         * 
         */
        System.out.println("618");
    }
}
@Component
public class BComponent extends NodeComponent {
    @Override
    public void process() {
        /**
         * 这里逻辑省略
         * 
         */
        System.out.println("11.11");
    }
}
//下面省略12.12

//主流程
@Component
public class TestFlow {

    @Resource
    private Map<String, NodeComponent> map;

    public void run(String name) throws Exception {
        for (Map.Entry<String, NodeComponent> entry : map.entrySet()) {
            String key = entry.getKey();
            if (StringUtils.equals(name,key)){
                entry.getValue().process();
            }
        }
    }
}

产品又搞事情了

我这还有一个系统需求如下:
需要进行查询前的校验,先进行A校验->B校验->>C校验->>D校验,这时候怎么办?..责任链?
那如果流程改了
B校验->A校验->>C校验->>D校验
或者
B校验->D校验->>A校验->>C
思考一下?你是不是想打一顿产品?别急,这时候新玩意来了.....往下看>>>>>>>

LIteFlow闪亮登场

image.png

LiteFlow简介

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

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

优点:

• 编排利器
• 规则轻量
• 优雅稳定
• 扩展灵活

特性:

• 复杂业务的解耦利器，为所有组件提供统一的实现协议
• 基于规则文件来编排流程，并可进行热编排
• 框架中支持zookeeper流程配置，即时推送修改内容
• 能自由扩展配置持久化源，提供扩展接口
• 支持springboot的自动装配，也支持spring的配置和非spring的项目
• 提供串行和并行2种模式，提供常见常见的表达式语句
• 提供无级嵌套子流程模式
• 数据槽高并发隔离机制
• 自带简单的监控，能够知道每个组件的运行耗时排行

架构设计

Liteflow适用于哪些场景

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

Liteflow的Gitee仓库：https://gitee.com/dromara/liteFlow
Liteflow的Github仓库：https://github.com/dromara/liteflow

使用文档地址

springboot中集成liteflow

• 引入依赖

     <dependency>
          <groupId>com.yomahub</groupId>
            <artifactId>liteflow-spring-boot-starter</artifactId>
            <version>${project.parent.version}</version>
        </dependency>

• 编写流程节点

@Component("a")
public class AComponent extends NodeComponent {
    @Override
    public void process() {
        String str = this.getSlot().getRequestData();
        System.out.println(str);
        System.out.println("Acomponent executed!");

        this.getSlot().setOutput(this.getNodeId(), "A component output");
    }

}

@Component("b")
public class BComponent extends NodeComponent {
    @Override
    public void process() {
        try {
            Thread.sleep(400L);
            String[] temp = new String[1000];
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Bcomponent executed!");

    }

}

• 流程测试

@Component
public class TestFlow{

    @Resource
    private FlowExecutor flowExecutor;

    @Override
    public void run(String... args) throws Exception {
        Slot slot = flowExecutor.execute("chain3", "it's a request");
        System.out.println(slot);
    }
}

• 创建flow.xml文件 src/main/resources/config/flow.xml

  
  
  image.png

<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="chain1">
        <then value="a,cond(b|d)"/> <!-- cond是条件节点，根据cond里的逻辑决定路由到b节点还是d节点,可以配置多个 -->
        <then value="e,f,g"/>
    </chain>

    <chain name="chain2">
        <then value="a,c"/> <!-- then表示串行 -->
        <when value="b,d"/> <!-- when表示串行 -->
        <then value="e,f,g"/>
    </chain>
</flow>

• application.properties

liteflow.rule-source=config/flow.xml
#------以下非必须-------
#slot的数量，默认值为1024
liteflow.slot-size=2048
#异步线程最长的等待时间秒(只用于when)，默认值为15
liteflow.when-max-wait-second=20
#是否开启监控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

总结

1) 引入依赖
2) 定义流程节点继承NodeComponent 
3) 注入:   
      @Resource 
      private FlowExecutor flowExecutor;
4)application.properties:
      liteflow.rule-source=config/flow.xml

使用推荐:

• 用完只能说大佬牛批.感谢这个框架.有些流程繁琐的业务终于不怕改动了.
• 日常开发用到到责任链模式,策略模式的使用场景,也可以尝试引入当前框架,相对更加简单优雅.

用完后,老板大喊全体起立