·设为首页收藏本站📧邮箱修改🎁免费下载专区💎积分✅卡密📒收藏夹👽聊天室
DZ插件网 门户 网站安全 查看内容

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!

2024-8-21 10:29| 发布者: 哥斯拉| 查看: 92454| 评论: 0

摘要: mall学习教程官网:macrozheng.com接到需求最近正好公司里有个需求,一个短信业务接了多个第三方供应商,某些业务需要查询第三方供应商剩余的短信包数量去选择剩余量最多的渠道去批量发送。有些业务是指定了某个短信 ...

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!3199 作者: 来源: 发布时间:2024-8-21 10:29

mall学习教程官网:macrozheng.com

接到需求


最近正好公司里有个需求,一个短信业务接了多个第三方供应商,某些业务需要查询第三方供应商剩余的短信包数量去选择剩余量最多的渠道去批量发送。有些业务是指定了某个短信供应商,有些场景需要根据业务的值去动态判断该用哪个供应商。场景非常复杂,还经常变化。

以前的代码实在惨不忍睹,选择剩余量最多的渠道是一个个去查的,然后获得结果去比较。至于指定的供应商和根据业务的值去判断选择供应商则是用大量的if else去嵌套各种判断。每次看到这坨代码真的觉得太粗糙了。关键是有些供应商还经常变,新接的供应商需要替代旧的供应商,加入这一大坨代码里。业务的判断条件还时不时变化一下。

出了几次问题之后,领导看不下去了,叫我想办法去优化。

我理了理逻辑,整个关系图应该是这样的,其中我把一个个去查的变成了并行去查,为了节约串行去查的IO耗时问题。

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!6224 作者: 来源: 发布时间:2024-8-21 10:29

其中有些复杂查库逻辑,判断幂等性的步骤我就去掉了。只挑选了关键的步骤画上去。

叫我去重构这个慢慢写也能写出,但是关键的是,每个步骤和判断逻辑还时不时变化下。这就要求我的代码非常灵活。所以在设计时,一直很苦恼该如何去设计。

选择规则引擎


在小组开交流会的时候,有其他组的小伙伴和我安利了一个开源框架-LiteFlow。

经过研究这款开源框架,发现LiteFlow是一个国产规则引擎,能够编排任意复杂的流程,还支持热刷新。这基本上完全契合我的需求啊!

文档很详细,很NICE,大概看了半天就全部学完了。发现新版本的LiteFlow的规则是用EL表达式来写的。语法总共数下来也就10个左右,非常好理解。

比如这种图:

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!3011 作者: 来源: 发布时间:2024-8-21 10:29

这或许是一个对你有用的开源项目,mall项目是一套基于 SpringBoot + Vue + uni-app 实现的电商系统(Github标星60K),采用Docker容器化部署,后端支持多模块和微服务架构。包括前台商城项目和后台管理系统,能支持完整的订单流程!涵盖商品、订单、购物车、权限、优惠券、会员、支付等功能!
  • Boot项目:https://github.com/macrozheng/mall
  • Cloud项目:https://github.com/macrozheng/mall-swarm
  • 视频教程:https://www.macrozheng.com/video/

项目演示:
新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!5154 作者: 来源: 发布时间:2024-8-21 10:29


在LiteFlow用规则表示就是:
<chain name="chain1">
    THEN(
        a,
        WHEN(b, THEN(c, d)),
        e
    )
</chain>

其中THEN是代表串行,WHEN代表并行执行,这种语法,一看就很好理解。

再来看这个图:

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!1696 作者: 来源: 发布时间:2024-8-21 10:29

在LiteFlow里规则表示就是:
<chain name="chain1">
    THEN(
        a,
        WHEN(
            b,
            SWITCH(c).to(d,e)
        ),
        f
    )
</chain>

其中SWITCH关键字就是排他网关的意思,c这个组件是一个java类,根据执行的结果去选择到底应该执行d还是e。

所以这样嵌套多层也应该是毫无问题的。

LiteFlow的文档里作者给出了很详细的例子,还有一些复杂例子,比如:

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!7050 作者: 来源: 发布时间:2024-8-21 10:29

