Java Flow 通用流编排应用开发框架 支持已知流编排的各种场景

源码资源网

Java Flow 通用流编排应用开发框架 支持已知流编排的各种场景
通用流编排引擎。可用于计算（或任务）的编排场景； 可用于业务规则和决策处理型的编排场景； 可用于办公审批型（有状态、可中断，人员参与）的编排场景； 可用于长时间流程（结合自动前进，等待介入）的编排场景。

面向全场景的 Java Flow （流编排）应用开发框架。是 Solon 项目的一部分。也可嵌入到 SpringBoot2、jFinal、Vert.x 等框架中使用。

支持已知流编排的各种场景:

• 可用于计算（或任务）的编排场景
• 可用于业务规则和决策处理型的编排场景
• 可用于办公审批型（有状态、可中断，人员参与）的编排场景
• 可用于长时间流程（结合自动前进，等待介入）的编排场景
  

附件中包含嵌入第三方框架的示例

六大特性展示1、使用

1. # c2.yml
   
2. id: "c2"
   
3. layout:
   
4.   - { type: "start"}
   
5.   - { when: "order.getAmount() >= 100", task: "order.setScore(0);"}
   
6.   - { when: "order.getAmount() > 100 && order.getAmount() <= 500", task: "order.setScore(100);"}
   
7.   - { when: "order.getAmount() > 500 && order.getAmount() <= 1000", task: "order.setScore(500);"}
   
8.   - { type: "end"}

复制代码

yaml 格式

配置简洁，关系清晰

1. # c1.yml
   
2. id: "c1"
   
3. layout:
   
4.   - { id: "n1", type: "start", link: "n2"}
   
5.   - { id: "n2", type: "activity", link: "n3"}
   
6.   - { id: "n3", type: "end"}

复制代码

还支持简化模式（能自动推断的，都会自动处理），具体参考相关说明

1. # c1.yml
   
2. id: "c1"
   
3. layout:
   
4.   - { type: "start"}
   
5.   - { task: ""}
   
6.   - { type: "end"}

复制代码

2、表达式与脚本自由

1. # c2.yml
   
2. id: "c2"
   
3. layout:
   
4.   - { type: "start"}
   
5.   - { when: "order.getAmount() >= 100", task: "order.setScore(0);"}
   
6.   - { when: "order.getAmount() > 100 && order.getAmount() <= 500", task: "order.setScore(100);"}
   
7.   - { when: "order.getAmount() > 500 && order.getAmount() <= 1000", task: "order.setScore(500);"}
   
8.   - { type: "end"}

复制代码

3、元信息配置，为扩展提供了无限空间（每个流程，相当于自带了元数据库）

1. # c3.yml
   
2. id: "c3"
   
3. layout:
   
4.   - { id: "n1", type: "start", link: "n2"}
   
5.   - { id: "n2", type: "activity", link: "n3", meta: {cc: "demo@noear.org"}, task: "@MetaProcessCom"}
   
6.   - { id: "n3", type: "end"}

复制代码

通过组件方式，实现元信息的抄送配置效果

1. @Component("MetaProcessCom")
   
2. public class MetaProcessCom implements TaskComponent {
   
3.     @Override
   
4.     public void run(FlowContext context, Node node) throws Throwable {
   
5.        String cc = node.getMeta("cc");
   
6.        if(Utils.isNotEmpty(cc)){
   
7.            //发送邮件...
   
8.        }
   
9.     }
   
10. }

复制代码

也可通过驱动定制方式，实现抄送效果（显得重一些）

1. public class OaFlowDriver extends SimpleFlowDriver {
   
2.     @Override
   
3.     public void handleTask(FlowContext context, Task task) throws Throwable {
   
4.         if (Utils.isEmpty(task.getDescription())) {
   
5.            String cc = task.getNode().getMeta("cc");
   
6.            if(Utils.isNotEmpty(cc)){
   
7.                //发送邮件
   
8.            }
   
9.         } else {
   
10.             super.handleTask(context, task);
    
11.         }
    
12.     }
    
13. }
    
14. 
    
15. //FlowEngine flowEngine = FlowEngine.newInstance();
    
16. //flowEngine.register(new OaFlowDriver()); //替换掉默认驱动

复制代码

4、事件广播与回调支持

广播（即只需要发送），回调（即发送后要求给答复）

1. id: f4
   
2. layout:
   
3.   - task: |
   
4.       //只发送
   
5.       context.<String,String>eventBus().send("demo.topic", "hello");  //支持泛型（类型按需指定，不指定时为 object）
   
6.   - task: |
   
7.       //发送并要求响应（就是要给答复）
   
8.       String rst = context.<String,String>eventBus().sendAndRequest("demo.topic.get", "hello");
   
9.       System.out.println(rst);

复制代码

5、支持“无状态”、“有状态”两种需求分类

支持丰富的应用场景：

• 可用于计算（或任务）的编排场景
• 可用于业务规则和决策处理型的编排场景
• 可用于办公审批型（有状态、可中断，人员参与）的编排场景
• 可用于长时间流程（结合自动前进，等待介入）的编排场景
  

自身也相当于一个低代码的运行引擎（单个 yml 文件，也可满足所有的执行需求）。

6、驱动定制（是像 JDBC 有 MySql, PostgreSQL，还可能有 Elasticsearch）

这是一个定制后的，支持基于状态驱动的流引擎效果。

1. StatefulFlowEngine flowEngine = new StatefulFlowEngine(StatefulSimpleFlowDriver.builder()
   
2.                 .stateOperator(new MetaStateOperator("actor"))
   
3.                 .stateRepository(new InMemoryStateRepository())
   
4.                 .build());
   
5.                
   
6. var context = new StatefulFlowContext("i1").put("actor", "陈鑫");
   
7. 
   
8. //获取上下文用户的活动节点
   
9. var statefulNode = flowEngine.getActivityNode("f1", context);
   
10. 
    
11. assert "step2".equals(statefulNode.getNode().getId());
    
12. assert StateType.UNKNOWN == statefulNode.getState(); //没有权限启动任务（因为没有配置操作员）
    
13. 
    
14. //提交活动状态
    
15. flowEngine.postActivityState(context, "f1", statefulNode.getNode().getId(), StateType.COMPLETED);

复制代码

流程配置样例：

1. id: f1
   
2. layout:
   
3.   - {id: step1, title: "发起审批", type: "start"}
   
4.   - {id: step2, title: "抄送", meta: {cc: "吕方"}, task: "@OaMetaProcessCom"}
   
5.   - {id: step3, title: "审批", meta: {actor: "陈鑫", cc: "吕方"}, task: "@OaMetaProcessCom"}
   
6.   - {id: step4, title: "审批", type: "parallel", link: [step4_1, step4_2]}
   
7.   - {id: step4_1, meta: {actor: "陈宇"}, link: step4_end}
   
8.   - {id: step4_2, meta: {actor: "吕方"}, link: step4_end}
   
9.   - {id: step4_end, type: "parallel"}
   
10.   - {id: step5, title: "抄送", meta: {cc: "吕方"}, task: "@OaMetaProcessCom"}
    
11.   - {id: step6, title: "结束", type: "end"}

复制代码

Java Flow 通用流编排应用开发框架 支持已知流编排的各种场景

链接：https://pan.quark.cn/s/61c59dda5331
提取码下载：

文件名称:提取码下载.txt 
下载次数:0  文件大小:16 Bytes  售价:29金钱 [记录]
下载权限: 不限 [购买VIP]   [充值]   [在线充值]   【VIP会员6折；永久VIP4折】

安全检测，请放心下载