如何用Workerman开发智能硬件的MQTT协议网关？-php教程-PHP中文网

workerman 本身不支持 mqtt 协议，必须使用 workerman/mqtt 扩展才能运行标准 mqtt 服务端；裸 worker 监听 1883 端口仅转发字节流，无法解析 mqtt 二进制帧（如 connect 中的 0x00 0x04 'm' 'q' 't' 't'），导致连上即断、connection reset by peer，且手写协议解析极易遗漏 qos 流程、遗嘱消息等关键逻辑。

如何用workerman开发智能硬件的mqtt协议网关？

Workerman 本身不支持 MQTT 协议，必须用 workerman/mqtt 扩展才能跑起标准 MQTT 服务端；直接监听 TCP 端口然后自己解析 CONNECT 包，极易出错且不兼容主流客户端。

为什么不能只用 Worker 监听 1883 端口？

因为裸 Worker 只做字节流转发，不识别 MQTT 协议帧结构。客户端发来的 CONNECT 报文（含二进制 protocol name 0x00 0x04 'M' 'Q' 'T' 'T'）会被当成乱码丢弃或触发解码异常，现象是连上即断、Connection reset by peer。

常见错误写法：

use Workerman\Worker;
$worker = new Worker('tcp://0.0.0.0:1883');
$worker->onMessage = function($connection, $data) {
    // 这里写一堆 switch($data[0]) 手动解析 —— 别这么干
};

MQTT 报文有变长头、payload offset、remaining length 编码规则，手写极易漏边界 case
QoS 1/2 的 PUBACK/PUBREC 流程、遗嘱消息、会话保持等逻辑全得自己维护
无法通过 mosquitto_sub 或 MQTTX 连接验证，调试成本极高

正确启动 MQTT 服务端的三步操作

必须用官方扩展 workerman/mqtt 提供的 MQTT\Server 类，它已封装完整协议栈。

Scale AI

Scale AI是一款AI学习资源工具，AI机器学习标注训练平台。

下载

安装：composer require workerman/mqtt
启动脚本中必须调用 $server->listen()，否则端口不真正监听
监听地址写 0.0.0.0:1883，不是 mqtt://0.0.0.0:1883（Workerman 不识别该协议前缀）
若需 TLS，得传 context 参数并监听 8883，例如：new Server('0.0.0.0', 8883, ['ssl' => $context])

最小可用示例关键行：

use Workerman\MQTT\Server;
$server = new Server('0.0.0.0', 1883);
$server->onConnect = function ($connection) { /* 设备上线逻辑 */ };
$server->onPublish = function ($connection, $topic, $payload, $qos) { /* 存库/转发/触发任务 */ };
$server->listen(); // ← 这行漏掉就等于没启动

设备上线后怎么跟 Web 后台互通？

不能用全局变量或 $_SESSION —— Workerman 多进程下内存完全隔离，重启即丢数据。

设备上线时，在 onConnect 回调里写 Redis：Redis::set('device:'.$client_id, 'online', ['EX' => 300])
Web 后台查在线设备：用 Redis::scan(0, 'device:*', 1000) 批量捞 key
下发指令：Web 后台 PUBLISH control:{$device_id}，MQTT 服务端起一个独立 Redis\PubSub 订阅者消费并调用 $connection->send()
注意：onPublish 回调内避免阻塞，重逻辑（如写 MySQL）应投递到 TaskWorker