这种复杂的例子用LiteFlow的表达式可以写成:
<chain name="chain1">
    THEN(
        A,
        WHEN(
            THEN(B, C),
            THEN(D, E, F),
            THEN(
                SWITCH(G).to(
                    THEN(H, I, WHEN(J, K)).id("t1"),
                    THEN(L, M).id("t2")
                ),
                N
            )
        ),
        Z
    )
</chain>

它的表达式还可以进行定义子变量,上述表达式又可以写成:
<chain name="chain1">
    item1 = THEN(B, C);
    item2 = THEN(D, E, F);
    item3_1 = THEN(H, I, WHEN(J, K)).id("t1");
    item3_2 = THEN(L, M).id("t2");
    item3 = THEN(SWITCH(G).to(item3_1, item3_2), N);
   
    THEN(
        A,
        WHEN(item1, item2, item3),
        Z
    );
</chain>

其实对照图,仔细看,会觉得这种表达式还是很清晰的。运用到我那个短信系统里是绰绰有余的。

流程的表达式


我研究了下,花了10分钟时间,就写出了我那个流程的表达式规则:
<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="channelSenderChain">
        selectBestChannel = THEN(
                                WHEN(
                                    channel1Query, channel2Query, channel3Query,
                                    channel4Query, channel5Query, channel6Query
                                ),
                                channelSelector
                            ).id("branch1");

        selectBizChannel = THEN(
                                biz1,
                                SWITCH(if_2).to(
                                    channel3,
                                    channel4,
                                    SWITCH(if_3).to(channel5, channel6).id("s3")
                                ).id("s2")
                            ).id("branch2");

        THEN(
            packageData,
            SWITCH(if_1).to(
                channel1,
                channel2,
                selectBestChannel,
                selectBizChannel
            ),
            batchSender
        );
    </chain>
</flow>

我用了文档中提到的子变量的方式去写,这种写法更加清晰。其实我总结了一个小窍门就是:**再复杂的图,都可以拆分成一个个局部的整体,先定局部的小变量,然后在主要的流程里去引入这些局部变量就可以了。**反正我写这个图的流程就差不多10分钟。

至于一个个小组件。我就跟着文档里做了一遍,把原来的大逻辑改拆成一个个的小逻辑。封装在不同的组件里,给上相应的Id就可以了。

最后通过LiteflowExecutor触发下就可以了。
LiteflowResponse response = flowExecutor.execute2Resp("channelSenderChain", null, BatchMessageResultContext.class);
BatchMessageResultContext context = response.getFirstContextBean();
if (response.isSuccess()){
  log.info("执行成功,最终选择的渠道是{}", context.getFinalResultChannel());
}else{
  log.error("执行失败", response.getCause());
}

非常简单有木有!!!

而且特别优雅!!!

完全解耦了


我改成上面这种形式了之后,每一个小逻辑块之间就完全解耦了。当中数据的连接完全是靠上下文进行连接的,在研究了LiteFlow的理念之后,我发现这理念特别好。直接把原先的耦合性特别强的代码给拆分开来了。

现在业务有变动的话,我只需要改写其中一个组件就可以了。而且组件是可以拿来复用的。之间的顺序也是可以随意切换的。这一切,只需要改规则文件即可。代码是完全不用动的。

我仔细翻看了文档,这框架还支持完全无缝的热刷新,虽然我的代码没用到这特,但是看起来真的是太厉害了,改变规则的编排连重启应用都不需要!!!不过我打死都不会用这个特性的,领导叫我改业务,我还想多报点工时,这个如果上线了,我就没法多报工时了。。。🤣

LiteFlow还有很多高级特性,比如隐式流程啊,事件回调啊,声明式组件,组件切面啊,步骤信息,线程池的自定义,私有投递,还有简单监控。这款国产规则引擎快要玩出花了,强大!

重点要说下LiteFlow的脚本组件这个功能 ,这个功能是我写好代码才发现的。我发现,如果用脚本组件的话会更灵活。

虽然LiteFlow支持热刷新,但也仅限于规则文件改变。你Java代码改变,还得重启。

但是LiteFlow的脚本组件连这层都给你捅破了,你可以定义脚本,还支持groovy脚本,这下,连改变逻辑都不用重启应用了。。

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!5590 作者: 来源: 发布时间:2024-8-21 10:29

