Spring 集成和 Spring Cloud Stream

Question

我正在编写一个应用程序

• 轮询目录（Sprint 集成 DSL 流程）
• 一旦文件可用，它将放入 rabbitmq 队列
• 微服务监听流RabbitMQ并处理文件（这是写在Spring Cloud流中的）

现在，我无法弄清楚从 Spring Integration 流服务将消息发送到 RabbitMQ 的最佳方式是什么。如何在 Spring-Integration 中使用 spring-cloud 流将消息发布到 RabbitMQ

Answer 1

您只需要在那里实现Source 绑定并使用RabbitMQ Binder 从您的源代码生成。因此，从目录轮询文件的结果将发布到Source.OUTPUT（或您的自定义绑定），其他一切都将由 RabbitMQ Binder 完成：https://docs.spring.io/spring-cloud-stream/docs/Fishtown.M3/reference/htmlsingle/#spring-cloud-stream-overview-producing-consuming-messages

当然，您可以使用 AmqpOutboundEndpoint 将消息发布到 RabbitMQ 上的适当交换：https://docs.spring.io/spring-integration/docs/5.0.8.RELEASE/reference/html/amqp.html#amqp-outbound-channel-adapter