我正在寻找比 AxonFramework 中的 Saga 更复杂的工作流程——我们目前正在使用它——我在 Netflix Conductor 中找到了一个。
可悲的是,我在互联网上搜索了一个不错的例子,但无济于事。
我的问题是,在 Netflix Conductor 中,如何定义和创建 Task 或 WorkflowTask,最重要的是将微服务链接到它?这是来自 github 的 Netflix Conductor 代码:
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 的新手。
最佳答案
假设微服务有一个基于 HTTP 的 REST 端点。在这种情况下,您必须使用系统任务 HttpTask。 Httptask 进行 Http 调用,响应可作为任务输出。请引用以下链接:HttpTask
请记住将包含 HttpTask 的 WorkflowDef 的 SchemaVersion 设置为 2。您还需要一个相应的 Task type挂号的。
关于microservices - 如何在 Netflix Conductor 中向 Task 注册微服务(或其方法)?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41903352/