两个消息代理之间的Spring集成

Question

我不熟悉Spring集成。

我的用例是：

侦听RabbitMQ队列/主题，获取消息，处理它，将其发送给其他消息代理（通常是另一个RabbitMQ实例）。

预期负载：5000条消息/秒

正在应用中。属性我们可以为一台主机设置配置。

如何在两个消息代理之间使用Spring集成？

我看到的所有示例都是针对一个消息代理的。任何关于两个消息代理和Spring集成的入门指南。

祝好

马赫什

Answer 1

因为你提到了一个应用程序。属性听起来像是使用了Spring Boot的自动配置功能。这在您的问题中是非常重要的细节，因为Spring Boot对自动配置有意见，并且您实际上只能自动配置一个代理连接配置。如果您希望在同一应用程序中有另一个类似的，那么您应该忘记自动配置功能。您仍然可以使用上面提到的应用程序。属性，但您必须手动管理它们。

由于您谈论的是RabbitMQ连接，因此您需要排除RabbitAutoConfiguration并手动管理所有必需的bean：

@SpringBootApplication(exclude = RabbitAutoConfiguration.class)

您仍然可以在一些配置类上使用EnableConfigurationProperties（RabbitProperties.class），以便能够注入该RabbitProperties，并填充相应的CachingConnectionFactory。对于第二个代理，您可以引入自己的配置属性（ConfigurationProperties），或者只需通过读取属性来手动配置所有内容。请参阅Spring AMQP参考手册中有关手动连接工厂配置的更多信息：https://docs.spring.io/spring-amqp/docs/2.2.1.RELEASE/reference/html/#connections