我正在寻找比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);
Run Code Online (Sandbox Code Playgroud)
原谅我的困惑,因为我是Netflix Conductor的新手.
我想知道是否有一种简单的方法可以连接 Kafka 和 Netflix Conductor(而不是 SQS)?目前,它似乎仅适用于 Amazon SQS。而且,似乎一个任务只能做出一个动作。有没有一种方法可以按任务执行多个操作?
提前致谢,
有人在生产代码上使用 Netflixconductor 吗?如果是,您是使用 Orkes 的托管版本还是自己直接集成和管理?希望在这里有任何见解,因为我们对如何选择感到困惑。
我们尝试了直接集成的 POC,但在使用 Postgres 进行持久性和其他部署相关问题时遇到了问题,并且在调试问题时无法找到良好的社区帮助。