RabbitMQ：为什么重新连接后通道不重新打开？

Question

在我的应用程序与RabbitMQ服务器失去连接后，我在日志中看到

ERROR ... o.s.a.r.c.CachingConnectionFactory : Channel shutdown: connection error

然后，当我的应用程序重新连接到RabbitMQ服务器时，我在日志中看到

INFO ...  Created new connection: SimpleConnection@7d9717bc [delegate=amqp://******]

但是，当应用程序重新连接到RabbitMQ服务器时，通道不会重新打开，在RabbitMQ管理控制台中，我可以在“通道”选项卡中看到没有任何通道。

重新连接后，在RabbitMQ服务器日志中：

=INFO REPORT==== 13-Jul-2017::10:33:39 ===
accepting AMQP connection (*.*.*.*:* -> *.*.*.*:5672)

=INFO REPORT==== 13-Jul-2017::10:33:39 ===
Connection (*.*.*.*:* -> *.*.*.*:5672) has 
a client-provided name: rabbitConnectionFactory#1

=INFO REPORT==== 13-Jul-2017::10:33:39 ===
connection (*.*.*.*:* -> *.*.*.*:5672 - 
rabbitConnectionFactory#1): user '***' authenticated and granted access to vhost '***'

我使用的是Spring Boot 1.5.3和Spring Boot starter amqp

看起来Spring AMQP 1.7禁用了rabbitmq客户端的“enableAutomaticRecovery”，并使用了自己的恢复机制

4.0。x客户端默认启用自动恢复；虽然与此功能兼容，但Spring AMQP有自己的恢复机制，通常不需要客户端恢复功能。建议禁用amqp客户端自动恢复，以避免在代理可用但连接尚未恢复时获取AutoRecoverConnectionNotCurrentlyOpenException。从版本1.7.1开始，Spring AMQP将禁用它，除非您显式创建自己的RabbitMQ连接工厂并将其提供给CachingConnectionFactory。默认情况下，由RabbitConnectionFactoryBean创建的RabbitMQ ConnectionFactory实例也将禁用该选项。

我不确定这是否与问题有关。

请注意，如果我关闭并重新启动应用程序，它的行为与预期一致。

Answer 1

Spring AMQP默认情况下关闭自动恢复：

private static com.rabbitmq.client.ConnectionFactory newRabbitConnectionFactory() {
    com.rabbitmq.client.ConnectionFactory connectionFactory = new com.rabbitmq.client.ConnectionFactory();
    connectionFactory.setAutomaticRecoveryEnabled(false);
    return connectionFactory; 
}

您可以通过RabbitConnectionFactoryBean打开它：

/**
 * Set to true to enable amqp-client automatic recovery. Note: Spring AMQP
 * implements its own connection recovery and this is generally not needed.
 * @param automaticRecoveryEnabled true to enable.
 * @since 1.7.1
 */
public void setAutomaticRecoveryEnabled(boolean automaticRecoveryEnabled) {
    this.connectionFactory.setAutomaticRecoveryEnabled(automaticRecoveryEnabled);
}

Spring AMQP开箱即用的自动恢复对侦听器容器有好处，但我想您需要处理rabbitemplate。因此，请考虑将其打开：http://docs.spring.io/spring-amqp/reference/html/_reference.html#auto-恢复