Springcloud:LiteFlow

news2024/12/23 13:38:34

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档

目录

一、LiteFlow简介

二、规则编排关键字及语法

1、THEN:

2、WHEN:

3、AND:

4、OR:

5、IF:

6、ELSE:

7、RETRY:

8、RETRY_FOR_EACH:

9、RETRY_WHILE:

10、RETRY_UNTIL:

三、Springcloud接入LiteFlow例子

1、定义节点nodeA、nodeB

 2、定义配置文件

3、配置文件配置

4、编写测试类

四、跳出节点的方式

1、抛异常 

五、规则编排适合使用的场景

总结


提示:以下是本篇文章正文内容,下面案例可供参考

一、LiteFlow简介

在日常的开发过程中,经常会遇到一些串行或者并行的业务流程问题,而业务之间不必存在相关性。

在这样的场景下,使用策略和模板模式的结合可以很好的解决这个问题,但是使用编码的方式会使得文件太多,在业务的部分环节可以这样操作,在项目角度就无法一眼洞穿其中的环节和逻辑。

在本文中,将引入规则引擎从全局角度来解决这个问题,这就是今天要介绍的主角 liteflow。

liteflow 是一个轻巧而且强大的规则引擎,能够实现开箱即用,可以在短时间内就可以完成复杂的规则编排,下图是 liteflow 的整体架构。liteflow 支持较多的规则文件格式,比如 xml/json/yaml, 对于规则文件的存储方式可以有sql/zk/nacos/apollo 等。

官网地址:LiteFlow

二、规则编排关键字及语法

1、THEN:

用于定义流程链中的节点顺序。节点按照THEN关键字后面的顺序执行

 <chain name="chain1">
    THEN(nodeA, nodeB, nodeC)
</chain>

2、WHEN:

用于定义条件节点。WHEN关键字后面的节点只有在满足条件时才会执行

<chain name="chain1">
    WHEN(conditionNode)
    THEN(nodeA, nodeB)
</chain>

3、AND:

用于并行执行多个节点。AND关键字后面的节点会同时执行

<chain name="chain1">
    AND(nodeA, nodeB)
</chain>

4、OR:

用于定义多个节点中的任意一个执行。OR关键字后面的节点会按照顺序执行,直到找到一个成功执行的节点

<chain name="chain1">
    OR(nodeA, nodeB)
</chain>

5、IF:

用于条件判断。IF关键字后面的节点只有在满足条件时才会执行

<chain name="chain1">
    IF(conditionNode)
    THEN(nodeA, nodeB)
</chain>

6、ELSE:

用于条件判断的否定分支。ELSE关键字后面的节点只有在IF关键字后面的条件判断失败时才会执行

<chain name="chain1">
    IF(conditionNode)
    THEN(nodeA, nodeB)
    ELSE(nodeC, nodeD)
</chain>

7、RETRY:

用于重试失败的节点。RETRY关键字后面的节点会在失败时重试执行

<chain name="chain1">
    RETRY(nodeA,  3)
</chain>

8、RETRY_FOR_EACH:

用于重试失败的节点,并且对每个节点进行重试

<chain name="chain1">
    RETRY_FOR_EACH(nodeA, nodeB,  3)
</chain>

9、RETRY_WHILE:

用于重试失败的节点,直到满足指定的条件

<chain name="chain1">
    RETRY_WHILE(nodeA, conditionNode)
</chain>

10、RETRY_UNTIL:

用于重试失败的节点,直到满足指定的条件

<chain name="chain1">
    RETRY_UNTIL(nodeA, conditionNode)
</chain>

三、Springcloud接入LiteFlow例子

1、定义节点nodeA、nodeB

@LiteflowComponent("nodeA")
public class NodeA extends NodeComponent {
    @Override
    public void process() {
        System.out.println("NodeA executed");
        throw new RuntimeException("测试异常");
    }
}
@LiteflowComponent("nodeB")
public class NodeB extends NodeComponent {
    @Override
    public void process() {
        System.out.println("NodeB executed");
    }
}

 2、定义配置文件

 新增配置文件flow.xml文件

<?xml version="1.0" encoding="UTF-8"?>
<flow name="myFlow">
	<chain name="chainabc">
		THEN(nodeA, nodeB);
	</chain>
</flow>

注意,首次接入时,配置文件中如果按照以下方式书写,在加载时会报错:init flow executor cause error for path [classpath:flow.xml],reason: no content in this chain

<flow name="myFlow">
    <chain name="chain1">
        <then name="nodeA" />
        <then name="nodeB" />
    </chain>
</flow>

3、配置文件配置

application.yml文件中添加配置

liteflow:
  rule-source: classpath:flow.xml

