基于AMQP的发布-订阅通道和消息转换

Question

我们在基于服务的应用程序中使用 作为一种事件总线。send方法和消息处理程序基于spring-messaging的message类（从Spring-Integration4.0(+)开始）。事件是对实体的更改，需要由其他服务接收。

问题是：spring-messagingMessage类被spring-amqp视为任意对象负载，因为它不被识别为spring-amqpMessage。这会导致以下问题：

• 默认消息格式是序列化的Java对象。spring-amqp不仅序列化了我们的原始有效负载对象，而且还序列化了包装spring-messagingmessage，它在Spring Framework 4.0和4.1
之间不兼容
• 为JSON配置消息转换器（准确地说是Jackson2JSONMessageConverter)并不能解决问题，因为它还会转换message实例--这是Spring-Integration的GenericMessage，而它不能从JSON实例化，因为它缺少适当的构造函数

我们需要混合使用Spring版本，因为我们有使用Grails 2.4（基于Spring 4.0）和当前Spring Boot（依赖Spring 4.1）实现的服务。

有没有办法解决这个问题，最好是一种惯用的Spring集成方法？除了PublishSubscribeamQPChannel之外，是否还有其他抽象？或者我们可以应用的任何其他消息转换方法？

Answer 1

不使用AMQP支持的通道，而是使用outbound-channel-adapter发送，使用inbound-channel-adapter接收。

通道保存整个消息（序列化），而适配器将有效负载作为消息体传输，并（可选地）将消息头映射到amqp消息头或从amqp消息头映射到amqp消息头。

您需要为pub/sub配置扇出交换（默认情况下，通道将创建一个名为si.fanout. 的扇出交换。然后您可以为每个收件人绑定一个队列。