likes
comments
collection
share

如何使用Go与MQTT进行通信

作者站长头像
站长
· 阅读数 16

简介

本文介绍了如何使用 Go 编程语言与 MQTT(Message Queuing Telemetry Transport)进行通信。MQTT 是一种轻量级的消息传输协议,广泛应用于物联网和实时通信场景。通过本文的指导,您将学习如何使用 Go 语言创建 MQTT 客户端,进行消息的发布和订阅。

准备工作

在开始之前,请确保您已完成以下准备工作:

  • 安装 Go 编程语言的开发环境

  • 了解 MQTT 协议的基本概念和工作原理

  • 选择一个 MQTT 服务器或代理作为消息的中转站,例如 Eclipse Mosquitto

安装 MQTT Go 库

Go 社区提供了许多优秀的 MQTT 客户端库,其中较为常用的是 github.com/eclipse/paho.mqtt.golang。您可以使用 Go 的包管理工具安装该库:

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

创建 MQTT 客户端

接下来,我们将使用 Go 创建一个 MQTT 客户端,并连接到 MQTT 服务器。下面是一个示例代码

package main

import (
	"fmt"
	"log"
	"os"
	"os/signal"
	"time"

	MQTT "github.com/eclipse/paho.mqtt.golang"
)

func main() {
	// 创建 MQTT 客户端配置
	opts := MQTT.NewClientOptions()
	opts.AddBroker("tcp://localhost:1883")
	opts.SetClientID("go-mqtt-client")

	// 创建 MQTT 客户端实例
	client := MQTT.NewClient(opts)

	// 连接到 MQTT 服务器
	if token := client.Connect(); token.Wait() && token.Error() != nil {
		log.Fatal(token.Error())
	}

	// 在连接成功后进行订阅和发布操作
	go func() {
		// 订阅主题
		if token := client.Subscribe("my/topic", 0, nil); token.Wait() && token.Error() != nil {
			log.Fatal(token.Error())
		}

		// 发布消息
		for i := 0; i < 5; i++ {
			text := fmt.Sprintf("Message %d", i)
			token := client.Publish("my/topic", 0, false, text)
			token.Wait()
			fmt.Println("Published:", text)
			time.Sleep(time.Second)
		}
	}()

	// 等待退出信号
	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt)
	<-c

	// 断开与 MQTT 服务器的连接
	client.Disconnect(250)
}

在上述示例代码中,我们创建了一个 MQTT 客户端实例,并使用 Connect() 方法连接到 MQTT 服务器。然后,我们在连接成功后进行了订阅和发布操作。您可以根据实际需求自定义主题、消息内容和 QoS 等级

作者:吕政超

转载自:https://juejin.cn/post/7233981178101350459
评论
请登录