Java原生RabbitMQ客户端需显式启用automaticRecoveryEnabled并配置networkRecoveryInterval、heartbeat等参数，连接恢复后需手动重建Channel及重新声明Exchange/Queue。
java原生 amqp 客户端（即 rabbitmq-client）默认不开启自动重连，必须显式配置 automaticrecoveryenabled 并合理设置相关参数，否则连接断开后会抛 ioexception 或 shutdownsignalexception 且不再恢复。
如何启用 automatic recovery 功能
AMQP 客户端的自动恢复不是“开箱即用”的特性，它依赖于 ConnectionFactory 的显式开关和配套策略。仅设置 automaticRecoveryEnabled = true 不够，还需注意以下几点：
-
automaticRecoveryEnabled必须在创建ConnectionFactory实例后、调用newConnection()前设置，否则无效 - 默认重试间隔是 5 秒，可通过
setNetworkRecoveryInterval(1000)调整（单位毫秒） - 若使用 TLS，需确保
useSslProtocol(true)与自动恢复共存——二者兼容，但 SSL 握手失败会导致恢复失败，不会静默跳过 - 自动恢复只作用于 TCP 连接层断开（如网络闪断、broker 重启），不处理认证失败、vhost 权限拒绝等逻辑错误
connection 和 channel 的恢复行为差异
启用自动恢复后，Connection 会尝试重建，但所有已关闭或失效的 Channel 不会自动复用；旧 Channel 对象保持 isOpen() == false 状态，继续调用其方法会抛 IllegalStateException。
- 应用必须监听连接状态变化：通过
addConnectionListener()捕获recoverStarted和recoverCompleted事件 - 不要缓存
Channel实例长期复用；推荐每次操作前检查channel.isOpen()，不满足则调用connection.createChannel()新建 - 如果用了
ConfirmListener或ReturnListener，需在recoverCompleted后重新注册，因为恢复后的Channel是全新对象
常见失效场景与绕过方案
自动恢复机制在某些部署环境下会静默失效，典型表现是连接断开后日志不再打印重试记录，或始终卡在 “recovering…” 状态。
- 防火墙主动 kill 空闲连接时，TCP FIN 可能未被及时感知；建议设置
setRequestedHeartbeat(30)并配合操作系统级 keepalive（如net.ipv4.tcp_keepalive_time） - Docker/K8s 中容器重启导致 IP 变更，而客户端 DNS 缓存未刷新；可设置
setAutomaticRecoveryEnabled(false)+ 手动重连逻辑，或使用InetAddress.getByName(host).getCanonicalHostName()强制刷新 - Broker 启用了
connection.blocked通知（如内存水位超限），此时连接未断开但无法发消息；该状态不会触发自动恢复，需监听addBlockedListener()并降级处理
一个最小可用的带恢复配置示例
下面这段代码展示了生产环境可直接参考的基础配置模式，不含封装，直击关键字段：
立即学习“Java免费学习笔记（深入）”；
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
factory.setPort(5672);
factory.setVirtualHost("/");
factory.setUsername("guest");
factory.setPassword("guest");
factory.setAutomaticRecoveryEnabled(true); // 必须开启
factory.setNetworkRecoveryInterval(2000); // 每 2 秒重试一次
factory.setRequestedHeartbeat(30); // 心跳周期设为 30 秒
// 添加连接生命周期监听，用于重建 channel 监听器等
factory.addConnectionListener(new DefaultConnectionListener() {
@Override
public void recoverStarted(Connection conn) {
System.out.println("Recovery started");
}
@Override
public void recoverCompleted(Connection conn) {
System.out.println("Recovery completed");
// 此处应重建 channel、绑定 confirm listener、redeclare queue 等
}
});
Connection conn = factory.newConnection(); // 此时才真正启用 recovery 逻辑
注意：自动恢复不会帮你重新声明 exchange/queue/bindings，这些必须在 recoverCompleted 回调里手动执行；否则恢复后的 channel 发送消息会因路由失败而被 nack。
