PHP中多个MQTT ClientBuilder同时运行受阻的解决方案咨询

你当前的代码中，$mqtt->loop(true)的true参数会让客户端进入无限阻塞循环，导致后续的$mqtt2->loop(true)永远无法执行。要让多个MQTT客户端同时运行，有两种常用的解决思路：

方法1：手动轮询非阻塞循环 #

将客户端的loop设置为非阻塞模式（传入false），然后自己写一个主循环，轮流调用两个客户端的loop方法，让它们都能处理消息。

修改后的核心代码如下：

// （前面的连接、订阅代码保持不变）

// 替换原来的两个loop(true)，改用手动轮询
while (true) {
    // 非阻塞处理第一个客户端的消息队列（单次执行，立即返回）
    $mqtt->loop(false);
    // 非阻塞处理第二个客户端的消息队列
    $mqtt2->loop(false);
    
    // 增加100ms延迟，避免CPU占用过高
    usleep(100000);
}

// 注意：实际场景中需要添加退出循环的条件，比如信号监听
// $mqtt->disconnect();
// $mqtt2->disconnect();

优缺点 #

• 优点：无需额外扩展，代码改动小，跨平台兼容
• 缺点：两个客户端的消息处理会串行执行，如果某个客户端的回调逻辑耗时较长，会轻微影响另一个客户端的响应速度

方法2：使用多进程隔离运行 #

利用PHP的PCNTL扩展（仅CLI环境支持，Windows系统不可用），为每个MQTT客户端创建独立的子进程，让它们各自运行阻塞循环，完全互不干扰。

修改后的核心代码如下：

// （前面的连接、订阅代码保持不变）

// 创建子进程运行第一个客户端
$pid1 = pcntl_fork();
if ($pid1 === -1) {
    die('无法创建子进程');
} elseif ($pid1 === 0) {
    // 子进程1：运行第一个客户端的无限阻塞循环
    $mqtt->loop(true);
    // 子进程退出前断开连接
    $mqtt->disconnect();
    exit();
}

// 创建子进程运行第二个客户端
$pid2 = pcntl_fork();
if ($pid2 === -1) {
    die('无法创建子进程');
} elseif ($pid2 === 0) {
    // 子进程2：运行第二个客户端的无限阻塞循环
    $mqtt2->loop(true);
    // 子进程退出前断开连接
    $mqtt2->disconnect();
    exit();
}

// 父进程等待所有子进程结束
pcntl_wait($status);
pcntl_wait($status);

优缺点 #

• 优点：两个客户端完全独立运行，互不影响，适合回调逻辑复杂或耗时的场景
• 缺点：需要PCNTL扩展支持，进程间通信需额外处理（如需要共享数据），Windows环境无法使用

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