我目前想要扩展walker的mqtt组件,实现mqtt5协议,也正在做这件事。 但是在兼容的不同版本时候,遇到以下问题:如何在workerman的容器下,Protocols\Mqtt类能自动区分当前encode 和 decode 的时候,知道应该使用3版本的打包encode、解包decode方法,亦或者该使用版本5的encode,decode处理方法。 目前卡住了。 因为在decode的时候,我无法介入由容器自动调用...
php 版本 框架和stomp组件版本 情况描述 对接IOT的amqp的时候,已经建立正常连接。如下: 问题: 在进行多次数据包的传送后, 云平台的数据包接收 出现 不完整的情况。导致出现:unknown cmd MESSAGE报错。 代码位置stomp包下的Client类的onConnectionMessage 方法 进一步排查TcpConnection下第557行public function bas...