介于我上面的私心,我同样也不会把这功能告诉领导😅。

可玩点非常多


我重构完这个项目之后,发现LiteFlow这个框架的可玩点非常多。

虽然官方是宣称是规则引擎,适用于用来解耦系统,组件编排。但是我发现用它来做一些简单的异步线程编排也是非常nice的。我自己本身对多线程不太精通,用这个来写,太方便了。

LiteFlow除了规则文件之外,还支持代码形式的链式组装规则,这个特性正好用来写多线程。

比如,我要写一个这样的多线程例子:

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!121 作者: 来源: 发布时间:2024-8-21 10:29

要让我用CompletableFuture来写,我还真不太会。但是你用LiteFlow就很容易,在LiteFlow你无需定义线程,框架自己会为你创建线程,你只需要把你线程里的代码变成一个个组件,然后用代码定义规则就可以了。

写法如下:
String el = "THEN(" +
  "          main1," +
  "          WHEN(" +
  "                THEN(c1, c2, WHEN(c3, c4))," +
  "                THEN(c5, c6)" +
  "             )," +
  "          main2" +
  "       )";
LiteFlowChainELBuilder.createChain().setChainName("testChain").setEL(el).build();
LiteflowResponse response = flowExecutor.execute2Resp("testChain", 流程初始参数, 你的上下文.class);

就这样即完成了这个看上去有点复杂的线程编排了。这款框架简直是对不会写多线程小白的福音啊。爱了爱了。

总结


顺便还要说下的是,官网的文章超详细。社区群也很活跃。

以下是LiteFlow的Gitee的仓库地址,大家可以关注下这款国产规则引擎

https://gitee.com/dromara/liteFlow

为了方便理解,我特地把我那个短信的例子进行了mock后推到了github仓库,大家可以自行pull下来玩耍。

https://github.com/bryan31/message-demo


Github上标星60K的电商实战项目mall,全套 视频教程(2023最新版) 已更新完毕!全套教程约40小时,共113期,通过这套教程你可以拥有一个涵盖主流Java技术栈的完整项目经验,同时提高自己独立开发一个项目的能力,下面是项目的整体架构图,感兴趣的小伙伴可以点击链接 mall视频教程 加入学习。

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!9522 作者: 来源: 发布时间:2024-8-21 10:29

整套 视频教程 的内容还是非常完善的,涵盖了mall项目最佳学习路线、整体框架搭建、业务与技术实现全方位解析、线上Docker环境部署、微服务项目学习等内容,具体大纲可以参考下图,你也可以点击链接 mall视频教程 了解更多内容。

新来个技术总监,使用流程引擎优化复杂的业务代码,老板惊呆了!9469 作者: 来源: 发布时间:2024-8-21 10:29

推荐阅读

  • 69K Star!这是我见过最强的开源电商系统 !!
  • Github标星60K!一套完整的项目实战教程来了,主流Java技术一网打尽!
  • 看了我项目中购物车、订单、支付一整套设计,同事也开始悄悄模仿了...
  • 订单系统就该这么设计,稳的一批!
  • 支付系统就该这么设计,稳的一批!
  • 权限系统就该这么设计,稳的一批!





上一篇:百度Web前端开发实战案例解析
下一篇:北斗开发不小众:结合5G、AI、物联网技术“脑洞大开”

鲜花

握手

雷人

路过

鸡蛋

评论

您需要登录后才可以发表言论 登录立即注册
创宇盾启航版免费网站防御网站加速服务
投诉/建议联系

discuzaddons@vip.qq.com

未经授权禁止转载,复制和建立镜像,
如有违反,按照公告处理!!!
  • 联系QQ客服
  • 添加微信客服

联系DZ插件网微信客服|最近更新|Archiver|手机版|小黑屋|DZ插件网! ( 鄂ICP备20010621号-1 )|网站地图 知道创宇云防御

您的IP:18.118.149.55,GMT+8, 2024-11-24 03:02 , Processed in 0.173694 second(s), 41 queries , Gzip On, Redis On.

Powered by Discuz! X5.0 Licensed

© 2001-2024 Discuz! Team.

关灯
扫一扫添加微信客服
QQ客服返回顶部
返回顶部