我目前想要扩展walker的mqtt组件,实现mqtt5协议,也正在做这件事。 但是在兼容的不同版本时候,遇到以下问题:如何在workerman的容器下,Protocols\Mqtt类能自动区分当前encode 和 decode 的时候,知道应该使用3版本的打包encode、解包decode方法,亦或者该使用版本5的encode,decode处理方法。
Protocols\Mqtt
encode
decode
目前卡住了。 因为在decode的时候,我无法介入由容器自动调用decode的处理。
单独写一个mqtt5 协议,和原来的mqtt协议分开。
单独写一个mqtt5 协议,和原来的mqtt协议分开。