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

Nodeflow4j业务流程配置化利器