Golang如何做MQTT客户端_Golang MQTT教程【总结】-Golang-PHP中文网

用 github.com/eclipse/paho.mqtt.golang 是当前最稳的选择，但连不上、收不到、发不出——90% 不是库的问题，而是 connect() 后没等就发、订阅传了 nil handler、qos 和 cleansession 配错这三件事。

golang如何做mqtt客户端_golang mqtt教程【总结】

用 github.com/eclipse/paho.mqtt.golang 是当前最稳的选择，但连不上、收不到、发不出——90% 不是库的问题，而是 connect() 后没等就发、订阅传了 nil handler、QoS 和 CleanSession 配错这三件事。

MQTT 连接是异步的，client.Connect() 返回的是个 Token，不是连接成功的信号。跳过等待直接 Subscribe() 或 Publish()，轻则 panic：client is not connected，重则消息彻底丢进黑洞，连错误都不报。

必须显式调 token.Wait() 或更安全的 token.WaitTimeout(5 * time.Second)，超时时间别设太短（比如 100ms），网络抖动下容易误判
检查不能只看 token.Error() != nil，还要确认 token.Wait() 返回 true；返回 false 表示超时未完成，此时连接实际还没建立
别在 main() 末尾用 defer client.Disconnect() —— Go 程序退出太快，Disconnect() 可能根本没发出去就被 OS 杀掉

client.Subscribe("sensors/+", 1, nil) 看似能跑通，但所有匹配到的消息都会被 SDK 直接丢弃，不报错、不警告、也不回调——这是最隐蔽的“收不到”原因。

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

必须传非 nil 的 MessageHandler 函数，哪怕只是 func(client mqtt.Client, msg mqtt.Message) { fmt.Println(msg.Topic(), string(msg.Payload())) }
handler 内别做耗时操作（如 HTTP 调用、DB 写入），否则会卡住整个 MQTT 事件循环；应把 msg 推进 chan，由独立 goroutine 处理
循环订阅多个 topic 时，闭包里直接用 topic 变量会导致所有 handler 都捕获到最后一个值；要写成 topic := topic 做局部副本

QoS=0 不保证送达，但“发了却完全没影”常是 broker 端行为和客户端配置共同作用的结果：

SetCleanSession(true)（默认）下，如果发布者先发、订阅者后连，broker 不保留历史消息，QoS=0 的消息就真的没了
某些 broker（如 Mosquitto 2.0+）对 QoS=0 的通配符订阅（如 sensors/+/temp）会静默忽略或不投递，换成 QoS=1 就立刻正常
测试阶段建议先用公共 broker（如 tcp://broker.hivemq.com:1883）验证逻辑；本地跑 EMQX 时注意容器内 localhost 指向自己，得换宿主机 IP 或 host.docker.internal
主题名别乱起，设备状态用 devices/{id}/status，指令用 devices/{id}/cmd；泛化主题（如 all/cmd）后期没法做 ACL 隔离

这个错误不是连不上，是 TLS 握手成功后证书校验失败。常见于自签名证书或内网 EMQX：

opts.SetTLSConfig(tlsConfig) 前，务必设 tlsConfig.InsecureSkipVerify = true（仅开发阶段），否则默认严格校验，自签名证书必挂
生产环境必须关掉 InsecureSkipVerify，改用 x509.NewCertPool() 加载 CA 证书，并确保路径正确、文件可读
URL 前缀写 ssl:// 或 mqtts:// 没用，paho 不解析协议头，只认 SetTLSConfig() 是否设置；明文地址（tcp://）配了 TLSConfig 才走加密
证书链不全（缺中间 CA）、私钥格式不对（非 PEM）、时间戳过期，都会触发同类错误，但日志里只显示那句 x509 错误，得自己排查