当前位置: 首页 > news >正文

liteflow 架构详解

LiteFlow 是一个轻量级的、高性能的流程编排框架,主要用于解决复杂业务流程的编排问题。它提供了一种简单而强大的方式来定义和执行复杂的业务流程。下面是 LiteFlow 的架构详解:

核心概念

  • 组件(Component):是流程中的最小执行单元,可以是一个简单的业务逻辑处理单元。
  • 链(Chain):是由多个组件按照一定顺序或条件组合而成的执行序列。
  • 脚本(Script):用于定义链的执行规则,可以使用 DSL(领域特定语言)或者 Java 代码来编写。

核心组件

  1. Parser

    • 作用:解析流程配置的规则,将规则文件解析成Java代码来运行。
    • 支持的文件格式:XML、JSON、YAML。用户可根据自身配置的习惯来选择规则文件的格式。
    • 规则文件的存储方式:支持基于ZooKeeper(zk)、本地文件的形式,同时也支持自定义的形式。
    • 解析过程:对于XML来说,Parser会将标签解析成Node对象,将解析成Chain对象,内部的如“if”、“else”等标签都会解析成Condition对象。
  2. Node

    • 定义:代表具体业务执行的节点,真正的业务是在Node中执行的。
    • 特性:在LiteFlow中,所有的逻辑都是组件,Node即为业务组件,直接使用Spring原生注解@Component定义即可。
  3. Condition

    • 定义:可以被理解为一种条件,例如前置条件或后置条件。一个Condition可以包含多个需要执行的Node。
    • 作用:用于定义Node的执行条件和顺序,它们可以是串行或并行执行的。
  4. Chain

    • 定义:可以理解成整个业务执行的流程,按照一定的顺序来执行Condition中的Node,即业务节点。

架构设计

LiteFlow的设计基于工作台模式,其中每个业务组件相当于一个工人,按照一定的顺序在工作台上生产零件(即执行业务逻辑),从而实现了组件间的解耦和流程的灵活编排。

组件模型

LiteFlow 支持多种类型的组件,包括但不限于:

  • 普通组件:最基础的组件类型,实现 LiteflowComponent 接口。
  • 条件组件:用于判断条件是否满足,实现 ConditionComponent 接口。
  • 脚本组件:可以直接运行脚本代码的组件,支持多种脚本语言。
  • 子流程组件:可以嵌套其他链,实现更复杂的流程控制。
链模型

链是通过脚本定义的,可以包含以下元素:

  • 组件调用:直接调用某个组件。
  • 条件判断:根据条件选择不同的分支。
  • 循环:重复执行某个组件或链。
  • 并行执行:同时执行多个组件或链。
  • 异常处理:定义异常发生时的行为。
脚本解析

LiteFlow 使用 EL 表达式引擎(如 MVEL 或者 SpEL)来解析脚本,支持动态表达式计算和条件判断。

执行引擎

执行引擎负责解析脚本,并根据脚本定义的规则执行相应的组件。执行过程中,可以通过上下文传递数据。

关键特性

  1. 组件化设计:LiteFlow将业务逻辑封装成独立的组件,每个组件负责处理特定的业务任务。这种组件化的设计使得业务流程更加清晰,也便于维护和扩展。
  2. 规则驱动:通过配置文件(支持XML、JSON、YAML等格式)定义业务流程的执行顺序和条件。这些规则文件描述了组件之间的流转关系,使得开发者可以灵活地调整业务流程。
  3. 热加载规则配置:LiteFlow支持热加载规则配置,即无需重启服务即可修改规则配置,实现业务流程的实时调整。这一特性大大提高了系统的灵活性和响应速度。
  4. 上下文隔离机制:LiteFlow提供了可靠的上下文隔离机制,确保在高并发情况下数据不会串流,从而保证了系统的稳定性和可靠性。
  5. 多种脚本语言支持:LiteFlow支持多种脚本语言(如Groovy、JavaScript、Python、Lua等),允许开发者根据具体业务需求进行定制。
  6. IDEA插件支持:LiteFlow拥有自己的IDEA插件LiteFlowX,通过该插件能支持规则文件的智能提示、语法高亮、组件与规则文件之间的跳转及LiteFlow工具箱等功能。
  7. 高灵活性:支持丰富的组件类型和多样的链定义方式。
  8. 高性能:通过高效的解析和执行机制,保证了较低的延迟。
  9. 易扩展:用户可以自定义组件和脚本解析器,以适应不同的业务需求。
  10. 可视化:提供了图形化的工具来帮助用户设计和调试流程。
  11. 分布式支持:支持在分布式环境中部署和运行。

