流程编排LiteFlow
流程编排LiteFlow
LiteFlow真的是相见恨晚啊,之前做过的很多系统,都会用各种if else,switch这些来解决不同业务方提出的问题,有时候还要“切一个分支”来搞这些额外的事情,把代码搞得一团糟,毫无可读性而言。如何打破僵局?LiteFlow为解耦逻辑而生,为编排而生,在使用LiteFlow之后,你会发现打造一个低耦合,灵活的系统会变得易如反掌!
背景
之前做过一个数据分发系统,需要消费kafka的数据,下游有不同的业务,每个业务可能有共同的地方,也有不同的地方,在经过各类的处理之后,最后数据分发到下游里面去,真个流程如下。
如果要在一个代码实现上诉功能,我们第一反应可能是责任链设计模式,每个业务一条链路,
在Spring中,类似下面的代码:
public abstract class Handler {
abstract void handler(Request request);
}
@Component
@Slf4j
public class HandlerA extends Handler{
@Override
public void handler(Request request) {
log.info("处理器1");
}
}
@Component
@Slf4j
public class HandlerB extends Handler {
@Override
public void handler(Request request) {
log.info("处理器2");
}
}
@Component
@Slf4j
public class HandlerC extends Handler{
@Override
public void handler(Request request) {
log.info("处理器3");
}
}
@Component
@Slf4j
public class HandlerD extends Handler{
@Override
public void handler(Request request) {
log.info("处理器4");
}
}
//然后我们定义一个枚举类,用来配置不同业务需要经历过的处理器。
public enum HandleBuz {
Business_1(HandlerA,HandlerB),
Business_2(HandlerB,HandlerC),
Business_3(HandlerA,HandlerD);
public final Class<? extends Handler>[] processors;
public HandleBuz(Class<? extends Handler>[] processors){
this.processors=processors;
}
public void handle(){
for (Handler handler : processors) {
handler.handler(xxx);
}
}
}
通过配置责任链,可以灵活地组合处理对象,实现不同的处理流程,并且可以在运行时动态地改变处理的顺序,由于责任链模式遵循开闭原则,新的处理者可以随时被加入到责任链中,不需要修改已有代码,提供了良好的扩展性。但实际上面对各种需求的时候,没法做到完全的解耦,比如对于HandlerA,如果业务1和业务2都有定制化的需求,此时是应该再HandlerA中用if else解决,还是再额外开个HandlerA_1和HandlerA_2。这类特性需求会非常多,最终把代码可读性变得越来越低。
一、为什么需要流程编排
LiteFlow由Baidu开源,专注于逻辑驱动流程编排,通过组件化方式快速构建和执行业务流程,有效解耦复杂业务逻辑。它以其轻量级、快速、稳定且可编排的特性,在业务流程管理、规则引擎、工作流、订单处理、数据处理、微服务编排以及智能化流程管理等领域都有广泛的应用前景。
二、它可以解决什么问题
<chain name="chain4">
THEN(
SWTICH(分业务).to(
)
A, B,
WHEN(
THEN(C, WHEN(J, K)),
D,
THEN(H, I)
),
SWITCH(X).to(
M,
N,
WHEN(Q, THEN(P, R)).id("w01")
),
Z
);
</chain>
三、LiteFlow改造之后
@Slf4j
@LiteflowComponent("a")
public class HandlerA extends NodeComponent {
@Override
public void process() throws Exception {
Customizer contextBean = this.getContextBean(Customizer.class);
}
}
@Slf4j
@LiteflowComponent("b")
public class HandlerB extends NodeComponent {
@Override
public void process() throws Exception {
Customizer contextBean = this.getContextBean(Customizer.class);
}
}
@Slf4j
@LiteflowComponent("c")
public class HandlerC extends NodeComponent {
@Override
public void process() throws Exception {
Customizer contextBean = this.getContextBean(Customizer.class);
}
}
@Slf4j
@LiteflowComponent("d")
public class HandlerD extends NodeComponent {
@Override
public void process() throws Exception {
Customizer contextBean = this.getContextBean(Customizer.class);
}
}
再配合LiteFlow的EL表达式使用
文档
1.【腾讯文档】业务处理复杂 https://docs.qq.com/flowchart/DZVFURmhCb0JFUHFD
2.【腾讯文档】业务处理复杂2 https://docs.qq.com/flowchart/DZXVOaUV5VGRtc3ZD