spring-amqp 请求/回复消息的空响应

Question

我正在按照Stock Trading 示例的说明进行操作，该示例概述了如何在spring-amqp 中使用请求/回复消息：http://static.springsource.org/spring-amqp/docs/1.2.x/reference/html/sample-apps.html#d4e742

我已调整示例说明以创建一个客户端，该客户端应使用convertSendAndReceive 而不是convertAndSend 等待回复：https://gist.github.com/pulkitsinghal/5774487

现在，即使回复已放在 responseQueue 上，并且我已将超时 rabbitTemplate.setReplyTimeout(60000); 更新为比默认的 5 秒长……在我的客户端中，我收到了 null 作为回复。

有人知道怎么回事吗？

---

更新#1

有人建议我将<reply-listener/> 添加到<rabbit:template/>，但我不确定如何以编程方式执行此操作：

@Bean
public RabbitTemplate rabbitTemplate() {
    RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
    rabbitTemplate.setMessageConverter(jsonMessageConverter());
    rabbitTemplate.setReplyQueue(responseQueue());
    rabbitTemplate.setReplyTimeout(60000);
    // following is private
    //rabbitTemplate.addListener
    return rabbitTemplate;
}

Answer 1

我假设你在convertsendAndReceive 上没有收到错误意味着你已经为RabbitTemplate 配置了一个固定的回复队列；如果这样做，则需要一个侦听器容器来接收带有模板作为“侦听器”的消息。

最简单的配置方法是使用 xml

<rabbit:template ... reply-queue="foo">
    <reply-listener/>
</rabbit:template>

我建议你先让它在没有固定回复队列的情况下工作 - 让模板创建自己的回复队列。

您还应该删除convertSendAndReceive 中的MessagePostProcessor，因为模板会处理自己的回复队列和相关配置。当没有固定的回复队列时，这是不允许的。

当您切换到使用固定回复队列时，我建议您使用 1.2.0.M1（或快照），因为该模板使用了非标准的关联技术。

更新：要使用 @Bean 配置而不是 XML，只需创建一个 SimpleMessageListenerContainer bean 并将其侦听器设置为 RabbitTemplate。只需确保在两个地方都使用相同的队列（解析器在使用命名空间时会处理这一点）。