1、如何在go-zero整合MQTT协议
整合EMQX与eclipse/paho.mqtt.golang实现TLS(ssl)单向认证 订阅、发布、解压缩gzip、zlib数据报文
https://ctraplatform.blog.csdn.net/article/details/130525974
1.1 、通过钩子函数一直出现Lost问题排查
场景:
我开始在本地启动了一个clientid为:mqtt_client1
然后忘记更改服务器的clientid,直接部署,则一直会报错
上图为k8s中pod的报错
1.2 、本地代码排查
找到启动连接MQTT位置,发现狗子函数
connectLostHandler
这个函数
一直在报错,接着到该项目的yaml中配置查看(开始以为证书的问题)
发现Clientid是一样的
如上图可以看出来问题
1.3、总结
部署MQTT的程序时候,如果ClientID写在了配置的yaml中
则需要再部署时根据规则来规范
各个环境一定要注意区分这个clientid,否则直接回搞崩生产环境的连接MQTT程序