PHP消费端平滑重启的关键是让正在处理的消息完成或安全退回，需禁用autoAck、手动确认、信号控制退出、设置足够停止等待时间，并在回调中用try/catch兜底确保ack/nack执行。
PHP消费端平滑重启的关键，不是“立刻停掉进程”，而是让正在处理的消息有机会完成或被安全退回——否则basic_ack没发、basic_nack没调，MQ就认为消息还在“飞行中”，一杀进程，消息直接重回队列甚至重复投递。
消费者必须禁用 autoAck，且手动控制确认时机
这是所有平滑重启的前提。如果声明队列时用了 autoAck=true（默认值），RabbitMQ 一发消息就立刻标记为已投递，哪怕 PHP 进程崩溃，消息也再不会重发——这等于主动放弃可靠性。
正确做法是显式关闭自动确认，并在业务逻辑真正完成后再调用 basic_ack：
-
$channel->basic_consume('task_queue', '', false, false, false, false, $callback)中第4个参数必须为false - 回调函数里，只在数据库写入成功、API 调用返回、文件落盘完成等**最终一致性达成后**才调
$channel->basic_ack($msg->delivery_info['delivery_tag']) - 若中途出错（如 DB 连接失败、超时），应调
$channel->basic_nack(..., true, true)触发重入队列，而非静默退出
收到信号后停止拉取新消息，但继续处理已拉取的
PHP 消费者通常用 while($channel->is_consuming()) { $channel->wait(); } 循环等待。平滑重启要打断这个循环，但不能中断当前正在执行的 $callback。
立即学习“PHP免费学习笔记（深入）”；
推荐做法是监听 SIGTERM 或 SIGHUP，设标志位并跳出循环，同时保持通道活跃直到当前消息处理完：
- 注册信号处理器：
pcntl_signal(SIGTERM, function() { $GLOBALS['should_exit'] = true; }); - 主循环中加判断：
if ($GLOBALS['should_exit'] && !$channel->is_consuming()) break; - 关键：不要在信号到来时立即
exit()或die()，否则正在执行的$callback会被强行终止
重启脚本需配合 graceful shutdown 流程
光靠 PHP 代码不够，启动/重启脚本得给消费者留出处理窗口。比如用 Supervisor 管理时，不能设 stopwaitsecs=1，否则 1 秒后直接 kill -9。
建议配置：
-
stopwaitsecs=30（给足时间处理最后一批消息） -
stopsignal=TERM（确保触发 PHP 的信号处理器） - 配合健康检查：重启前 curl 一个 /health 端点，确认消费者已进入“拒绝新任务”状态
如果用 systemd，对应的是 TimeoutStopSec=30 和 KillSignal=SIGTERM。
容易被忽略的陷阱：未处理的异常会跳过 ack/nack
最隐蔽的问题是——你的业务逻辑抛了未捕获异常，导致 basic_ack 或 basic_nack 根本没执行。此时消息处于 unack 状态，但消费者进程已退出，MQ 会在 consumer_timeout（默认 30 分钟）后自动释放该消息，可能造成延迟重复。
务必在回调顶层包一层 try/catch：
$callback = function($msg) use($channel) {
try {
// 处理逻辑
$channel->basic_ack($msg->delivery_info['delivery_tag']);
} catch (Exception $e) {
error_log("处理失败: " . $e->getMessage());
$channel->basic_nack($msg->delivery_info['delivery_tag'], false, true);
}
};
没有这个兜底，所谓“平滑重启”只是幻觉。
