流程编排

快速开始

业务场景 代码

参见hz.ddbm.jfsm.pay包

public class PayFsm extends Fsm {
   //    定义工作流
   @Override
   public Flow flow() {
       return new FlowBuilder("testFlow", null, null) {
           {
               addNode(new NodeBuilder(Node.Type.START, "init") {{
                   onEvent(Coast.EVENT_PUSH, "payAction", "any://payRouter", "pay_unknow", "true");
               }});
               addNode(new NodeBuilder(Node.Type.TASK, "pay_unknow") {{
                   onEvent(Coast.EVENT_PUSH, "payQueryAction", "any://payRouter");
               }});
               addNode(new NodeBuilder(Node.Type.END, "su"));
               addNode(new NodeBuilder(Node.Type.END, "fail"));

               addRouter(payRouter());
               addPlugin("logPlugin");
           }
//            回忆

       }.build();
   }

   //定义路由
   private Router payRouter() {
       return new Router.Any("payRouter", new HashMap<String, String>() {{
           put("su", "null != actionResult && actionResult.code == '0000'");
           put("fail", "null != actionResult &&  actionResult.code == '0001'");
           put("pay_unknow", "true");
       }});
   }

}

测试

 pcService.executeMore("testFlow",1, new Object(),Coast.EVENT_PUSH,null)


2024-06-12 11:33:23.700  INFO 20140 --- [           main] hz.ddbm.pc.core.PcServiceTest            : Starting PcServiceTest using Java 1.8.0_381 on DESKTOP-RJKO1VK with PID 20140 (started by wanglin in D:\project\process-control)
2024-06-12 11:33:23.700  INFO 20140 --- [           main] hz.ddbm.pc.core.PcServiceTest            : No active profile set, falling back to 1 default profile: "default"
2024-06-12 11:33:24.096  INFO 20140 --- [           main] o.s.c.a.ConfigurationClassEnhancer       : @Bean method PcConfiguration.infraUtils is non-static and returns an object assignable to Spring's BeanFactoryPostProcessor interface. This will result in a failure to process annotations such as @Autowired, @Resource and @PostConstruct within the method's declaring @Configuration class. Add the 'static' modifier to this method to avoid these container lifecycle issues; see @Bean javadoc for complete details.
2024-06-12 11:33:24.175  INFO 20140 --- [           main] hz.ddbm.pc.core.PcService                : 初始化流程:testFlow
2024-06-12 11:33:24.698  INFO 20140 --- [           main] hz.ddbm.pc.core.PcServiceTest            : Started PcServiceTest in 1.204 seconds (JVM running for 1.852)
2024-06-12 11:33:24.824  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,init,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,pay_unknow
2024-06-12 11:33:24.840  INFO 20140 --- [           main] hz.ddbm.pc.core.plugin.LogPlugin         : testFlow,1,pay_unknow,fail

功能

• 复杂、长业务流程积木化、组件化开发
• 高性能SAGA事务
• 插件化可插拔功能，包括：日志、监控、告警、统计……等
• 动态发布
• 数字化运营

使用说明

flow参数

• flowName：流程名
• statusService：状态存储服务bean：redis/jvm或自定义
• sessionService：会话存储服务bean：redis/jvm
• nodes：流程所属节点
• routers：路由定义
• plugins：插件

节点

• Node.Type: 节点类型

  • Node.Type.Start: 开始节点，只能有有一个
  • Node.Type.Task: 业务节点
  • Node.Type.End: 结束节点

• name: 节点名称/状态名称

事件

路由

插件