MQTT Go 客户端库

Eclipse Paho MQTT Go ClientMQTT Go 客户端库 - 图1 (opens new window) 为 Eclipse Paho 项目下的 Go 语言版客户端库，该库能够连接到 MQTT Broker 以发布消息，订阅主题并接收已发布的消息，支持完全异步的操作模式。

客户端依赖于 Google 的 proxyMQTT Go 客户端库 - 图2 (opens new window) 和 websocketsMQTT Go 客户端库 - 图3 (opens new window) 软件包，通过以下命令完成安装：

  1. go get github.com/eclipse/paho.mqtt.golang

MQTT Go 使用示例

本示例包含 Go 语言的 Paho MQTT 连接 EMQ X Broker，并进行消息收发完整代码：

  1. package main
  3. import (
  4.     "fmt"
  5.     "log"
  6.     "os"
  7.     "time"
  9.     "github.com/eclipse/paho.mqtt.golang"
  10. )
  12. var f mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {
  13.     fmt.Printf("TOPIC: %s\n", msg.Topic())
  14.     fmt.Printf("MSG: %s\n", msg.Payload())
  15. }
  17. func main() {
  18.     mqtt.DEBUG = log.New(os.Stdout, "", 0)
  19.     mqtt.ERROR = log.New(os.Stdout, "", 0)
  20.     opts := mqtt.NewClientOptions().AddBroker("tcp://broker.emqx.io:1883").SetClientID("emqx_test_client")
  22.     opts.SetKeepAlive(60 * time.Second)
  23.     // 设置消息回调处理函数
  24.     opts.SetDefaultPublishHandler(f)
  25.     opts.SetPingTimeout(1 * time.Second)
  27.     c := mqtt.NewClient(opts)
  28.     if token := c.Connect(); token.Wait() && token.Error() != nil {
  29.         panic(token.Error())
  30.     }
  32.     // 订阅主题
  33.     if token := c.Subscribe("testtopic/#", 0, nil); token.Wait() && token.Error() != nil {
  34.         fmt.Println(token.Error())
  35.         os.Exit(1)
  36.     }
  38.     // 发布消息
  39.     token := c.Publish("testtopic/1", 0, false, "Hello World")
  40.     token.Wait()
  42.     time.Sleep(6 * time.Second)
  44.     // 取消订阅
  45.     if token := c.Unsubscribe("testtopic/#"); token.Wait() && token.Error() != nil {
  46.         fmt.Println(token.Error())
  47.         os.Exit(1)
  48.     }
  50.   // 断开连接
  51.     c.Disconnect(250)
  52.     time.Sleep(1 * time.Second)
  53. }

Paho Golang MQTT 5.0 支持

目前 Paho Golang 还在适配 MQTT 5.0，尚未全面支持。