应使用 HAProxy 做 TCP 层负载均衡而非 PHP 手动轮询，因后者无法精准判断连接各阶段错误、不感知节点真实健康状态、复用连接导致故障转移失效；HAProxy 需配置 mode tcp、AMQP 协议级健康检查，并配合 RabbitMQ 镜像队列才能实现真正高可用。
直接用 HAProxy 做 TCP 层负载均衡，PHP 客户端只连 HAProxy 的 IP 和端口，别自己在代码里轮询节点或重试逻辑。
为什么不能在 PHP 里手动轮询 RabbitMQ 节点
很多 PHP 开发者第一反应是写个数组存三个节点 IP，array_rand 随机挑一个，连不上就换下一个。这看似简单，但实际踩坑极多：
- 连接建立失败时，
AMQPConnectionException或AMQPRuntimeException可能发生在不同阶段（DNS 解析、TCP 握手、AMQP 协议握手），错误类型不统一，很难精准判断是否该切节点 - 即使连上了，后续信道（
channel）创建、队列声明、消费启动都可能因节点临时不可用而失败，PHP 客户端没做元数据重建逻辑，直接 crash - 轮询不感知节点真实健康状态：某个节点 CPU 100% 或磁盘满，但 TCP 端口仍通，请求照样打过去，反而加剧雪崩
- PHP-FPM 进程复用连接时，
AMQPConnection对象可能被缓存，下次请求复用的还是旧连接，故障转移完全失效
HAProxy 配置要点（TCP 模式，非 HTTP）
RabbitMQ 是 AMQP 协议，必须走 mode tcp，不能用 mode http，否则协议解析失败，连接直接被 reset。
关键配置片段（/etc/haproxy/haproxy.cfg）：
立即学习“PHP免费学习笔记（深入）”；
frontend rabbitmq_frontend
bind *:5672
default_backend rabbitmq_nodes
backend rabbitmq_nodes
mode tcp
balance roundrobin
option tcp-check
tcp-check connect
tcp-check send "AMQP\x00\x00\x09\x01"
tcp-check expect string "AMQP"
server node1 192.168.1.101:5672 check inter 3000 rise 2 fall 3
server node2 192.168.1.102:5672 check inter 3000 rise 2 fall 3
server node3 192.168.1.103:5672 check inter 3000 rise 2 fall 3
-
tcp-check send发送的是 AMQP 协议握手头（AMQP\x00\x00\x09\x01），比单纯connect更可靠，能过滤出“端口通但 RabbitMQ 进程卡死”的节点 -
rise 2 fall 3表示连续 2 次检查成功才恢复上线，连续 3 次失败才摘除，避免抖动误判 - 不要加
cookie或stick规则——RabbitMQ 的连接/信道/队列不是无状态的，客户端侧无法保证会话粘性有意义
PHP 客户端代码只需改一处连接地址
原来直连节点的代码：
$connection = new AMQPConnection([
'host' => '192.168.1.101',
'port' => 5672,
'vhost' => '/',
'login' => 'guest',
'password' => 'guest'
]);
改成只连 HAProxy：
$connection = new AMQPConnection([
'host' => '192.168.1.200', // HAProxy 的 VIP 或宿主机 IP
'port' => 5672,
'vhost' => '/',
'login' => 'guest',
'password' => 'guest'
]);
- 所有重连、信道重建、队列声明逻辑保持不变——因为 HAProxy 已把故障转移透明化了
- 如果使用
php-amqplib/php-amqplib，同样只需改$connection = new AMQPStreamConnection(...)的 host 参数 - 务必关闭客户端自动重连（如
retry_limit设为 0），否则会和 HAProxy 的健康检查打架，造成连接风暴
镜像队列 + HAProxy 才算真正高可用
只配 HAProxy 不够。如果 RabbitMQ 集群没开镜像队列（Mirrored Queues），某节点宕机后，它上面声明的队列（包括消息）就彻底丢失，HAProxy 切到其他节点也消费不到——因为队列只存在于原节点。
必须在集群中执行策略命令：
rabbitmqctl set_policy ha-two "^" '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
-
^匹配所有队列；ha-mode: exactly表示每个队列固定镜像到 2 个节点；ha-sync-mode: automatic确保新消息同步完成再返回 ACK - PHP 消费端不需要感知镜像，声明队列时加
passive=false即可，集群会自动在可用节点上拉起副本 - 注意：镜像队列会降低写入吞吐，但这是换取故障时不丢消息的必要代价
最常被忽略的一点：HAProxy 只解决连接入口的故障转移，不解决队列元数据和消息本身的冗余。两者缺一不可，否则你看到的“高可用”只是假象。
