首页 > 自媒体 > 谷雨课堂 > 正文

【谷雨课堂】Go实战 No.023 Go干货！轻松使用MQTT

2021-06-22 来源：华纳网责任编辑：王双双人气：

核心提示：本节我们使用Go来连接使用MQTT服务。Go不仅能连接使用MQTT服务器，Go其实也可以实现MQTT服务器的功能（如gmqtt）

知识点：

轻松使用MQTT

本课内容：

大家好，欢迎来到谷雨课堂，

本节我们使用Go来连接使用MQTT服务。

Go不仅能连接使用MQTT服务器，

Go其实也可以实现MQTT服务器的功能（如gmqtt），

MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的"轻量级"通讯协议，该协议构建于TCP/IP协议上，由IBM在1999年发布。MQTT最大优点在于，可以以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。作为一种低开销、低带宽占用的即时通讯协议，使其在物联网、小型设备、移动应用等方面有较广泛的应用。

我们使用Go进行MQTT相关的开发时，

一般的场景是在服务器环境中，

接收各设备发送过来的数据，

以后向设备发送一些控制信息，

所以，

我们常用的就是订阅一些topic,

然后根据业务规则publish一些topic供其它设备或业务系统使用

package main
import ("fmt""time"
  mqtt "github.com/eclipse/paho.mqtt.golang"  //"github.com/gin-gonic/gin")
var i int = 0var messagePubHandler mqtt.MessageHandler = func(client mqtt.Client, msg mqtt.Message) {  fmt.Printf("Received message: %s from topic: %s\n", msg.Payload(), msg.Topic())}var connectHandler mqtt.OnConnectHandler = func(client mqtt.Client) {  fmt.Println("Connected")}var connectLostHandler mqtt.ConnectionLostHandler = func(client mqtt.Client, err error) {  fmt.Printf("Connect lost: %v", err)}
func sub(client mqtt.Client) {  topic := "topic/test"  token := client.Subscribe(topic, 1, nil)  token.Wait()  fmt.Printf("Subscribed to topic %s", topic)}

func publish(client mqtt.Client) {  num := 10  for i := 0; i < num; i++ {    text := fmt.Sprintf("Message From GuYu %d", i)    token := client.Publish("topic/test", 0, false, text)    token.Wait()    time.Sleep(time.Millisecond * 100)  }}

func main() {

var broker = "<改为你的MQTT地址>"var port = 1883opts := mqtt.NewClientOptions()opts.AddBroker(fmt.Sprintf("tcp://%s:%d", broker, port))opts.SetClientID("go_mqtt_client")opts.SetUsername("username")opts.SetPassword("123456")opts.SetDefaultPublishHandler(messagePubHandler)opts.OnConnect = connectHandleropts.OnConnectionLost = connectLostHandlerclient := mqtt.NewClient(opts)if token := client.Connect(); token.Wait() && token.Error() != nil {  panic(token.Error())}
  sub(client)  publish(client)}