RabbitMQ+Spring集成：从队列绑定到主题交换的消息转换

Question

生产者可以发送两种不同的消息类型；foo和bar（每个消息的内容无关，但假设它们都有一个id字段）。每个消息使用的路由密钥分别是msg.foo和msg.bar。生产者不依赖默认的Java序列化，而是使用Jackson2JSONMessageConverter。

使用者有一个队列，该队列使用msg.#的路由键绑定到同一个交换。一旦使用，使用者所要做的就是在日志文件中打印每个消息的ID。为了检索id字段的值，需要将JSON有效负载转换为某种对象。

这两个组件之间不共享消息类(foo和bar)。使用者的对象在其消息表示中可能有或多或少的字段。这很好，在这种情况下，任何空字段都可以设置为NULL。

@Bean
public IntegrationFlow inbound(ConnectionFactory connectionFactory, Queue queue) {
    return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, queue))
        .handle(message -> {
            final byte[] payload = (byte[]) message.getPayload();
            final String payloadStr = new String(payload, Charset.defaultCharset());

            final String routingKey = (String) message.getHeaders().get("amqp_receivedRoutingKey");

            try {
                if (routingKey.equals("msg.foo")) {
                    final Foo foo = new Jackson2JsonObjectMapper().fromJson(payloadStr, Foo.class);

                    System.out.println("FOO id: " + foo.getId());
                } else if (routingKey.equals("msg.bar")) {
                    final Bar bar = new Jackson2JsonObjectMapper().fromJson(payloadStr, Bar.class);

                    System.out.println("BAR id: " + bar.getId());
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        })
        .get();
}

不幸的是，由于重复的if/else子句，它非常古怪，也非常难看。我是否遗漏了任何使代码更易读的Spring集成技巧？

我设法找到了一个类似的问题（spring boot rabbitmq MappingJackson2MessageConverter自定义对象转换），但除了解决方案不起作用之外，它非常特定于rabbitmq。我宁愿是RabbitMQ不可知论者，并在可能的情况下使用标准AMQP类/导入。

Answer 1

您似乎忽略了Jackson2JSONMessageConverter在AMQP消息中填充适当的头这一事实。这个可以依靠这些头在消费者端恢复POJO。

因此，考虑用Jackson2JSONMessageConverter配置AMQP.InboundAdapter(connectionFactory，queue)。

有关converter的更多信息请参见文档:https://docs.spring.io/spring-amqp/docs/2.2.0.rc1/reference/html/#json-message-converter