LiteFlow组件式流程引擎框架

LiteFlow组件式流程引擎框架

前言 产品的需求: 以东哥家的京东为例,我现在进了一批只需998的好家伙.每次618要进行大促销668,双十一888,双十二180. 初级开发 看到需求大喊一句,这么简单看不起我?于是一顿操作猛如虎.写道: if ("618".equals(day)){ System.out.println("668...

前言

产品的需求:

以东哥家的京东为例,我现在进了一批只需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");
        }

中级开发

image.png

好家伙,你这是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 map;

    public void run(String name) throws Exception {
        for (Map.Entry 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种模式,提供常见常见的表达式语句
  • 提供无级嵌套子流程模式
  • 数据槽高并发隔离机制
  • 自带简单的监控,能够知道每个组件的运行耗时排行

架构设计

image.png

Liteflow适用于哪些场景

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

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

使用文档地址

springboot中集成liteflow

  • 引入依赖
     com.yomahubliteflow-spring-boot-starter${project.parent.version}
  • 编写流程节点
@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
  • 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

使用推荐:

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

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

image.png

文章来源于互联网:LiteFlow组件式流程引擎框架

0

评论0

鱼翔浅底,鹰击长空,驼走大漠
没有账号? 注册  忘记密码?