Docker中Laravel MQTT订阅进程无报错意外终止的排查与重启方案

可能的问题根源 #

1. 内存泄漏或内存限制耗尽 #

进程处理一定数量消息后终止，最可能的原因是内存泄漏：

• 消息处理回调handleSubscriberCallback()中可能存在未释放的对象、变量或循环引用，导致内存持续占用无法回收。
• PHP默认的memory_limit可能过低，当内存占用达到上限时，进程会被强制终止且无日志输出（致命错误未被捕获）。

2. MQTT客户端库的循环处理缺陷 #

当前代码中$mqtt->loop(true)是阻塞式循环，若库本身在高消息量下存在资源未正确回收的问题，会导致进程崩溃。此外，每次循环重复调用subscribe()会重复注册回调，积累不必要的资源。

3. 未捕获的致命错误/Throwable #

代码中的try-catch仅捕获Exception，但PHP中的致命错误、Error等属于Throwable范畴，这类错误不会被Exception捕获，会直接导致进程终止且无日志。

4. Docker/WSL2资源限制 #

• 检查Docker容器是否设置了内存上限，若容器内存不足，系统会直接终止进程。
• WSL2在高负载下可能存在跨系统资源调度的稳定性问题，导致进程意外退出。

进程自动重启方案 #

方案1：使用Supervisord管理进程 #

这是容器内管理常驻进程的标准方案，能自动监控并重启异常退出的进程：

1. 在Docker镜像中安装supervisord：

apt-get update && apt-get install -y supervisor

2. 创建配置文件/etc/supervisor/conf.d/mqtt-worker.conf：

[program:mqtt-worker]
command=php /var/www/html/artisan mqtt:start
user=www
autostart=true
autorestart=true
stdout_logfile=/var/www/html/storage/logs/mqtt-worker.log
stderr_logfile=/var/www/html/storage/logs/mqtt-worker-error.log

3. 修改容器启动命令为supervisord -n，让它作为PID 1进程运行。

方案2：使用bash循环脚本重启 #

若不想引入额外工具，可使用简单的bash循环实现自动重启：
替换原启动命令php artisan mqtt:start > /dev/null &为以下脚本：

#!/bin/bash
while true; do
    php artisan mqtt:start
    echo "MQTT进程意外退出，1秒后重启..."
    sleep 1
done

将此脚本设为容器的启动命令，确保脚本运行在前台。

方案3：优化代码捕获异常并减少资源消耗 #

先解决无日志问题，同时优化代码减少资源浪费：

public function handle()
{
    $this->logger->info('Start connecting to broker.');
    $subscribeTopic = '#';
    $mqtt = MQTT::connection(MqttClient::MQTT_SUBSCRIBE_CONNECTION);

    // 订阅只需执行一次，无需放入循环
    $mqtt->subscribe($subscribeTopic, $this->handleSubscriberCallback());

    while (true) {
        try {
            if (!$mqtt->isConnected()) {
                $this->logger->info('Client is disconnected. Re-connecting.');
                $mqtt->connect();
            }
            $mqtt->loop(true);
        } catch (\Throwable $exception) { // 捕获所有Throwable类型错误
            $this->logger->error('进程异常：'.$exception->getMessage(), [
                'trace' => $exception->getTraceAsString()
            ]);
            $mqtt->disconnect();
            sleep(5);
        }
    }
}

内容的提问来源于stack exchange，提问作者simpsons3