一、快速开始

liteflow需要你的项目使用maven

1.1依赖

<dependency>
	<groupId>com.thebeastshop.liteflow</groupId>
	<artifactId>liteflow</artifactId>
	<version>${liteFlow.version}</version>
</dependency>

最新版本为2.1.0
稳定版本为2.0.1

1.2流程配置文件

(不依赖任何框架的写法)

<?xml version="1.0" encoding="UTF-8"?>
<flow>
	<nodes>
		<node id="a" class="com.thebeastshop.liteflow.test.component.AComponent"/>
		<node id="b" class="com.thebeastshop.liteflow.test.component.BComponent"/>
		<node id="c" class="com.thebeastshop.liteflow.test.component.CComponent"/>
		<node id="d" class="com.thebeastshop.liteflow.test.component.DComponent"/>
		<node id="e" class="com.thebeastshop.liteflow.test.component.EComponent"/>
	</nodes>
	
	<chain name="demoChain">
		<then value="a,b,c"/> <!-- then表示串行 -->
		<when value="d,e"/> <!-- when表示并行 -->
	</chain>
</flow>

component为组件，这里你需要实现这些组件，每个组件继承NodeComponent类

public class AComponent extends NodeComponent {

	@Override
	public void process() {
		String str = this.getSlot().getRequestData();
		System.out.println(str);
		System.out.println("Acomponent executed!");
	}
}

chain为流程链，每个链上可配置多个组件节点。目前执行的模式分串行和并行2种。
串行标签为then，并行标签为when。
在串行的模式下，以下2种写法是等价的,可以根据业务需要来把不同种类的节点放一行里。

<then value="a,b,c,d"/>

<then value="a,b"/>
<then value="c,d"/>

1.3执行流程链

(不依赖任何框架的写法)

FlowExecutor executor = new FlowExecutor();
executor.setRulePath(Arrays.asList(new String[]{"/config/flow.xml"}));
executor.init();
Slot slot = executor.execute("demoChain", "arg");

如果你的项目使用spring，推荐参考和Spring进行集成

二、和spring进行集成

2.1流程配置可以省略的部分

流程配置中的nodes节点，可以不用配置了，支持spring的自动扫描方式。你需要在你的spring配置文件中定义

<context:component-scan base-package="com.thebeastshop.liteflow.test.component" />
<bean class="com.thebeastshop.liteflow.spring.ComponentScaner"/>

当然，你的组件节点也需要注册进spirng容器

@Component("a")
public class AComponent extends NodeComponent 
	@Override
	public void process() {
		String str = this.getSlot().getRequestData();
		System.out.println(str);
		System.out.println("Acomponent executed!");
	}
}

2.2spring中执行器的配置

<bean id="flowExecutor" class="com.thebeastshop.liteflow.core.FlowExecutor">
	<property name="rulePath">
		<list>
			<value>/config/flow.xml</value>
		</list>
	</property>
</bean>

然后你的项目中通过spring拿到执行器进行调用流程。

三、和Spring Boot集成

3.1 依赖

liteFlow提供了liteflow-spring-boot-starter依赖包

<dependency>
  <groupId>com.thebeastshop</groupId>
  <artifactId>liteflow-spring-boot-starter</artifactId>
  <version>2.1.0</version>
</dependency>

3.2配置

在依赖了以上jar包后。

在application.properties里加上配置地址后，就可以在容器中依赖拿到FlowExecutor实例

liteflow.ruleSource=config/flow.xml

工程中的liteflow-test演示了如何在springboot下进行快速配置

四、和zookeeper进行集成

4.1spring配置

liteFlow支持把配置放在zk集群中，并支持实时修改流程
你只需在原来配置执行器的地方，把本地xml路径换成zk地址就ok了

<!-- 这种是zk方式配置 -->
<bean id="flowExecutor" class="com.thebeastshop.liteflow.core.FlowExecutor">
	<property name="rulePath">
		<list>
			<value>127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183</value>
		</list>
	</property>
	<!--这个不配置就用默认的/lite-flow/flow节点 -->
	<property name="zkNode" value="/lite-flow/customFlow"/>
</bean>

如果你不加zkNode这个标签，就用默认的节点路径进行读取配置。
使用这种方式加载配置，在zk上进行更改配置。liteFlow会实时刷新配置。

五、使用自定义的配置源

5.1创建自定义配置源的类

如果你不想用本地的配置，也不打算使用zk作为配置持久化工具。liteFlow支持自定义的配置源的扩展点。
在你的项目中创建一个类继承ClassXmlFlowParser这个类

public class TestCustomParser extends ClassXmlFlowParser {

	@Override
	public String parseCustom() {
		System.out.println("进入自定义parser");
		String xmlContent = null;
		//这里需要自己扩展从自定义的地方获取配置
		return xmlContent;
	}
}

5.2Spring配置

spring中需要改的地方还是执行器的配置，只需要在配置的路径地方放入自定义类的类路径即可

<bean id="flowExecutor" class="com.thebeastshop.liteflow.core.FlowExecutor">
	<property name="rulePath">
		<list>
			<value>com.thebeastshop.liteflow.test.TestCustomParser</value>
		</list>
	</property>
