如何在 Go 中使用 Paho MQTT 客户端正确指定连接协议

Paho MQTT for Go 要求在 Broker 地址 URL 中显式声明协议方案（如 tcp://、tls:// 或 ws://），否则会因无法识别协议而报错“Unknown protocol”。

在 Go 语言中使用 Eclipse Paho 这个 MQTT 客户端库的时候，有一个特别容易被忽视，但一旦踩坑就很头疼的问题：Broker 地址到底该怎么写？

简单说，就是地址里必须带上明确的协议方案，比如 tcp://、tls:// 或者 ws://。没错，它不会主动帮你猜测你打算用什么协议，全靠 URL 最前面的那几个字母来判断连接方式。如果忘了写，结果就是直接摔一个 Unknown protocol 的错误给你看。

正确的写法其实非常直观，直接上例子：

// 普通 TCP 连接（无加密）
broker := "tcp://broker.hivemq.com:1883"

// TLS 加密连接（推荐用于生产环境）
broker := "tls://broker.hivemq.com:8883"
// 或者写成 ssl:// 或 tcps://，效果都一样

// WebSocket 连接（适用于浏览器或受限网络环境）
broker := "ws://broker.hivemq.com:8000/mqtt"

那什么样的写法会触发 panic 呢？

broker := "broker.hivemq.com:1883"     // ❌ 少了 scheme，直接报错
broker := "127.0.0.1:1883"            // ❌ 同样无效
broker := "mqtt://localhost:1883"     // ❌ mqtt:// 不受支持，别用

在代码里，你的地址最终会传给 opts.AddBroker()，像这样：

opts := paho.NewClientOptions()
opts.AddBroker(broker)           // ✅ 必须是 tcp://、tls:// 或 ws:// 开头
opts.SetClientID("my-go-client")
opts.SetUsername("user")
opts.SetPassword([]byte("pass"))

client := paho.NewClient(opts)
token := client.Connect()
if token.Error() != nil {
    log.Fatal("MQTT connect error:", token.Error())
}
defer client.Disconnect(250)

有几个细节值得留意一下：

• tls://、ssl:// 和 tcps:// 在 Paho Go 库里是同一个意思，都表示启用 TLS 1.2 或更高版本的加密连接。当然，服务端的证书得是可信的，不然你还需要通过 opts.SetTLSConfig() 来自定义配置；
• 如果用的是自签名证书或者私有 CA，测试时可能得设置 InsecureSkipVerify: true，不过这只适合开发环境。正式上线的话，一定要老老实实配好 RootCAs；
• WebSocket 这条线需要 Broker 那边也支持才行，比如 Mosquitto 就得单独开启 listener + protocol websockets；
• 最后一点，协议方案是区分大小写的，必须全是小写。写成 TCP:// 是行不通的。

说到底，Go 里 Paho MQTT 报 Unknown protocol，十有八九就是地址里漏了 scheme。记住这个核心准则：不是 host:port，而是 scheme://host:port。把这个搞清楚了，连接的第一步才算真正站稳了。