PHP 怎么实现 RabbitMQ 消费端的优雅下线（安全停止不中断当前订单处理）？-php教程-PHP中文网

php消费端收到sigterm后丢消息，是因为未注册信号处理器、未禁用auto_ack、未限制预取数为1，导致进程被杀时未ack的消息可能重复处理或已写库未确认；必须用pcntl_signal拦截信号、设$should_exit标志、在主循环中检测并等待当前消息处理完再退出。

php 怎么实现 rabbitmq 消费端的优雅下线（安全停止不中断当前订单处理）？

消费端收到 SIGTERM 后为什么还会丢消息？

直接 kill -15 进程时，php amqp_consumer.php 如果正在执行 $channel->basic_get() 或刚拿到消息但还没调用 $channel->basic_ack()，进程就退出了——RabbitMQ 会因超时自动将消息放回队列（或进死信），但同一消息可能被重复处理；更糟的是，如果业务逻辑已写库但没 ack，重启后又来一遍，订单就重复了。

根本原因是：PHP 默认不响应信号，或响应了但没做任何清理。必须手动注册 pcntl_signal()，并配合 AMQP 的手动确认模式 + 消息重入队列控制。

怎么让 PHP 进程真正“等当前消息处理完再停”？

核心是两件事：关掉自动确认、拦截退出信号、在退出前完成当前消息的 ack/nack。不能依赖 try/finally 做兜底——信号可能发在任意位置，包括 sleep() 或数据库查询中。

启动时必须设 $channel->basic_qos(0, 1, false)，限制预取数为 1，避免一次拉多条却只处理了一半就挂
消费循环里用 $channel->basic_consume() 注册回调，而不是轮询 basic_get()
在信号处理器里设全局标记 $should_exit = true，**不立即 exit**；主循环每次迭代开头检查该标记，若为真且当前无活跃消息，则调用 exit()
回调函数内处理完业务后，必须显式调用 $msg->ack() 或 $msg->nack(['requeue' => false])，绝不能靠 autoack

示例关键片段：

$should_exit = false;
pcntl_signal(SIGTERM, function () use (&$should_exit) {
    $should_exit = true;
});
pcntl_signal(SIGINT, function () use (&$should_exit) {
    $should_exit = true;
});

$callback = function ($msg) use ($channel, &$should_exit) {
    try {
        processOrder($msg->body); // 实际业务
        $msg->ack();
    } catch (\Exception $e) {
        $msg->nack(['requeue' => false]); // 失败不重试，进死信
    }
};

while (count($channel->callbacks) > 0 && !$should_exit) {
    $channel->wait(null, false, 5.0); // 非阻塞 wait，方便检查 $should_exit
}

AMQP 扩展里哪些参数会影响下线安全性？

basic_consume() 的 $no_ack 必须为 false（默认值），否则无法手动 ack；basic_qos() 的第三个参数 $global 必须是 false（PHP AMQP 扩展要求），否则设置无效；预取值设为 1 是底线，设更大值意味着下线时最多有 N-1 条消息卡在内存里没处理，风险陡增。