使用java时未反映Rabbit心跳配置

Question

我们正在尝试使用以下命令设置requestedHeartbeat值

​

<rabbit:connection-factory id="connectionFactory"
        host="#{rabbitmq.hostname}" username="#{rabbitmq.username}"
        password="#{rabbitmq.password}" virtual-host="#{rabbitmq.virtualhost}"
        publisher-confirms="false" publisher-returns="false" requested-heartbeat="120" port="#{rabbitmq.port}"/>

​

我们使用以下命令创建一个consumer对象

​

AbstractApplicationContext context = new ClassPathXmlApplicationContext("classpath:/consumer_context.xml"); 
SimpleMessageListenerContainer container = context.getBean(SimpleMessageListenerContainer.class);

​

container.connectionFactory.rabbitConnectionFactory的值为120

但当我们在RabbitMQ UI中检查连接心跳时，它会显示该值为60。

有没有人能告诉我我错过了什么？

我甚至还尝试了在application.properties中使用spring.rabbitmq.requested-heartbeat。它没有起作用。

我们使用的是spring-rabbit 2.1.8 RabbitMQ 3.7.15 Erlang 22.0.4

Answer 1

RabbitMQ配置也有一个心跳的值，所以你可能也想改变它。

表示服务器在连接参数协商期间建议的心跳超时的https://www.rabbitmq.com/configure.html值。如果两端都设置为0，则禁用心跳(不建议这样做)。有关详细信息，请参阅《心跳》指南。默认值：

heartbeat = 60

https://www.rabbitmq.com/heartbeats.html#using-heartbeats-in-java请注意，如果RabbitMQ服务器配置了非零心跳超时(这是从3.6.x开始的版本中的默认设置)，客户端只能降低该值，而不能增加该值。