面向全场景的 Java 通用流程编排框架。同时兼容 java8 ~ java25,是 OpenSolon 的重要组成部分。支持已知流程编排的各种场景:
- 可用于计算(或任务)的编排场景
- 可用于业务规则和决策处理型的编排场景
- 可用于可中断、可恢复流程(结合自动前进,停止,再执行)的编排场景
可视化设计器:
- https://solon.noear.org/flow/designer/
- 第三方开源(已组件化):https://gitee.com/opensolon/solon-flow-bpmn-designer
嵌入第三方框架(SpringBoot、jFinal、Vert.X、Quarkus、Micronaut 等)的示例:
- https://gitee.com/solonlab/solon-flow-embedded-examples
- https://gitcode.com/solonlab/solon-flow-embedded-examples
- https://github.com/solonlab/solon-flow-embedded-examples
一、最近更新了什么?
重要变化:
- 第六次预览
- 取消“有状态”、“无状态”概念。
- solon-flow 回归通用流程引擎(分离“有状态”的概念)。
- 新增 solon-flow-workflow 为工作流性质的封装(未来可能会有 dataflow 等)。
具体更新:
- 插件
solon-flow第六次预览 - 新增
solon-flow-workflow插件(替代 FlowStatefulService) - 添加
solon-flowFlowContext:lastNode() 方法(最后一个运行的节点) - 添加
solon-flowFlowContext:lastNodeId() 方法(最后一个运行的节点Id) - 添加
solon-flowNode.getMetaAs, Link.getMetaAs 方法 - 添加
solon-flowNodeSpec:linkRemove 方法(增强修改能力) - 添加
solon-flowGraph:create(id,title,consumer) 方法 - 添加
solon-flowGraph:copy(graph,consumer) 方法(方便复制后修改) - 添加
solon-flowGraphSpec:getNode(id) 方法 - 添加
solon-flowGraphSpec:addLoop(id) 方法替代 addLooping(后者标为弃用) - 添加
solon-flowFlowEngine:eval(Graph, …) 系列方法 - 优化
solon-flowFlowEngine:eval(Node startNode) 处理,改为从 root 开始恢复到 start 再开始执行(恢复过程中,不会执行任务) - 调整
solon-flow移除 Activity 节点预览属性 “i m o d e " 和 " imode" 和 "imode"和"omode” - 调整
solon-flowActivity 节点流出改为自由模式(可以多线流出:无条件直接流出,有条件检测后流出) - 调整
solon-flowNode.getMeta 方法返回改为 Object 类型(并新增 getMetaAs) - 调整
solon-flowEvaluation:runTest 改为 runCondition - 调整
solon-flowFlowContext:incrAdd,incrGet 标为弃用(上下文数据为型只能由输入侧决定) - 调整
solon-flowCondition 更名为 ConditionDesc - 调整
solon-flowTask 更名为 ConditionDesc - 调整
solon-flowGraphDecl 重命名改为 GraphSpec,NodeDecl 重命名改为 NodeSpec,LinkDecl 重命名改为 LinkSpec - 调整
solon-flowGraphSpec.parseByText 重命名改为 fromText,parseByUri 重命名改为 fromUri - 调整
solon-flowGraph.parseByText 重命名改为 fromText,parseByUri 重命名改为 fromUri
兼容变化对照表:
| 旧名称 | 新名称 | 说明 |
|---|---|---|
GraphDecl | GraphSpec | 图定义 |
GraphDecl.parseByXxx | GraphSpec.fromXxx | 图定义加载 |
Graph.parseByXxx | Graph.fromXxx | 图加载 |
LinkDecl | LinkSpec | 连接定义 |
NodeDecl | NodeSpec | 节点定义 |
Condition | ConditionDesc | 条件描述 |
Task | TaskDesc | 任务描述(避免与 workflow 的概念冲突) |
FlowStatefulService | WorkflowService | 工作流服务 |
StatefulTask | Task | 任务 |
Operation | TaskAction | 任动工作 |
TaskType | TaskState | 任务状态 |
FlowStatefulService 到 WorkflowService 的接口变化对照表:
| 旧名称 | 新名称 | 说明 |
|---|---|---|
postOperation(..) | postTask(..) | 提交任务 |
postOperationIfWaiting(..) | postTaskIfWaiting(..) | 提交任务 |
evel(..) | / | 执行 |
stepForward(..) | / | 单步前进 |
stepBack(..) | / | 单步后退 |
| / | getState(..) | 获取状态 |
新特性预览:Graph 硬编码方式(及修改能力增强)
//硬编码Graphgraph=Graph.create("demo1","示例",spec->{spec.addStart("start").title("开始").linkAdd("01");spec.addActivity("n1").task("@AaMetaProcessCom").linkAdd("end");spec.addEnd("end").title("结束");});//修改GraphgraphNew=Graph.copy(graph,spec->{spec.getNode("n1").linkRemove("end").linkAdd("n2");//移掉 n1 连接;改为 n2 连接spec.addActivity("n2").linkAdd("end");});新特性预览:FlowContext:lastNodeId (计算的中断与恢复)。参考:https://solon.noear.org/article/1246
flowEngine.eval(graph,context.lastNodeId(),context);//...(从上一个节点开始执行)flowEngine.eval(graph,context.lastNodeId(),context);新特性预览:WorkflowService(替代 FlowStatefulService)
WorkflowServiceworkflow=WorkflowService.of(engine,WorkflowDriver.builder().stateController(newActorStateController()).stateRepository(newInMemoryStateRepository()).build());//1. 取出任务Tasktask=workflow.getTask(graph,context);//2. 提交任务workflow.postTask(task.getNode(),TaskAction.FORWARD,context);二、特色展示
1、采用 yaml 或 json 偏平式编排格式
偏平式编排,没有深度结构(所有节点平铺,使用 link 描述连接关系)。配置简洁,关系清晰
# c1.ymlid:"c1"layout:-{id:"n1",type:"start",link:"n2"}-{id:"n2",type:"activity",link:"n3"}-{id:"n3",type:"end"}还支持简化模式(能自动推断的,都会自动处理),具体参考相关说明
# c1.ymlid:"c1"layout:-{type:"start"}-{task:""}-{type:"end"}2、表达式与脚本自由
# c2.ymlid:"c2"layout:-{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"}3、元数据配置,为扩展提供了无限空间
元数据主要有两个作用:(1)为任务运行提供配置支持(2)为视图编辑提供配置支持
# c3.ymlid:"c3"layout:-{id:"n1",type:"start",link:"n2"}-{id:"n2",type:"activity",link:"n3",task:"@MetaProcessCom",meta:{cc:"demo@noear.org"}}-{id:"n3",type:"end"}通过组件方式,实现元数据的抄送配置效果
@Component("MetaProcessCom")publicclassMetaProcessComimplementsTaskComponent{@Overridepublicvoidrun(FlowContextcontext,Nodenode)throwsThrowable{Stringcc=node.getMeta("cc");if(Utils.isNotEmpty(cc)){//发送邮件...}}}4、事件广播与回调支持
广播(即只需要发送),回调(即发送后要求给答复)
id:f4layout:-task:|//发送事件 context.eventBus().send("demo.topic", "hello"); //支持泛型(类型按需指定,不指定时为 object)-task:|//调用事件(就是要给答复) String rst = context.eventBus().<String, String>call("demo.topic.get", "hello").get(); System.out.println(rst);5、支持驱动定制(就像 jdbc 的驱动机制)
通过驱动定制,可方便实现:
- 工作流(workflow), 用于办公审批型(有状态、人员参与)的编排场景
- 规则流(ruleflow)
- 数据流(dataflow)
- AI流(aiflow)
- 等…