Nodeflow4j简介
Nodeflow4j是本人最近发布的一个JAVA开源项目,并实际运用于生产项目中。一直想写一篇中文的介绍,恰好公司美女约稿,治愈本次的懒癌。
Nodeflow4j是一个轻量基于JSON定义且面象组件开发的JAVA流程引擎。
主要特性
- JSON定义
和其他的流程引擎基于XML不同,其基于JSON定义在流程配置和定义方面更加简洁和友好,且流程解析方面性能更佳。
- 面向组件
基于组件化开发的可以灵活,可伸缩的配置业务流程。包括内置的组件,还可以自定义自身的组件并在多个业务流程中使用。
如果组件足够丰富,可以做到零编程或少编程,就能定义一个新的业务处理流程。
- Groovy表达式
除了语法简法和亲切,Groovy在处理表达式方面更加强大和高效。
JSON定义说明
下面是一个JSON定义的样本,演示表达式的定义和流程的跳转
{
"indexs":[{"idx":"foo","type":"INT"},
{"idx":"bar","mode":2,"type":"INT"}],
"nodes":[
{"id":"n1","component":"ruleset","ruleset":
["bar=foo*1000","bar+=24"],"next":"n2"},
{"id":"n2","next":[{"condition":"bar==1024","next":"n3"},
{"condition":"bar==2024","next":"n4"},{"next":"n5"}]},
{"id":"n3","component":"testCustomComponent"},
{"id":"n4"},
{"id":"n5"}
]
}
-
indexs - 输入输出参数
ind - 参数名称
type - 参数类型,取值INT,LONG,DOUBLE 或 NUMERIC,大小写不敏感
mode - 参数模式,取值1, 2或3分别代表输入,输出或即是输入也是输出(流程执行完的输出结果)
-
nodes - 流程结点
id - 流程上结点的唯一性ID
component - 组件ID
next - 当前结点的下一个结点. 取值可以是结点的ID字符串(无条件进行下一个结点)或是对象(需进行条件判断),当取值为对象时, 必须有condition属性。当为对象数组时,即按数据顺序进行历遍,符合条件时后面的条件不再判断
内置组件
当前提供下列内置组件,更多的内置组件将会陆续提供。当然你也可以自定义自己的组件
ruleset - 执行一组groovy表代式
delay - 执行下一个结点时进行延时,默认为2秒钟
开始使用
- 怎么执行流程文件
下面是com.github.zzzhan.nodeflow4j.NodeflowTest的代码片断, 位于src/test/java,可直接运行并查看结果。
nfJson = IOUtils.toString(NodeflowTest.class.getResourceAsStream(
"/NodeflowTest.nf"));
Map<String, Object> params = new HashMap<String,Object>();
params.put("foo", 1);
Nodeflow nf = new Nodeflow(nfJson);
nf.execute(params);
assertEquals("n3", nf.getCurNode());
Map<String, Object> output = nf.getOutput();
assertEquals(2048, output.get("bar"));
params.put("foo", 2);
nf = new Nodeflow(nfJson);
nf.execute(params);
assertEquals("n4", nf.getCurNode());
output = nf.getOutput();
assertEquals(2024, output.get("bar"));
params.put("foo", 3);
nf = new Nodeflow(nfJson);
nf.execute(params);
assertEquals("n5", nf.getCurNode());
- 在Spring中使用
请打开模块nodeflow4j-spring, 并查看里面的使用方式
- Maven
<dependency>
<groupId>com.github.zzzhan</groupId>
<artifactId>nodeflow4j</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
应用场景
之前涉及到一些风控建模采用了drools(基于JAVA的规则引擎),暂不说其运行效率,其定义配置跟写程序无异,对业务人员很不友好,维护很不方便,所以才有了Nodeflow4j。
Nodeflow4j可以满足业务流程变动的需求,对流程定义维护可以快速响应。典型的,可以应用于连接多方数据,进行模型构建,如用户评分、额度测算或交叉验证等等业务。
当然对流程状态进行持久化,也可以作为工作流引擎的底层实现。因此,基于组件化的流程定义在实际的业务流程处理中可以发挥很大作用。
最后
帮加个星,加星又不会怀孕:https://github.com/zzzhan/nodeflow4j
网友评论