LiteFlow规则引擎框架

news2025/1/20 3:43:26

LiteFlow规则引擎框架

Hi，我是阿昌，今天介绍一个规则引擎框架，LiteFlow；

一、前言

那首先得知道什么是规则引擎？规则引擎是一种用于自动化处理业务规则的软件组件。

在软件行业中，规则引擎通常用于解决复杂的业务逻辑处理问题。它可以将业务规则从应用程序中分离出来，并以一种易于管理和维护的方式进行配置和修改。

规则引擎能够根据预先定义的规则集对输入数据进行评估和处理，并根据规则的结果执行相应的操作。这样可以提高软件系统的灵活性、可扩展性和可维护性。

规则引擎在许多软件领域都有广泛的应用，比如金融行业的风险评估、保险业的理赔处理、电子商务的促销活动等。

一些拥有复杂业务逻辑的系统，这些系统承载着核心业务逻辑，几乎每个需求都和这些核心业务有关，这些核心业务业务逻辑冗长，涉及内部逻辑运算，缓存操作，持久化操作，外部资源调取，内部其他系统RPC调用等等。时间一长，项目几经易手，维护成本就会越来越高。各种硬代码判断，分支条件越来越多。

代码的抽象，复用率也越来越低，各个模块之间的耦合度很高。一小段逻辑的变动，会影响到其他模块，需要进行完整回归测试来验证。

如要灵活改变业务流程的顺序，则要进行代码大改动进行抽象，重新写方法。实时热变更业务流程，几乎很难实现，那LiteFlow为解耦逻辑而生，为编排而生。

二、优势

一个编排式的规则引擎框架，组件编排，帮助解耦业务代码，让每一个业务片段都是一个组件。
- 可以将瀑布流式的代码，转变成以组件为核心概念的代码结构，这种结构的好处是可以任意编排，组件与组件之间是解耦的，组件可以用脚本来定义，组件之间的流转全靠规则来驱动。
- LiteFlow拥有开源规则引擎最为简单的DSL语法。
组件可实时热更替，也可以给编排好的逻辑流里实时增加一个组件，从而改变你的业务逻辑。
支持众多脚本语言，完全和Java打通，你可以用脚本来实现任何逻辑。
配置存放灵活，支持把编排规则和脚本放在数据库，注册中心中，还有可以任意扩展的接口，方便定制。
同时要保证所有组件都是灵活可变的。

三、场景情况

1、适用场景

LiteFlow适用于拥有复杂逻辑的业务，比如说价格引擎，下单流程等，这些业务往往都拥有很多步骤，这些步骤完全可以按照业务粒度拆分成一个个独立的组件，进行装配复用变更。

可得到一个灵活度高，扩展性很强的系统。

因为组件之间相互独立，也可以避免改一处而动全身的这样的风险。

2、不适用场景

LiteFlow只做基于逻辑的流转，而不做基于角色任务的流转。如果你想做基于角色任务的流转，推荐使用flowable (opens new window)，activiti (opens new window)这2个框架。

四、HelloWorld

liteflow支持多种框架的引入，场景的springboot、spring或非spring场景

1、前置版本

下面的代码是基于此版本进行演示：

springboot：2.3.4.RELEASE
jdk：1.8
liteflow-springboot：2.11.4.2

2、依赖

LiteFlow提供了liteflow-spring-boot-starter依赖包，提供自动装配功能

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

3、组件定义

在依赖了以上jar包后，需要定义并实现一些组件，确保SpringBoot会扫描到这些组件并注册进上下文。
定义如下：a,b,c组件

/**
 * @author achang
 * @date 2024/2/8 - 12:27 下午
 **/
@Component(value = "a")
public class AComponent extends NodeComponent {
	@Override
	public void process() throws Exception {
		System.out.println("do A");
	}
}

/**
 * @author achang
 * @date 2024/2/8 - 12:27 下午
 **/
@Component(value = "b")
public class BComponent extends NodeComponent {
	@Override
	public void process() throws Exception {
		System.out.println("do B");
	}
}

/**
 * @author achang
 * @date 2024/2/8 - 12:27 下午
 **/
@Component(value = "c")
public class CComponent extends NodeComponent {
	@Override
	public void process() throws Exception {
		System.out.println("do C");
	}
	
}

4、springboot配置

在SpringBoot的application.properties或者application.yml里添加配置(这里以properties为例，yaml也是一样的)，更多的配置项

liteflow.rule-source=config/flow.el.xml

5、流程规则编写

在上面flow.el.xml文件中编写流程规则

<?xml version="1.0" encoding="UTF-8"?>
<flow>
    <chain name="achang">
        THEN(a, b, c);
    </chain>
</flow>

SpringBoot在启动时会自动装载规则文件。

6、测试执行

编写测试执行类

/**
 * @author achang （caimu.zyc@raycloud.com）
 * @date 2024/2/8 - 12:34 下午
 * 执行测试组件
 **/
@Component("testHandleComponent")
public class TestHandleComponent {
	
	@Resource
	private FlowExecutor flowExecutor;
	
	public void testHandle(String arg){
		LiteflowResponse liteflowResponse = flowExecutor.execute2Resp("tagChain", arg);
		System.out.println("done");
	}
	
}

提示：
这个DefaultContext是默认的上下文，用户可以用最自己的任意Bean当做上下文传入，如果需要传入自己的上下文，则需要传用户Bean的Class属性，具体请看数据上下文这一章节。

编写测试入口：

@SpringBootTest
class LiteFlowDemoApplicationTests {
	
	@Autowired
	private TestHandleComponent testHandleComponent;

	@Test
	void contextLoads() {
		testHandleComponent.testHandle("achang");
	}
}