当前位置：首页 > 科技 > 软件

惊呆了，Spring Boot + Liteflow 居然这么好用！

来源：责编：时间：2024-07-06 07:46:24 871观看

导读引言在我们的日常开发中，经常会遇到一些需要串行或并行处理的复杂业务流程。每次处理这些流程时，我们都希望能够更简单、高效地进行管理和维护。这个时候，规则引擎就成了我们的好帮手。今天，我要和大家分享的是如何利用Sp

引言

在我们的日常开发中，经常会遇到一些需要串行或并行处理的复杂业务流程。

每次处理这些流程时，我们都希望能够更简单、高效地进行管理和维护。

这个时候，规则引擎就成了我们的好帮手。

今天，我要和大家分享的是如何利用Spring Boot结合liteflow规则引擎来简化我们的业务流程。

一、什么是liteflow规则引擎？

首先，我们需要了解什么是liteflow。

liteflow是一个轻量级但功能强大的规则引擎。

它支持多种规则文件格式，如XML、JSON等，方便开发者根据自己的需求进行选择。

liteflow可以帮助我们快速编排复杂的业务规则，并实现动态的规则更新。

二、为什么选择liteflow？

其中一个主要原因是它能够快速完成复杂规则的编排。

无论是串行还是并行任务，它都能处理得游刃有余。

而且liteflow支持热部署，这意味着我们可以实时替换或增加节点，而无需重启服务。

三、liteflow组件概览

在liteflow中，主要有以下几种组件：

普通组件：集成NodeComponent，用于执行具体的业务逻辑；
选择组件：通过业务逻辑选择不同的执行路径；
条件组件：基于条件返回结果，决定下一步的业务流程。

我们通过代码示例来了解每种组件的用法。

// 普通组件示例@LiteflowComponent("commonNode")public class CommonNode extends NodeComponent {    @Override    public void process() throws Exception {        // 业务逻辑        System.out.println("Executing commonNode logic");    }}// 选择组件示例@LiteflowComponent("choiceNode")public class ChoiceNode extends NodeSwitchComponent {    @Override    public String processSwitch() throws Exception {        // 根据条件返回不同的节点ID        return "nextNodeId";    }}// 条件组件示例@LiteflowComponent("conditionNode")public class ConditionNode extends NodeIfComponent {    @Override    public boolean processIf() throws Exception {        // 判断条件        return true;    }}

四、EL规则文件

在liteflow中，规则文件可以采用XML格式编写，下面是一个简单的规则文件示例。

<flow>    <node id="commonNode"/>    <if id="conditionNode">        <true-to id="nextNode"/>        <false-to id="otherNode"/>    </if>    <switch id="choiceNode">        <case id="case1" to="node1"/>        <case id="case2" to="node2"/>    </switch></flow>

如何使用EL规则文件

创建规则文件：将上述规则文件保存为flow.xml，放在项目的resources目录下；
配置liteflow：在Spring Boot项目中添加liteflow的配置，指定规则文件的位置；

liteflow:  rule-source: "classpath:flow.xml"  node-retry: 3  thread-executor:    core-pool-size: 10    max-pool-size: 20    keep-alive-time: 60

编写业务逻辑组件：按照规则文件中的定义，编写相应的组件逻辑。

五、数据上下文

在liteflow中，数据上下文非常重要，它用于参数传递和业务逻辑的执行。

我们可以通过以下代码示例了解数据上下文的用法。

