PHP 7.4下RabbitMQ消费者必须手动ack且与业务成功强绑定，禁用auto_ack；需配置prefetch_count=1、合理heartbeat、进程守护及幂等设计，防止重复消费。
PHP 7.4 使用 amqp 扩展（如 php-amqplib 或原生 amqp.so）做消费者时，进程意外退出（如 PHP Fatal Error、SIGKILL、OOM kill、未捕获异常、超时被 kill）而未发送 basic_ack，会导致消息一直留在 Unacked 状态。一旦连接断开，RabbitMQ 会将这些消息重新置为 Ready 并再次投递——这就是重复消费的典型源头。
核心原则：Ack 必须与业务成功强绑定
不能“先 ack 再处理”，也不能“不管成不成功都 ack”。必须确保只有业务逻辑真正完成（比如 DB 写入成功、外部调用返回 OK、状态更新提交），才调用 ack。否则，任何中断都会让消息重回队列。
常见错误写法：
- 自动 ack（no_ack=true）：一收就丢，进程崩了消息直接消失；
- finally 里无条件 ack：哪怕业务抛出异常、数据库失败，也强行 ack；
- ack 放在 try 外部或位置错误：没等事务 commit 就 ack，事务回滚后消息已确认。
强制手动 Ack + 异常兜底机制
声明队列和消费时，必须设置 no_ack=false，并只在业务完全成功后显式调用 basic_ack：
立即学习“PHP免费学习笔记（深入）”；
- PHP 中使用
$channel->basic_consume(..., false)； - 处理完且无异常 →
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag'])； - 捕获所有可能中断的异常（包括
FatalError、ParseError、TypeError），统一进入 nack + requeue=false 流程（即不重入队，避免死循环）； - 对不可恢复错误（如消息格式非法、关键依赖不可用），调用
basic_nack($tag, $multiple=false, $requeue=false)，让消息进死信队列（DLX）。
进程生命周期防护：避免“假存活”导致 Unacked 堆积
消费者长期运行时，若进程卡住但 TCP 连接未断，RabbitMQ 无法感知其失效，Unacked 消息持续堆积，最终拖垮 Broker 性能。需主动破局：
- 启用
basic_qos(prefetch_count=1)：限制单个消费者最多持有一条未确认消息，降低堆积风险； - 设置合理的
heartbeat（如 30s），配合客户端心跳检测； - 在消费主循环中加入超时控制（如
microtime()计时 +pcntl_signal_dispatch()响应 SIGTERM）； - 使用 supervisord / systemd 管理进程，并配置
autorestart=true和startsecs，确保崩溃后快速拉起新实例（新连接会自动释放旧 Unacked）。
幂等性兜底：承认重复仍能安全处理
即使做了以上全部，网络分区、Broker 切主、客户端重连等极端情况仍可能导致同一条消息被投递多次。必须在业务层实现幂等：
- 每条消息携带唯一业务 ID（如订单号、任务 UUID），入库前先查是否存在；
- 利用数据库唯一索引 + INSERT IGNORE / ON CONFLICT DO NOTHING；
- 使用 Redis SETNX 记录已处理 msg_id（带过期时间，防止 key 残留）；
- 注意：RabbitMQ 的
x-deathheader 可读取重试次数，可用于灰度跳过第 N+1 次重试。
