首页 > 解决方案 > 如何从 Spring Cloud 数据流任务将消息发布到目的地?

问题描述

是否有使用 Spring Cloud Data Flow 将消息从任务发送到目标的正确/首选方式?

我们有一个带有目的地的现有流,并且希望计划任务也通过其中一个目的地将消息馈送到流中。

到目前为止我们考虑过的选项:

  1. 使用 http 源应用程序创建一个新流以馈送到目标,然后在任务中使用 rest 模板将数据发布到 http 源。这种方法的问题是,如果重新部署流/pod,http 源的 ip 地址可能是短暂的。
  2. 在任务中手动配置rabbit,将消息直接发送到目的地(交换)。对这种方法的担忧是感觉有点脏,并且可能滥用数据流/流正在使用的底层消息传递系统。

标签: spring-cloud-streamspring-cloud-dataflowspring-rabbitspring-cloud-task

解决方案


我没有看到 #2 有任何实际问题,但您也可以配置输出绑定并使用StreamBridge发送给它。

将任意数据发送到输出(例如外部事件驱动源)


推荐阅读