使用场景

  1. 业务流程管理:对于拥有复杂业务逻辑的系统,使用LiteFlow可以降低维护成本,提高代码的抽象和复用率。
  2. 规则引擎:LiteFlow支持动态构建组件和流程,以及数据上下文的使用,使得在流程中的数据传递和共享变得更加方便和高效。
  3. 工作流:企业中的审批流程(如请假、加班、报销、采购等)可以使用LiteFlow进行快速开发和部署。
  4. 订单处理:电商网站和其他交易平台的订单处理流程也可以使用LiteFlow进行流程管控和监管,确保订单处理的准确性和高效性。
  5. 数据处理:在数据平台中,数据的流动和处理需要经历一系列的流程。LiteFlow可以用于管控和优化这些数据流程,确保数据的准确性和及时性。
  6. 微服务编排:在分布式系统中,微服务的管理、编排与监控涉及到多个服务之间的依赖关系。使用LiteFlow可以实现服务的自动化调用和管理,提高系统的稳定性和可维护性。
  7. 事件驱动架构:处理事件触发的复杂业务逻辑。

示例

假设我们有一个简单的业务流程,需要先验证用户信息,然后查询订单,最后生成报告。我们可以使用 LiteFlow 来定义这个流程:

@Component("userCheck")
public class UserCheckComponent extends NodeComponent {@Overridepublic ExecuteResult execute(ExecuteContext context) throws Exception {// 用户验证逻辑return ExecuteResult.SUCCESS;}
}@Component("orderQuery")
public class OrderQueryComponent extends NodeComponent {@Overridepublic ExecuteResult execute(ExecuteContext context) throws Exception {// 订单查询逻辑return ExecuteResult.SUCCESS;}
}@Component("reportGenerate")
public class ReportGenerateComponent extends NodeComponent {@Overridepublic ExecuteResult execute(ExecuteContext context) throws Exception {// 报告生成逻辑return ExecuteResult.SUCCESS;}
}

然后定义链:

@Configuration
public class FlowConfig {@Beanpublic Chain chain() {return new ChainBuilder().begin("userCheck").then("orderQuery").then("reportGenerate").end();}
}

这样就定义了一个简单的流程,其中包含了三个步骤:用户验证、订单查询和报告生成。

总结

LiteFlow 提供了一种简洁而强大的方式来定义和执行复杂的业务流程。它的灵活配置、高性能以及易扩展性使其成为处理复杂业务逻辑的理想选择。

相关文章:

liteflow 架构详解

LiteFlow 是一个轻量级的、高性能的流程编排框架,主要用于解决复杂业务流程的编排问题。它提供了一种简单而强大的方式来定义和执行复杂的业务流程。下面是 LiteFlow 的架构详解: 核心概念 组件(Component):是流程中…...

国产麒麟操作系统上运行LabVIEW

LabVIEW 目前并没有官方支持直接在国产麒麟操作系统(Kylin OS)上运行。LabVIEW 是由美国国家仪器公司(NI)开发的软件,主要面向 Windows 和 Linux 操作系统。麒麟操作系统虽然基于 Linux,但其内核和一些软件…...

【C语言】结构体(一)

一,是什么 结构体就是一些值的集合,这些值称为成员变量。 结构体的每个成员可以是不同类型的变量。说到集合,数组也是集合,但是不同的是数组只能是相同类型元素的集合。 二,结构体的声明 struct tag {   member1;…...

C++《set与map》

在之前我们已经学习了解了CSTL当中的string和vector等容器,现在我们已经懂得了这些容器提供的接口该如何使用,并且了解了这些容器的底层结构。接下来我们在本篇当中将继续学习STL内的容器set与map,在此这两个容器与我们之前学习的容器提供的成…...

深度学习-52-AI应用实战之基于Yolo8的目标检测自动标注

文章目录 1 YOLOv81.1 YOLOV8的不同版本1.2 可检测类别1.3 数据说明1.4 网络结构1.5 算法核心步骤2 目标检测的基本原理2.1 安装yolov8(cpu版本)2.2 图片检测2.3 视频检测2.4 自动标注2.5 保存标注结果3 参考附录1 YOLOv8 YOLOv8是一种前沿的计算机视觉技术,它基于先前YOLO版…...

【Elasticsearch】05-DSL查询

1. 查询所有 es最多只支持查询1万条数据。 # 查询所有 GET /items/_search {"query": {"match_all": {}} }2. 叶子查询 全文检索 会对结果进行相关度打分。 # 检索单个字段 GET /items/_search {"query": {"match": {"name&…...

qml项目创建的区别

在Qt框架中,你可以使用不同的模板来创建应用程序。你提到的这几个项目类型主要针对的是Qt的不同模块和用户界面技术。下面我将分别解释这些项目类型的区别: 根据你提供的信息,以下是每个项目模板的详细描述和适用场景: Qt Widgets…...

.NET8/.NETCore 依赖注入:自动注入项目中所有接口和自定义类

.NET8/.NETCore 依赖接口注入&#xff1a;自动注入项目中所有接口和自定义类 目录 自定义依赖接口扩展类&#xff1a;HostExtensions AddInjectionServices方法GlobalAssemblies 全局静态类测试 自定义依赖接口 需要依赖注入的类必须实现以下接口。 C# /// <summary>…...

Flutter:city_pickers省市区三级联动

pubspec.yaml city_pickers插件地址 自己用的GetBuilder页面模板 cupertino_icons: ^1.0.8 # 省市区城市选择 city_pickers: ^1.3.0编辑地址页面&#xff1a;controller class AddressEditController extends GetxController {AddressEditController();Future<Result?>…...

Kafka-Connect自带示例

一、上下文 《Kafka-Connect》中已经阐述了Kafka-Connect的理论知识&#xff0c;为了更生动的理解它&#xff0c;我们今天通过官方的一个小例子来感受下它的妙用。 二、创建topic kafka-topics --create --topic connect-test --bootstrap-server cdh1:9092 --partitions 2 -…...

Hbase应用案例 随机号码生成

Hbase应用案例1 随机号码生成 在Hbase中插入如下格式的数据&#xff0c;数据内容随机生成 名称示例说明phonenumber158randomrowkey&#xff0c;号码dnum199randomcolumn&#xff0c;另一位通话者lengthrandomcolumn&#xff0c;时长valuerandomcolumn&#xff0c;接收或拨打…...

论文阅读——量子退火Experimental signature of programmable quantum annealing

摘要&#xff1a;量子退火是一种借助量子绝热演化解决复杂优化问题的通用策略。分析和数值证据均表明&#xff0c;在理想化的封闭系统条件下&#xff0c;量子退火可以胜过基于经典热化的算法&#xff08;例如模拟退火&#xff09;。当前设计的量子退火装置的退相干时间比绝热演…...

(长期更新)《零基础入门 ArcGIS(ArcMap) 》实验二----网络分析(超超超详细!!!)

相信实验一大家已经完成了&#xff0c;对Arcgis已进一步熟悉了&#xff0c;现在开启第二个实验 ArcMap实验--网络分析 目录 ArcMap实验--网络分析 1.1 网络分析介绍 1.2 实验内容及目的 1.2.1 实验内容 1.2.2 实验目的 2.2 实验方案 2.3 实验流程 2.3.1 实验准备 2.3.2 空间校正…...

go语言 Pool实现资源池管理数据库连接资源或其他常用需要共享的资源

go Pool Pool用于展示如何使用有缓冲的通道实现资源池&#xff0c;来管理可以在任意数量的goroutine之间共享及独立使用的资源。这种模式在需要共享一组静态资源的情况&#xff08;如共享数据库连接或者内存缓冲区&#xff09;下非 常有用。如果goroutine需要从池里得到这些资…...

mysql一个事务最少几次IO操作

事务的IO操作过程 开始事务&#xff1a;用户发起一个事务&#xff0c;例如执行START TRANSACTION;&#xff0c;此时事务开始。读取和修改数据&#xff1a;用户读取和修改数据时&#xff0c;InnoDB首先从Buffer Pool查找所需的数据页。如果数据页不在Buffer Pool中&#xff0c;…...

运输层总结

运输层协议&#xff1a;端到端协议 面向连接的传输控制协议 TCP无连接的用户数据报协议 UDP - 主要任务&#xff1a;为相 互通信的应用进程 提供 逻辑通信服务 - 屏蔽&#xff1a;运输层向高层用户 屏蔽 了下面网络核心的细节&#xff08;如网络拓扑、所采用 的路由选择协议等…...

【嵌套查询】.NET开源 ORM 框架 SqlSugar 系列

.NET开源 ORM 框架 SqlSugar 系列 【开篇】.NET开源 ORM 框架 SqlSugar 系列【入门必看】.NET开源 ORM 框架 SqlSugar 系列【实体配置】.NET开源 ORM 框架 SqlSugar 系列【Db First】.NET开源 ORM 框架 SqlSugar 系列【Code First】.NET开源 ORM 框架 SqlSugar 系列【数据事务…...

React 前端框架1

一、React 简介 &#xff08;一&#xff09;什么是 React React 是一个用于构建用户界面的 JavaScript 库&#xff0c;由 Facebook 开源并维护。它采用了组件化的开发思想&#xff0c;允许开发者将复杂的 UI 拆分成一个个独立、可复用的小组件&#xff0c;就如同搭积木一般&am…...

【真正离线安装】Adobe Flash Player 32.0.0.156 插件离线安装包下载(无需联网安装)

网上很多人声称并提供的flash离线安装包是需要联网才能安装成功的&#xff0c;其实就是在线安装包&#xff0c;而这里提供的是真正的离线安装包&#xff0c;无需联网即可安装成功。 点击下面地址下载离线安装包&#xff1a; Adobe Flash Player 32.0.0.156 for IE Adobe Fla…...

数据采集时,不同地区的动态IP数据质量有什么差异?

在数据采集的广阔世界中&#xff0c;动态IP扮演着至关重要的角色。它们不仅帮助我们突破地域限制&#xff0c;还能够提供多样化的数据来源。但是&#xff0c;不同地区的动态IP在数据质量上是否存在差异呢&#xff1f;本文将探讨这一问题&#xff0c;并为您提供实用的见解。 动…...

地震勘探——干扰波识别、井中地震时距曲线特点

目录 干扰波识别反射波地震勘探的干扰波 井中地震时距曲线特点 干扰波识别 有效波&#xff1a;可以用来解决所提出的地质任务的波&#xff1b;干扰波&#xff1a;所有妨碍辨认、追踪有效波的其他波。 地震勘探中&#xff0c;有效波和干扰波是相对的。例如&#xff0c;在反射波…...

Redis相关知识总结(缓存雪崩,缓存穿透,缓存击穿,Redis实现分布式锁,如何保持数据库和缓存一致)

文章目录 1.什么是Redis&#xff1f;2.为什么要使用redis作为mysql的缓存&#xff1f;3.什么是缓存雪崩、缓存穿透、缓存击穿&#xff1f;3.1缓存雪崩3.1.1 大量缓存同时过期3.1.2 Redis宕机 3.2 缓存击穿3.3 缓存穿透3.4 总结 4. 数据库和缓存如何保持一致性5. Redis实现分布式…...

Cloudflare 从 Nginx 到 Pingora:性能、效率与安全的全面升级

在互联网的快速发展中&#xff0c;高性能、高效率和高安全性的网络服务成为了各大互联网基础设施提供商的核心追求。Cloudflare 作为全球领先的互联网安全和基础设施公司&#xff0c;近期做出了一个重大技术决策&#xff1a;弃用长期使用的 Nginx&#xff0c;转而采用其内部开发…...

自然语言处理——Transformer

自然语言处理——Transformer 自注意力机制多头注意力机制Transformer 虽然循环神经网络可以对具有序列特性的数据非常有效&#xff0c;它能挖掘数据中的时序信息以及语义信息&#xff0c;但是它有一个很大的缺陷——很难并行化。 我们可以考虑用CNN来替代RNN&#xff0c;但是…...

[Java恶补day16] 238.除自身以外数组的乘积

给你一个整数数组 nums&#xff0c;返回 数组 answer &#xff0c;其中 answer[i] 等于 nums 中除 nums[i] 之外其余各元素的乘积 。 题目数据 保证 数组 nums之中任意元素的全部前缀元素和后缀的乘积都在 32 位 整数范围内。 请 不要使用除法&#xff0c;且在 O(n) 时间复杂度…...

C++ Visual Studio 2017厂商给的源码没有.sln文件 易兆微芯片下载工具加开机动画下载。

1.先用Visual Studio 2017打开Yichip YC31xx loader.vcxproj&#xff0c;再用Visual Studio 2022打开。再保侟就有.sln文件了。 易兆微芯片下载工具加开机动画下载 ExtraDownloadFile1Info.\logo.bin|0|0|10D2000|0 MFC应用兼容CMD 在BOOL CYichipYC31xxloaderDlg::OnIni…...

Go 语言并发编程基础:无缓冲与有缓冲通道

在上一章节中&#xff0c;我们了解了 Channel 的基本用法。本章将重点分析 Go 中通道的两种类型 —— 无缓冲通道与有缓冲通道&#xff0c;它们在并发编程中各具特点和应用场景。 一、通道的基本分类 类型定义形式特点无缓冲通道make(chan T)发送和接收都必须准备好&#xff0…...

基于IDIG-GAN的小样本电机轴承故障诊断

目录 🔍 核心问题 一、IDIG-GAN模型原理 1. 整体架构 2. 核心创新点 (1) ​梯度归一化(Gradient Normalization)​​ (2) ​判别器梯度间隙正则化(Discriminator Gradient Gap Regularization)​​ (3) ​自注意力机制(Self-Attention)​​ 3. 完整损失函数 二…...

解决:Android studio 编译后报错\app\src\main\cpp\CMakeLists.txt‘ to exist

现象&#xff1a; android studio报错&#xff1a; [CXX1409] D:\GitLab\xxxxx\app.cxx\Debug\3f3w4y1i\arm64-v8a\android_gradle_build.json : expected buildFiles file ‘D:\GitLab\xxxxx\app\src\main\cpp\CMakeLists.txt’ to exist 解决&#xff1a; 不要动CMakeLists.…...

Python 训练营打卡 Day 47

注意力热力图可视化 在day 46代码的基础上&#xff0c;对比不同卷积层热力图可视化的结果 import torch import torch.nn as nn import torch.optim as optim from torchvision import datasets, transforms from torch.utils.data import DataLoader import matplotlib.pypl…...