</bean>

六、架构设计

6.1组件式流程引擎架构设计

Handler Unit：我们想象成每一个业务都是一个业务组件，每一个业务组件就是一个handlerUnit（处理单元）
EPU：这里的epu对应的就是我们的执行器，用来统筹并处理handlerUnit。相当于计算机的CPU
Event Bus：事件总线，用来指定下一个命令是什么，该如何去执行处理单元。这里的时间总线由我们的配置构成
Data Bus：数据总线，用来存储整个调用链里数据。每一个请求生成一个数据槽。一个数据里最多有1024个数据槽

七、接入详细指南

7.1执行器

执行器FlowExecutor用来执行一个流程，用法为

public <T extends Slot> T execute(String chainId,Object param);

第一个参数为流程ID，第二个参数为流程入参
返回为Slot接口的子类，以上方法所返回的为默认的实现类DefaultSlot

!> 实际在使用时，并不推荐用默认的DefaultSlot，推荐自己新建一个类继承AbsSlot类
这是因为默认Slot实现类里面大多数都存放元数据，给用户扩展的数据存储是一个弱类型的Map
而用户自定义的Slot可以实现强类型的数据，这样对开发者更加友好

推荐使用带自定义Slot的执行接口：

public <T extends Slot> T execute(String chainId,Object param,Class<? extends Slot> slotClazz);

关于Slot的说明，请参照数据槽

7.2数据槽

在执行器执行流程时会分配唯一的一个数据槽给这个请求。不同请求的数据槽是完全隔离的。
数据槽实际上是一个Map，里面存放着liteFlow的元数据
比如可以通过getRequestData获得流程的初始参数，通过getChainName获取流程的命名，通过setInput,getInput,setOutput,getOutput设置和获取属于某个组件专有的数据对象。当然也提供了最通用的方法setData和getData用来设置和获取业务的数据。

!> 不过这里还是推荐扩展出自定义的Slot（上一小章阐述了原因），自定义的Slot更加友好。更加贴合业务。

7.3组件节点

组件节点需要继承NodeComponent类
需要实现process方法
但是推荐实现isAccess方法，表示是否进入该节点，可以用于业务参数的预先判断

其他几个可以覆盖的方法有：
方法isContinueOnError：表示出错是否继续往下执行下一个组件
方法isEnd：表示是否立即结束整个流程

在组件节点里，随时可以通过方法getSlot获取当前的数据槽，从而可以获取任何数据。

7.4条件节点

在实际业务中，往往要通过动态的业务逻辑判断到底接下去该执行哪一个节点

<chain name="chain1">
    <then value="a,c(b|d)"/> <!-- cond是条件节点，根据c里的逻辑决定路由到b节点还是d节点,可以配置多个 -->
    <then value="e,f,g"/>
</chain>

利用表达式可以很方便的进行条件的判断
c节点是用来路由的，被称为条件节点，这种节点需要继承NodeCondComponent类
需要实现方法processCond，这个方法需要返回Class类型，就是具体的结果节点

7.5嵌套执行

liteFlow可以无极嵌套执行n条流程

@Component("h")
public class HComponent extends NodeComponent {

	@Resource
	private FlowExecutor flowExecutor;
	
	@Override
	public void process() {
		System.out.println("Hcomponent executed!");
		flowExecutor.invoke("strategy1",3, DefaultSlot.class, this.getSlotIndex());
	}
	
}

这段代码演示了在某个业务节点内调用另外一个流程链的方法

7.6步骤打印

liteFlow在执行每一条流程链后会打印步骤
样例如下：

a==>c==>h(START)==>m==>p==>p1==>h(END)==>g

?> 其中h节点分start和end两个步骤，说明在h节点内调用了另一条流程。start和end之间的步骤就是另一条流程的步骤

7.7监控

liteFlow提供了简单的监控，目前只统计一个指标：每个组件的平均耗时
每5分钟会打印一次，并且是根据耗时时长倒序排的。

八、未来版本计划

2.5版本

支持更多的表达式，重写表达式解析器
重新设计数据总线，解决数据槽热点问题
增加一种驱动模式：消息驱动的模式
对spring进行标签级支持
对组件侵入更低，支持标注级声明
增加监控的数据类型

2.6版本

提供一个简单的组件注册中心
有UI界面来查看监控数据
此版本的重点功能：能用UI界面来回放整个执行过程（精确到数据槽里每一个对象）
此版本的重点功能：界面式设计规则

3.0版本

主要是规则引擎的进化，制定规则文件。完善表达式引擎。

八、更新记录

1.3.1更新日志

优化大量潜在的问题，此版本为稳定版本，主要更新点如下：

增加条件节点功能
优化异常捕获的日志打印
支持自定义SLOT的特性
优化步骤打印，能够支持开闭区间的打印方式
增加了内部策略的调用方式
增加了追踪ID
优化了监控打印

2.0.1更新日志

更新点如下：

增加对zookeeper的支持
增加自定义配置源
优化监控的表现

guide_cn.md 11 KB 히스토리 Raw