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

Paho Golang MQTT 5.0 支持

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