Spring 集成和 Spring 云流
Spring Integration and Spring Cloud Stream
我正在编写一个应用程序
- 轮询目录（Sprint 集成 DSL 流程）
- 一旦文件可用，它将放入 rabbitmq 队列
- 微服务监听流RabbitMQ并处理文件（这是Spring云流中写的）
现在，我不知道从 Spring 集成流服务向 RabbitMQ 发送消息的最佳方式是什么。如何在 Spring-Integration 中使用 spring-cloud stream 将消息发布到 RabbitMQ
您只需要在那里实施 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
我正在编写一个应用程序
- 轮询目录（Sprint 集成 DSL 流程）
- 一旦文件可用，它将放入 rabbitmq 队列
- 微服务监听流RabbitMQ并处理文件（这是Spring云流中写的）
现在，我不知道从 Spring 集成流服务向 RabbitMQ 发送消息的最佳方式是什么。如何在 Spring-Integration 中使用 spring-cloud stream 将消息发布到 RabbitMQ
您只需要在那里实施 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