solon-flow 是一个基础级的流处理引擎（可用于业务规则、决策处理、计算编排、流程审批等…）。提供有 “开放式” 驱动定制支持，像 jdbc 有 mysql 或 pgsql 等驱动，可为不同的应用场景定制不同的驱动处理。

1、Helloworld

1.1、新建项目

可以用 Solon Initializr 新建 solon-lib 模板项目，之后添加 solon-flow 依赖（也支持在 spring 或 vert.x 或 jfinal 项目里使用）。

<dependency><groupId>org.noear</groupId><artifactId>solon-flow</artifactId>
</dependency>

1.2、添加配置

在 app.yml 里添加应用配置，指定 flow 为流处理配置存放地：

solon.flow:- "classpath:flow/*"

添加流处理配置（支持 json 或 yml 格式），例： flow/demo1.chain.yml

id: "c1"
nodes: - { id: "n1", type: "start", link: "n2"}- { id: "n2", type: "execute", link: "n3", task: "System.out.println(\"hello world!\");"}- { id: "n3", type: "end"}

示意图：

1.3、代码应用

应用启动时，可以打印：hello world!。

java">@Component
public class DemoCom implements LifecycleBean {@Inject private FlowEngine flowEngine;@Overridepublic void start() throws Throwable {flowEngine.eval("c1");}
}

2、转换 drools 的规则参考

配置业务处理规则：flow/r1.chain.yml。使用 solon-flow 的简化模式，很适配转换 drools dsl 的规则：

id: "r1"
title: "评分规则"
nodes:- { type: "start"}- { when: "order.getAmount() >= 100", task: "order.setScore(0);"}- { when: "order.getAmount() > 100 && order.getAmount() <= 500", task: "order.setScore(100);"}- { when: "order.getAmount() > 500 && order.getAmount() <= 1000", task: "order.setScore(500);"}- { type: "end"}

规则应用：

java">@Component
public class DemoCom {@Inject FlowEngine flowEngine;//评分public int score(Order order) {//执行ChainContext ctx = new ChainContext();ctx.put("order", order); //模型数据，可被规则直接使用flowEngine.eval("r1", ctx);//获取评分结果return order.getScore();}
}