当连接被阻塞时，spring-amqp 无法正常工作

Question

我正在使用 spring-amqp 1.4.4，在队列包含太多消息并且超出水印内存之后，如果在发送方法之后调用 RabbitTemplate 接收方法，则它不会响应。它是无限期地等待。在 spring xml 中，我将 reply-timeout="10"设置为 rabbit:template。如果我不调用发送方法而只是调用接收它就可以正常工作。怎么了？

template.convertAndSend("test message");

String msg = (String) template.receiveAndConvert("log.queue"); // receiveAndConvert not response

Answer 1

正是出于这个原因，rabbitmq 人员建议为发布者和消费者使用单独的连接。

spring amqp CachingConnectionFactory 为所有用户共享一个连接。

我们正在考虑提供使用两个连接的选项，但与此同时，您可以配置两个连接工厂(和模板)，一个用于发送，另一个用于接收。