amqp.connect不支持自动Failover，需手动实现：用Promise.race并发尝试多个URL连接，取首个成功结果，失败后主动取消其余请求，并监听error/close事件触发重连。
Node.js 客户端直连集群多节点时，amqp.connect 不支持自动 Failover
AMQP 客户端库（如 amqplib）的 amqp.connect 默认只尝试连接第一个 URL，失败即抛错，不会自动轮询后续地址。这不是 bug，而是设计使然：AMQP 协议本身不定义客户端重试策略，这部分必须由上层应用控制。
常见错误现象是：Error: connect ECONNREFUSED 192.168.1.101:5672 后程序直接退出，完全没试 192.168.1.102 和 192.168.1.103。
- 不要把多个 URL 拼成一个字符串传给
amqp.connect（例如"amqp://...;amqp://..."），它会解析失败 - 不要依赖 DNS 轮询或系统 hosts 多条记录——TCP 层无法感知 RabbitMQ 节点健康状态
-
amqplib的urls数组参数仅在ClientsModule（NestJS）等封装层中生效，原生amqp.connect不识别该字段
手动实现 Failover：用 Promise.race + 递归重试最可靠
核心思路是并发发起多个连接尝试，取第一个成功的，其余主动取消。这比串行重试快，也避免了单点阻塞。
const amqp = require('amqplib');
const urls = [
'amqp://user:pass@node1.cluster.local:5672',
'amqp://user:pass@node2.cluster.local:5672',
'amqp://user:pass@node3.cluster.local:5672',
];
const connectWithFailover = async () => {
const promises = urls.map(url =>
amqp.connect(url).catch(err => Promise.reject({ url, err }))
);
const result = await Promise.race(promises);
if (result.err) throw result.err;
return result;
};
- 每个
amqp.connect(url)独立超时（默认 30s），可通过{ timeout: 5000 }显式控制 - 成功后记得调用
connection.on('error', ...)和connection.on('close', ...)监听断连，触发重新调用connectWithFailover - 若所有连接都失败，
Promise.race会以第一个 reject 结束，需捕获后做降级处理（如写本地日志、暂停生产）
配合镜像队列时，必须确保 ha-sync-mode=automatic
即使客户端连上了备用节点，如果该节点不是队列 Master，且镜像未同步完成，basic.publish 或 basic.consume 可能卡住或报 NOT_FOUND。这不是连接问题，而是队列状态不一致。
- 检查策略是否生效：
rabbitmqctl list_policies应显示ha-sync-mode为automatic - 避免在活跃队列上动态加节点——新节点加入时默认不同步历史消息，除非设为
automatic - Quorum 队列更推荐用于新项目，它的故障转移由 Raft 协议驱动，无需人工干预同步时机
别忽略 Erlang Cookie 和节点名格式这个硬门槛
客户端能连上某节点 ≠ 该节点能正常参与集群。如果 rabbit@node1.cluster.local 和 rabbit@node2 的 Erlang Cookie 不一致，或主机名解析失败，集群内部元数据就不同步，镜像队列根本不会创建。
- 确认所有节点的
/var/lib/rabbitmq/.erlang.cookie内容完全相同，权限为600，属主rabbitmq:rabbitmq - 节点名必须带完整域名（如
rabbit@node1.cluster.local），不能只写rabbit@node1，否则rabbitmqctl cluster_status会显示disc节点离线 - 客户端连接用的 host 名（如
node1.cluster.local）必须能被 DNS 或/etc/hosts正确解析，且与集群内节点名后缀一致
实际部署中最容易被跳过的，是验证集群内部状态是否真正一致——连得上管理界面不代表镜像队列已就绪，得看队列详情页有没有 +2 标识，以及 rabbitmqctl list_queues name slave_pids 是否返回非空。
