spring rabbitmq自动重试到代理的连接

Question

我读过这段文档：

RabbitMQ自动连接/拓扑恢复

自Spring AMQP的第一个版本以来，该框架在代理失败的情况下提供了自己的连接和通道恢复。此外，如第3.1.10节“配置代理”所述，RabbitAdmin将在重新建立连接时重新声明任何基础结构bean（队列等）。因此，它不依赖amqp客户端库现在提供的自动恢复。Spring AMQP现在使用4.0。amqp客户端的x版本，默认情况下已启用自动恢复。如果愿意，Spring AMQP仍然可以使用自己的恢复机制，在客户端中禁用它（通过将底层RabbitMQ connectionFactory上的automaticRecoveryEnabled属性设置为false）。但是，该框架与启用的自动恢复完全兼容。这意味着您在代码中创建的任何使用者（可能通过rabbitemplate.execute（））都可以自动恢复。

我不确定我是否正确理解了。在我的应用程序中。属性我已经定义了端口和主机。在启动我的spring boot应用程序期间，它成功地建立了连接和所有必要的bean，以便与队列通信。

然而，如果在启动期间，我的应用程序代理关闭，并且将在应用程序启动五分钟后启动，该怎么办？spring rabbitmq是否能够重新连接并定义所有bean？

Answer 1

是的，代理重新上线时将重新创建连接。默认恢复间隔为5秒。您可以通过设置container.setRecoveryInterval（30000）；来更改恢复间隔，其中容器是SimpleMessageListenerContainer。在底层连接工厂cachingConnectionFactory.getRabbitConnectionFactory（）. setNetworkRecoveryInterval（int）中设置恢复间隔似乎没有反映。

Answer 2

我遇到过类似的问题，您只需要在连接工厂配置中添加一个属性。

根据此处的文章设置<代码>工厂。setAutomaticRecoveryEnabled（真） 和<代码>工厂。setNetworkRecoveryInterval（10000）

因为您正在为连接工厂使用spring配置，所以您的连接工厂将如下所示

<bean id="connectionFactory"
      class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
    <constructor-arg value="somehost"/>
    <property name="username" value="guest"/>
    <property name="password" value="guest"/>
    <property name="automaticRecoveryEnabled" value="true"/>
    <property name="networkRecoveryInterval" value="100000"/>
</bean>

连接工厂参考这里

Answer 3

没错。Spring AMQP自动管理重新连接和恢复。

此主题与bean定义无关。如果您谈论的是代理实体声明，那么是的，它们实际上是在建立连接时处理的。