4、编写测试类

@RestController
public class FlowController {

    @Resource
    private FlowExecutor flowExecutor;

    @GetMapping("/executeFlow")
    public String executeFlow() {
        LiteflowResponse response = flowExecutor.execute2Resp("chainabc");
        return response.getExecuteStepStr();
    }

}
@Resource
private FlowController flowController;

@Test
public void liteFlowTest() {
    flowController.executeFlow();
}

四、跳出节点的方式

1、抛异常 

THEN(nodeA, nodeB, nodeC)

当 nodeA 节点抛出异常后,整个流程不再向下执行,失败之后的策略,可以在配置文件里配置,例如:重试几次、一直重试直到成功等等

五、规则编排适合使用的场景

在上边这个图中,A和B是顺序执行,C、D、H三个节点所在的线是并行的。三条线都执行完毕后,再接着执行X。

1、在金融系统中

复杂的渠道和资方,各自的流程有一样的,也有区别很大的,很适合编排,如果将配置文件放在nacos中,就能实现动态编排,实时生效。

2、在电商系统中

如果一个商品有M个优惠活动,有些能叠加,那么我们可以编排优惠的顺序,快速适应新需求调整计算顺序。


总结

实用,实用,实用,重要的事情说三遍!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1460756.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

手动代码实现神经网络

网络结构 第一层有13个神经元&#xff0c;第二层8个神经元&#xff0c;第三层是输出层&#xff1b;其中第一层的激活函数是relu&#xff0c;第二层是sigmoid 代码实现 # 导入库 import torch import torch.nn as nn from torch.nn import functional as F # 确定数据 torch…

使用IntelliJ IDEA查看接口的全部实现方法

在大型Java项目中&#xff0c;经常会使用接口和抽象类进行代码设计。为了更好地了解代码结构和功能&#xff0c;我们需要快速查看一个接口的所有实现类。IntelliJ IDEA提供了一些方便的方法来实现这一目标。 1. 点击查看接口的实现子类 在IDEA中&#xff0c;你可以轻松地查看…

swagger 内容信息与代码不一致,已解决

ApiModel是Swagger中的常用到的注解&#xff0c;检查下信息错误的实体类的ApiModel的value值是否一致&#xff0c;应该是写错了&#xff0c;是不是张冠李戴了

STM32 TIM2重映射

STM32定时器 文章目录 STM32定时器[TOC](文章目录) 前言一、问题分析二、代码 前言 最近想弄一个多路输出PWM&#xff0c;但是发现TIM2不能用&#xff0c;根据手册也对它进行重映射了&#xff0c;但是还是不能用&#xff0c;用示波器发现驱动能力比较弱&#xff0c;然后禁用jt…

博途PLC PID仿真(单容水箱液位高度控制)

单容水箱和双荣水箱的微分方程和数值求解,可以参考下面文章链接: https://rxxw-control.blog.csdn.net/article/details/131139432https://rxxw-control.blog.csdn.net/article/details/131139432这篇博客我们利用欧拉求解器在PLC里完成单容水箱的数学建模。PLC也可以和MATL…

【笔记】【算法设计与分析 - 北航童咏昕教授】绪论

算法设计与分析 - 北航童咏昕教授 文章目录 算法的定义定义性质 算法的表示自然语言编程语言伪代码 算法的分析算法分析的原则渐近分析 算法的定义 定义 给定计算问题&#xff0c;算法是一系列良定义的计算步骤&#xff0c;逐一执行计算步骤即可得预期的输出。 性质 有穷性确…

运维07:堡垒机

什么是跳板机 跳板机就是一台服务器而已&#xff0c;运维人员在使用管理服务器的时候&#xff0c;必须先连接上跳板机&#xff0c;然后才能去操控内网中的服务器&#xff0c;才能登录到目标设备上进行维护和操作 开发小张 ---> 登录跳板机 ---> 再登录开发服务器 测试…

vue3 用xlsx 解决 excel 低版本office无法打开问题

需求背景解决思路解决效果将json导出为excel将table导为excel导出样式 需求背景 原使用 vue3-json-excel &#xff0c;导致在笔记本office环境下&#xff0c;出现兼容性问题 <vue3-json-excel class"export-btn" :fetch"excelGetList" :fields"js…

Aster实现一台电脑当两台使——副屏搭配键鼠

前言&#xff1a;笔者每年回家&#xff0c;都面临着想要和小伙伴一起玩游戏&#xff0c;但小伙伴没有电脑/只有低配电脑的问题。与此同时&#xff0c;笔者自身的电脑是高配置的电脑&#xff0c;因此笔者想到&#xff0c;能否在自己的电脑上运行游戏&#xff0c;在小伙伴的电脑上…

