详解如何使用Webman实现物联网（IoT）设备的实时监控-php教程-PHP中文网

webman不原生支持mqtt，需通过“设备→mqtt broker→webman消费端”架构实现iot通信；其websocket服务需手动实现心跳、退避重连及redis等外部存储状态，避免多进程数据不一致与告警风暴。

详解如何使用webman实现物联网（iot）设备的实时监控

Webman 本身不是专为 IoT 设计的框架，但它的高性能、常驻内存和 WebSocket 支持，让它能稳当地承担设备监控后端角色——关键不在“能不能”，而在“怎么绕过它不原生支持 MQTT 的短板”。

为什么不能直接用 `webman` 接收设备原始数据

绝大多数 IoT 设备（尤其是嵌入式终端）默认走 MQTT 协议上报数据，而 Webman 没有内置 MQTT Broker，也不监听 1883 端口。硬改设备固件切 HTTP POST 成本高、风险大；直接让设备连 Webman 的 HTTP 或 WebSocket 接口，则面临连接维持难、QoS 无保障、离线消息不可达等问题。

所以真实路径是：设备 → MQTT Broker（如 Mosquitto / EMQX）→ Webman 消费端。Webman 不做“接入层”，只做“处理+分发层”。

设备保持标准 MQTT 连接，发布到类似 /device/{id}/status 的主题
用独立进程（如 PHP 脚本或 Python 服务）订阅该主题，收到消息后通过 WebSocket 或 HTTP 主动推给 Webman 内部逻辑
Webman 的 WebSocket 服务（如 app\process\WebSocket.php）负责把状态广播给已连接的浏览器客户端

`WebSocket` 连接管理必须自己补全心跳与重连

Webman 的 WebSocket 服务默认不带心跳检测，IoT 场景下设备端或网关网络不稳定，TCP 连接容易静默断开，导致前端长时间显示“在线”假象。

你得在 onMessage 回调里手动处理 ping/pong：

$ws->onMessage = function ($connection, $data) {
    $msg = json_decode($data, true);
    if ($msg['type'] === 'ping') {
        $connection->send(json_encode(['type' => 'pong', 'ts' => time()]));
        return;
    }
    // 其他业务逻辑
};

同时前端必须主动发 ping（例如每 25 秒一次），并监听 onclose 触发指数退避重连——Webman 不管前端连没连上，只管自己端口是否在 listen。