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程序

2、在K8S中开启多pod消费者问题

2.1、MQTT消费者程序 在k8s开多个pod造成多个消费者问题

您好，如果您在Kubernetes中部署了多个Pod来运行MQTT消费者程序，可能会出现多个消费者同时接收相同消息的问题。为了避免这个问题，您可以考虑使用MQTT的QoS（服务质量）功能。

MQTT的QoS功能可以确保消息的可靠传输，并且可以控制消息的传输速率。在MQTT中，有三个不同的QoS等级：

• QoS 0：最多一次传递。消息不会被确认，也不会重传。
• QoS 1：至少一次传递。消息会被确认，但可能会重传。
• QoS 2：恰好一次传递。消息会被确认，并且只会传递一次。
  

2.2、推荐解决方案

从同时被消费

到分别被消费

为了解决多pod同时作为消费了一起消费消息
推荐使用消息队列接入MQTT的broker（如果MQTT有这个能力）如果没有需要另外开发