php mqtt 保持 长连接

### PHP 中实现 MQTT 长连接 为了在PHP中实现MQTT长连接，可以利用`php-mqtt/client`库来创建一个持久化的连接。该库提供了灵活的方式来进行MQTT消息的发布和订阅操作。 对于保持长时间连接而言，重要的是设置合理的重连机制以及心跳包发送间隔[^2]。当建立初始连接之后，应当监听网络状态变化，在断开时尝试重新连接服务器直到成功为止。此外，还需配置客户端的心跳检测功能以维持会话活跃度。 下面是基于`php-mqtt/client`的一个简单示例代码片段用于展示如何构建具有自动重试特性的长期在线MQTT客户端： ```php <?php require __DIR__ . '/vendor/autoload.php'; use PhpMqtt\Client\MqttClient; use PhpMqtt\Client\ConnectionSettings; $host = 'mqtt.example.com'; $port = 1883; $clientId = uniqid(); // 创建新的 Mqtt 客户端实例. $mqtt = new MqttClient($host, $clientId); try { // 设置连接选项. $connectionSettings = (new ConnectionSettings) ->setUsername('your_username') ->setPassword('your_password'); // 尝试连接至 broker 并处理异常情况. while (!$mqtt->connect(true, null, 5)) { // 自动重连标志设为 true ，超时时间设为 5 秒 echo "Failed to connect, retrying...\n"; sleep(5); // 等待一段时间再进行下次尝试 } // 成功连接后的回调函数注册. $mqtt->subscribe('#', function ($topic, $message) use (&$mqtt) { printf("Received message on topic [%s]: %s\n", $topic, $message); // 如果收到特定的消息则主动断开连接作为测试用途. if ($message === 'disconnect') { $mqtt->unsubscribe('#'); $mqtt->disconnect(); } }, QOS_0); // 发送心跳包保持连接存活. $mqtt->loop(true); // 启用心跳监测，默认每60秒一次 } catch (\Exception $e) { echo 'Error: '.$e->getMessage()."\n"; } ?> ``` 上述脚本展示了怎样通过循环调用来不断尝试与Broker建立联系直至成功；一旦建立了稳定通道，则可以通过`loop()`方法周期性地向服务端发送PINGREQ报文从而防止因闲置而导致被关闭的情况发生。