@LiteflowComponent("contextNode")public class ContextNode extends NodeComponent {    @Override    public void process() throws Exception {        // 获取数据上下文        LiteflowContext context = this.getContextBean();        // 设置数据        context.setData("key", "value");        // 获取数据        String value = context.getData("key");        System.out.println("Context data: " + value);    }}

六、配置详解

在使用liteflow时，我们需要对一些参数进行配置，如规则文件地址、节点重试、线程池参数等。

以下是一个配置示例。

liteflow:  rule-source: "classpath:flow.xml"  # 指定规则文件的位置  node-retry: 3  # 节点重试次数  thread-executor:    core-pool-size: 10  # 线程池核心线程数    max-pool-size: 20  # 线程池最大线程数    keep-alive-time: 60  # 线程存活时间

七、实践案例

接下来，我们来看一个完整的业务实践案例。

在电商场景下，当订单完成后，我们需要同时进行积分发放和消息发送。

这时候，我们可以利用liteflow进行规则编排，处理这些并行任务。

1. 引入依赖

首先，在pom.xml文件中添加liteflow的依赖：

<dependency>    <groupId>com.yomahub</groupId>    <artifactId>liteflow-spring-boot-starter</artifactId>    <version>2.6.5</version></dependency>

2. 增加配置

在application.yml文件中添加liteflow的配置：

spring:  application:    name: liteflow-demoliteflow:  rule-source: "classpath:flow.xml"  # 指定规则文件的位置  node-retry: 3  # 节点重试次数  thread-executor:    core-pool-size: 10  # 线程池核心线程数    max-pool-size: 20  # 线程池最大线程数    keep-alive-time: 60  # 线程存活时间

3. 编写规则文件

在resources目录下创建flow.xml文件，编写规则文件内容：

<flow>    <parallel>        <node id="pointNode"/>        <node id="messageNode"/>    </parallel></flow>

4. 编写业务逻辑组件

按照规则文件中的定义，编写相应的业务逻辑组件：

@LiteflowComponent("pointNode")public class PointNode extends NodeComponent {    @Override    public void process() throws Exception {        // 发放积分逻辑        System.out.println("Issuing points for the order");    }}@LiteflowComponent("messageNode")public class MessageNode extends NodeComponent {    @Override    public void process() throws Exception {        // 发送消息逻辑        System.out.println("Sending message for the order");    }}

5. 流程触发

当订单完成后，我们需要触发liteflow的流程来执行积分发放和消息发送的逻辑。

我们可以在订单完成的服务方法中添加如下代码：

@Servicepublic class OrderService {        @Autowired    private FlowExecutor flowExecutor;        public void completeOrder(Order order) {        // 完成订单的其他逻辑        System.out.println("Order completed: " + order.getId());                // 执行liteflow流程        flowExecutor.execute2Resp("flow", order);    }}

在上述代码中，我们使用FlowExecutor来执行liteflow流程，并将订单对象传递给流程。
这将触发flow.xml中定义的规则，执行并行的积分发放和消息发送逻辑。

八、性能统计

liteflow在启动时完成规则解析和组件注册，保证高性能的同时，还能统计各业务环节的耗时，帮助我们进行性能优化。

以下是一个性能统计示例：

@LiteflowComponent("performanceNode")public class PerformanceNode extends NodeComponent {    @Override    public void process() throws Exception {        long start = System.currentTimeMillis();        // 业务逻辑        long end = System.currentTimeMillis();        System.out.println("PerformanceNode execution time: " + (end - start) + "ms");    }}

总结

怎么样，听起来很高大上，用起来其实很简单吧。

总的来说，liteflow在简化业务流程管理方面起到了非常重要的作用，可以提升开发效率和业务流程管理能力。

没用过的xdm，闲暇之余可以自己动手试试哦！

好了，今天的知识你学会了吗？

本文链接：http://www.28at.com/showinfo-26-99175-0.html惊呆了，Spring Boot + Liteflow 居然这么好用！

声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com

上一篇：携程注册中心整体架构与设计取舍

下一篇：使用 Spring Boot 结合安全框架增强支付系统的安全加固

标签：

热门焦点

俄罗斯：将审查iPhone等外国公司设备保数据安全

iPhone和特斯拉都属于在各自领域领头羊的品牌，推出的产品也也都是数一数二的，但对于一些国家而言，它们的产品可靠性和安全性还是在限制范围内。近日，俄罗斯联邦通信、信息技术
7月安卓手机性能榜：红魔8S Pro再夺榜首

7月份的手机市场风平浪静，除了红魔和努比亚带来了两款搭载骁龙8Gen2领先版处理器的新机之外，别的也想不到有什么新品了，这也正常，通常6月7月都是手机厂商修整的时间，进入8月份之
这款新兴工具平台，让你的电脑效率翻倍

随着信息技术的发展,我们获取信息的渠道越来越多,但是处理信息的效率却成为一个瓶颈。于是各种工具应运而生,都在争相解决我们的工作效率问题。今天我要给大家介绍一款效率
虚拟键盘 API 的妙用

你是否在遇到过这样的问题：移动设备上有一个固定元素，当激活虚拟键盘时，该元素被隐藏在了键盘下方？多年来，这一直是 Web 上的默认行为，在本文中，我们将探讨这个问题、为什么会发生
2天涨粉255万，又一赛道在抖音爆火

来源：运营研究社作者 | 张知白编辑 | 杨佩汶设计 | 晏谈梦洁这个暑期，旅游赛道彻底火了：有的「地方」火了——贵州村超旅游收入 1 个月超过 12 亿；有的「博主」火了&m
拼多多APP上线本地生活入口，群雄逐鹿万亿市场

Tech星球（微信ID：tech618）文 | 陈桥辉 Tech星球独家获悉，拼多多在其APP内上线了“本地生活”入口，位置较深，位于首页的“充值中心”内，目前主要售卖美食相关的
冯提莫签约抖音公会前“斗鱼一姐”消失在直播间

来源：直播观察提起“冯提莫”这个名字，很多网友或许听过，但应该不记得她是哪位主播了。其实，作为曾经的“斗鱼一姐”，冯提莫在游戏直播的年代影响力不输于现
iQOO 11S屏幕细节公布：首发三星2K E6全感屏安卓最好的直屏手机

日前iQOO手机官方宣布，新一代电竞旗舰iQOO 11S将会在7月4日19:00正式与大家见面。随着发布时间的日益临近，官方关于该机的预热也更加密集，截至目前已
质感不错！OPPO K11渲染图曝光：旗舰IMX890传感器首次下放

一直以来，OPPO K系列机型都保持着较为均衡的产品体验，历来都是2K价位的明星机型，去年推出的OPPO K10和OPPO K10 Pro两款机型凭借各自的出色配置，堪称有