Workerman如何实现物联网（IoT）设备硬件TCP双向通信？-php教程-PHP中文网

workerman 适合作为 iot tcp 双向通信底座，但需手动处理连接生命周期、协议解析（如粘包）、设备身份绑定及跨服务转发；建议在 onconnect 中握手并绑定设备 id，设置心跳，缓存并按协议头切分数据，通过映射表实现 websocket 精准控制硬件。

workerman如何实现物联网（iot）设备硬件tcp双向通信？

Workerman 本身不封装硬件通信逻辑，但它是极适合做 IoT TCP 双向通信底座的 PHP 框架——关键在于你得自己处理连接生命周期、协议解析和跨服务转发，不能指望开箱即用。

为什么不能直接用 `Worker` 类监听硬件端口就完事？

硬件设备（如温湿度传感器、PLC）通常以固定格式发包（比如 Modbus TCP 帧、自定义二进制头+JSON 负载），Worker 的 onMessage 回调只收到原始字节流，不做解析就无法识别指令或状态
onMessage 触发时，$connection 是单次 TCP 连接对象，但硬件可能长连不发心跳，容易被误判为“空闲断开”
默认没有连接池、无设备身份绑定机制，多个设备连上来后，WebSocket 端或 HTTP API 想定向推送给某台设备，根本找不到对应 $connection

常见错误现象：

设备连上后发几条数据就断，日志里没报错 → 实际是 $connection->close() 被隐式触发（比如未设置 $connection->protocol 或未处理粘包）
同一 IP 多个设备复用连接，后连的把前连的踢掉 → Worker 默认按 IP+port 去重，需手动用设备 ID 替换 key

建议做法：

在 onConnect 中立刻发送握手响应，并要求设备回传唯一标识（如 MAC、SN）
把设备 ID 作为键存入全局数组：$websocket->deviceConnections[$deviceId] = $connection
设置 $connection->heartbeatIdle = 60 和 $connection->heartbeatData = 'ping' 防止被中间设备断连

`onMessage` 里怎么安全解析硬件 TCP 数据？

硬件协议几乎都存在粘包、半包问题，不能直接 json_decode($data)。必须先按协议头长度字段切分。

以常见「4 字节长度 + JSON 内容」格式为例：

先缓存未完整帧：$connection->tmpBuffer .= $data
循环检查是否有完整包：若 strlen($connection->tmpBuffer) >= 4，读前 4 字节得 $len = unpack('N', $connection->tmpBuffer)[1]
若 strlen($connection->tmpBuffer) >= 4 + $len，则截取 substr($connection->tmpBuffer, 4, $len) 解析，再更新 $connection->tmpBuffer

要点：

不要用 explode 或 strpos 找分隔符，硬件不会给你发 \n\r
解析失败时别 close()，记录日志并丢弃当前缓冲区，否则设备重连风暴
如果协议含 CRC 校验，必须在切包后立即验证，不通过直接跳过

如何让 WebSocket 页面实时控制某台硬件设备？

不能靠「广播给所有 TCP 连接」，得精准路由。最简方案是：在 WebSocket 服务端维护一个映射表，设备上线时注册，下线时注销。

示例结构：

Mark Copy

Mark Copy是一款AI文本写作工具，SEO 写作与营销文案工具。

下载

$websocket->deviceMap = [
    'SN-88A2F1' => ['conn' => $tcpConn, 'ip' => '192.168.2.105'],
    'SN-B3C9E7' => ['conn' => $tcpConn, 'ip' => '192.168.2.106']
];

当 WebSocket 收到控制指令（如 {"cmd": "relay_on", "device": "SN-88A2F1"}）：