RocketMQ 如何使用MQTT 作为通信协议？

Question

@linkgo 你好，想跟你请教个问题：RocketMQ 使用netty 作为协议层的辅助处理，看官网上写的已经支持mqtt，然而并未发现对应的mqttclient 包。而使用eclipse的paho mqtt 包也无法直连rocketmq，是否需要自己在rocketmq上扩展netty组件来匹配mqtt 协议？   

Answer 1

硬件  加个netty转接吧。。。。没办法的

Answer 2

我的客户端是硬件设备，不具备协议转换能力，智能发送MQTT协议的消息。所以才希望ROCKETMQ 实现MQTT协议

Answer 3

回复
估计比较难，我看了rocketmq的源代码，协议这块如果要添加的话，需要重构的。

Answer 4

应该是在客户端进行了协议转换，rocketmq内部还是自己的协议。