Webman自定义TCP协议需手动注册:实现Workerman\Protocols\ProtocolInterface接口,提供input(判断完整包长,解决粘包)、decode(转PHP结构)方法,并在独立TCP Worker中显式挂载。

Webman 本身不直接提供「协议解析器」类,但底层基于 Workerman,而 Workerman 支持通过 input、decode、encode 三个方法自定义 TCP/UDP 协议解析逻辑。你得自己写一个协议类,再在 Worker 实例中指定它——不是配个 config 就完事,必须手动挂载。
如何注册自定义协议类到 Webman 的 TCP Worker
Webman 的 HTTP 服务默认不走自定义协议,你要做的是启动一个独立的 TCP Worker(通常放在 app/process 或单独的启动脚本里),然后显式传入协议类实例。
- 协议类必须实现
Workerman\Protocols\ProtocolInterface接口,至少提供input和decode方法 -
input用于判断当前接收缓冲区是否已收到完整包(解决粘包),返回包长度;若返回 0 表示数据不足,继续收;返回负数表示非法包,连接会被断开 -
decode负责把完整二进制包转成 PHP 可用结构(如数组),供onMessage使用 - 不能直接在 HTTP 路由或中间件里用这个协议——那是应用层逻辑,不是传输层解析
常见粘包判断错误:只看固定包头长度
很多新手写 input 时直接 return 16(假设包头 16 字节),结果一发多条消息就全乱。真实场景中,包头里必须含长度字段,且要能可靠提取。
Webman 2.2.0版本强化了 TCP/UDP 服务支持,优化路由组管理,并增强异步任务处理能力。结合协程与连接池技术,Webman 能轻松应对高并发场景,适用于网站、接口服务、即时通讯、物联网及游戏开发,兼具高性能、灵活扩展与稳定可靠,是多场景 PHP 服务开发的理想选择。
- 正确做法:先读包头(比如前 4 字节是 body 长度),用
unpack('N', $buffer)解出实际 payload 长度,再算总长(头长 + body 长) - 如果缓冲区长度
- 没做大小端校验或未检查 unpack 返回值是否 false,会导致
input报 Warning 后返回 null,Workerman 会静默跳过该连接 - 别在
input里做业务校验(如验签、解密)——它只管“是不是一个完整包”,校验应挪到decode或onMessage
decode 方法里容易忽略的边界情况
decode 接收的是已确认完整的二进制字符串,但它不保证内容合法。这里崩一次,整个连接就断了,而且不会抛异常给上层捕获。
- 必须用
mb_strlen($data, '8bit')替代strlen,避免中文或二进制数据被截断 - 如果协议含变长字段(如字符串长度前缀 + 内容),要严格按 offset 移动解析,别依赖正则或 strpos —— 二进制里可能含 \0
- 解包失败时,建议返回
null(Workerman 会忽略该包),而不是 throw Exception(会终止连接) - 不要在
decode里调用数据库或远程 API——它是同步阻塞的,会拖慢整个事件循环
真正难的不是写对一个包的解析,而是让 input 在各种网络抖动、分片、重传下始终返回确定性长度,同时 decode 能容忍部分字节损坏仍安全退出。这两处没压测过,上线后大概率在凌晨三点开始丢连接。

















