如何在Netflix Conductor中将微服务(或其方法)注册到Task？

Question

我正在寻找比AxonFramework中的Saga更复杂的工作流程 - 我们目前正在使用它 - 我在Netflix Conductor中找到了一个.可悲的是,我在互联网上搜索了一个不错的例子,但无济于事.

我的问题是,在Netflix Conductor中,如何定义和创建Task或WorkflowTask,最重要的是,将微服务链接到它？这是来自github的Netflix指挥代码:

    WorkflowDef def = new WorkflowDef();
    def.setName("test");
    WorkflowTask t0 = new WorkflowTask();
    t0.setName("t0");
    t0.setType(Type.SIMPLE);
    t0.setTaskReferenceName("t0");

    WorkflowTask t1 = new WorkflowTask();
    t1.setName("t1");
    t1.setType(Type.SIMPLE);
    t1.setTaskReferenceName("t1");

    def.getTasks().add(t0);
    def.getTasks().add(t1);

原谅我的困惑,因为我是Netflix Conductor的新手.

Answer 1

（免责声明：我没有尝试过，我只是查看了文档......）

1. 实现您自己的WorkflowSystemTask
2. 重写 start() /execute() 方法来调用您的微服务
3. 根据 https://netflix.github.io/conductor/intro/concepts/#worker-taks将任务类型设置为 SIMPLE