Code-Audit(代码审计)习题记录

介绍&#xff1a; 自己懒得搭建靶场了&#xff0c;靶场地址是 GitHub - CHYbeta/Code-Audit-Challenges: Code-Audit-Challenges为了方便在公网练习&#xff0c;可以随地访问&#xff0c;本文所有的题目均来源于网站HSCSEC-Code Audit 1、习题一 题目内容如下&#xff1a; 1…

2024pytest自动化测试框架学习(三)

在自动化测试中我们经常会针对某些测试方法编写前置测试数据&#xff0c;当测试方法执行完毕后再清理这些测试数据。之前我们接触的unittest框架中&#xff0c;使用setUp、tearDown方法来解决前置数据、后置数据销毁的问题。pytest为我们提供了更加强大灵活的fixtrue来完成该实…

《Solidity 简易速速上手小册》第8章:高级 Solidity 概念(2024 最新版)

文章目录 8.1 高级数据类型和结构8.1.1 基础知识解析更深入的理解实际操作技巧 8.1.2 重点案例&#xff1a;构建一个去中心化身份系统案例 Demo&#xff1a;创建去中心化身份系统案例代码DecentralizedIdentityContract.sol 测试和验证拓展案例 8.1.3 拓展案例 1&#xff1a;管…

MedicalGPT 训练医疗大模型,实现了包括增量预训练、有监督微调、RLHF(奖励建模、强化学习训练)和DPO(直接偏好优化)

MedicalGPT 训练医疗大模型&#xff0c;实现了包括增量预训练、有监督微调、RLHF(奖励建模、强化学习训练)和DPO(直接偏好优化)。 MedicalGPT: Training Your Own Medical GPT Model with ChatGPT Training Pipeline. 训练医疗大模型&#xff0c;实现了包括增量预训练、有监督微…

我为什么不喜欢关电脑?

程序员为什么不喜欢关电脑&#xff1f; 你是否注意到&#xff0c;程序员们似乎从不关电脑&#xff1f;别以为他们是电脑上瘾&#xff0c;实则是有他们自己的原因&#xff01;让我们一起揭秘背后的原因&#xff0c;看看程序员们真正的“英雄”本色&#xff01; 一、上大学时。 …

AP5216 降压恒流 全亮 半亮9W 车灯手电筒 性价比方案

AP5216 是一款 PWM工作模式, 高效率、外 围简单、内置功率管&#xff0c;适用于5V&#xff5e;100V输入的高 精度降压 LED 恒流驱动芯片。输出功率可达 9W&#xff0c;电流 1.0A。AP5216 可实现全亮/半亮功能切换&#xff0c;通过 MODE 切换&#xff1a;全亮/半亮 模式。AP5216…

《小程序商城定制:为你打造独特的线上商业帝国》

在当今数字化的时代&#xff0c;拥有一个定制的小程序商城已经成为了许多企业和个人创业者的首要任务。小程序商城作为一种轻量级的移动应用&#xff0c;具有无需下载、使用方便、传播迅速等优势&#xff0c;为用户提供了更加便捷的购物体验。而通过定制小程序商城&#xff0c;…

linux部署jenkins,支持jdk1.8

无废话&#xff0c;纯干活安装指令 本文前提条件需安装jdk8&#xff0c;安装参考&#xff1a;Linux配置jdk环境 下载资源 # 创建安装目录 mkdir -p /data/jenkins && cd /data/jenkins# 下载jenkins的war包&#xff0c;v2.346.x支持jdk1.8&#xff0c;高于这个版本的…

书生·浦语大模型实战营第四节课作业

基础作业 fintune过程 这里要注意下。 合并完参数的模型再进行网页部署时&#xff0c;需要用到InternLM源码&#xff0c;教程里面忽略了需要commit版本。通过以下命令转到所需版本&#xff0c;然后就可以看到web_demo.py。 cd InternLM git checkout 3028f07cb79e5b1d7342f4…

ping 8.8.8.8和ping www.baidu.com都OK,但是打不开网页

ping 8.8.8.8和ping www.baidu.com都OK&#xff0c;但是打不开网页 打开设置 -> 网络 找到IPV4, DNS栏输入 8.8.8.8 , apply 设置里界面变成这样 然后网页就能加载了

EPS-HiL转向硬件在环测试方案

1、项目背景 为提升研发能力&#xff0c;深入研究电动助力转向系统(EPS)功能&#xff0c;拟搭建EPS硬件在环测试设备。本设备可进行多种EPS相关测试实验。 2、需求分析 本方案中被测EPS如下图&#xff0c;为转向杆式电动助力转向器&#xff08;C-EPS&#xff09;&#xff0c…