在 Spring 云数据流中使用一个源、两个并行处理器和一个接收器创建流
Create Stream with one source, two parallel processors and one sink in Spring Cloud Data Flow
我正在尝试使用
在 Spring 云数据流中创建流
一个来源即订单来源
订单消息将发布到 RabbitMQ Topic/Queue.
两个并行处理器，即产品处理器和装运处理器
这两个处理器都将成为 RabbitMQ Topic/Queue 的订阅者并获取订单消息，它们中的每一个都将单独处理这些订单消息并更新订单，订单消息将发布到 RabbitMQ Topic/Queue。
一个接收器，即支付接收器
接收器将成为 RabbitMQ Topic/Queue 的订阅者，并将获取订单消息并根据订单消息完成付款流程。
我尝试了以下命令并部署了
stream create --name order-to-payment --definition 'order-source | product-processor|shipment-processor | payment-sink'
但在 Spring Cloud Data Flow 中的图形显示如下：
但我看起来像下面这样
有可能实现吗？由于 Spring Cloud Data Flow 不允许它从一个源连接两个处理器，也无法以图形方式从两个处理器连接到一个接收器？
谢谢，
大卫.
您可以使用命名目标将 DAG 与数据流结合起来，请在此处查看：http://docs.spring.io/spring-cloud-dataflow/docs/1.2.2.RELEASE/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced
您将需要通过指定的目的地发送您的消息，并从它们组成流程。如果您在浏览文档时遇到问题，请告诉我，我可以 post 这里举个例子。
我正在尝试使用
在 Spring 云数据流中创建流一个来源即订单来源 订单消息将发布到 RabbitMQ Topic/Queue.
两个并行处理器，即产品处理器和装运处理器 这两个处理器都将成为 RabbitMQ Topic/Queue 的订阅者并获取订单消息，它们中的每一个都将单独处理这些订单消息并更新订单，订单消息将发布到 RabbitMQ Topic/Queue。
一个接收器，即支付接收器 接收器将成为 RabbitMQ Topic/Queue 的订阅者，并将获取订单消息并根据订单消息完成付款流程。
我尝试了以下命令并部署了
stream create --name order-to-payment --definition 'order-source | product-processor|shipment-processor | payment-sink'
但在 Spring Cloud Data Flow 中的图形显示如下：
但我看起来像下面这样
有可能实现吗？由于 Spring Cloud Data Flow 不允许它从一个源连接两个处理器，也无法以图形方式从两个处理器连接到一个接收器？
谢谢， 大卫.
您可以使用命名目标将 DAG 与数据流结合起来，请在此处查看：http://docs.spring.io/spring-cloud-dataflow/docs/1.2.2.RELEASE/reference/htmlsingle/#spring-cloud-dataflow-stream-advanced
您将需要通过指定的目的地发送您的消息，并从它们组成流程。如果您在浏览文档时遇到问题，请告诉我，我可以 post 这里举个例子。