Golang中使用Mqtt的方法示例

更新时间：2025年02月17日 09:36:51 作者：小吴-斌

本文介绍了Golang中使用paho.mqtt.golang库实现MQTT客户端与服务器的连接、订阅和消息收发,具有一定的参考价值,感兴趣的可以了解一下

项目初始化

环境为1.23.2

在这里插入图片描述

本项目使用 paho.mqtt.golang 作为 MQTT 客户端库，安装：

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

连接Mqtt

	opts := mqtt.NewClientOptions().AddBroker("tcp://broker.emqx.io:1883")
	opts.SetClientID("mqtt_golang_NTkxOD123213")  // Client ID
	// opts.SetUsername("mqtt_toys")  // 用户名
	// opts.SetPassword("to113gz")  // 用户密码
	opts.SetDefaultPublishHandler(onMessageReceived)  // 订阅主题时的消息处理函数

	client := mqtt.NewClient(opts)
	if token := client.Connect(); token.Wait() && token.Error() != nil {
		log.Fatal(token.Error())
		os.Exit(1)
	}

	// 订阅主题
	// production/# 匹配 production/ 开头的主题 
	if token := client.Subscribe("production/#", 0, nil); token.Wait() && token.Error() != nil {
		log.Fatal(token.Error())
		os.Exit(1)
	}

订阅主题消息处理函数

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
	now := time.Now()
	fmt.Printf("时间：%s\t接收topic: %s\tMessage: %s\n", now.Format("2006-01-02 15:04:05.000"), message.Topic(), message.Payload())
	// 在这里将消息转发回业务平台，您可以根据需要修改此部分
 
}

发送主题

	// 玩具入库数据
	toysProduce := map[string]interface{}{
		"method": "produce",
		"params": map[string]interface{}{
			"sex": "1", 
			"name": "test",
			"ver": "V1.0.0",
		},
	}

	mjson, _ := json.Marshal(toysProduce) //转json 
	// 发送代码指令
	token := client.Publish("production/create", 0, false, string(mjson))
	token.Wait()

完成代码

package main

import (
	"encoding/json"
	"fmt"
	"log"
	"os"
	"os/signal"
	"syscall"
	"time"

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

func onMessageReceived(client mqtt.Client, message mqtt.Message) {
	now := time.Now()
	fmt.Printf("时间：%s\t接收topic: %s\tMessage: %s\n", now.Format("2006-01-02 15:04:05.000"), message.Topic(), message.Payload())
	// 在这里将消息转发回业务平台，您可以根据需要修改此部分 
}

func main() {
opts := mqtt.NewClientOptions().AddBroker("tcp://broker.emqx.io:1883")
	opts.SetClientID("mqtt_golang_NTkxOD123213")  // Client ID
	// opts.SetUsername("mqtt_toys")  // 用户名
	// opts.SetPassword("to113gz")  // 用户密码
	opts.SetDefaultPublishHandler(onMessageReceived)  // 订阅主题时的消息处理函数

	client := mqtt.NewClient(opts)
	if token := client.Connect(); token.Wait() && token.Error() != nil {
		log.Fatal(token.Error())
		os.Exit(1)
	}

	// 订阅主题
	// production/# 匹配 production/ 开头的主题
	if token := client.Subscribe("production/#", 0, nil); token.Wait() && token.Error() != nil {
		log.Fatal(token.Error())
		os.Exit(1)
	}

	// 玩具入库数据
	toysProduce := map[string]interface{}{
		"method": "produce",
		"params": map[string]interface{}{
			"sex": "1", 
			"name": "test",
			"ver": "V1.0.0",
		},
	}

	mjson, _ := json.Marshal(toysProduce) //转json
	fmt.Println("发送数据：", string(mjson))
	// 发送代码指令
	token := client.Publish("production/create", 0, false, string(mjson))
	token.Wait()

	// 处理系统信号，以便在接收到SIGINT或SIGTERM时优雅地关闭程序
	signalChan := make(chan os.Signal, 1)
	signal.Notify(signalChan, os.Interrupt, syscall.SIGTERM)

	<-signalChan
	fmt.Println("Received signal, shutting down...")
	client.Disconnect(250)
}

到此这篇关于Golang中使用Mqtt的方法示例的文章就介绍到这了,更多相关Golang使用Mqtt内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Golang
Mqtt

浅谈go语言中别名类型的使用
类型别名是 Go 1.9 版本添加的新功能,主要用于解决代码升级、迁移中存在的类型兼容性问题,本文主要介绍了go语言中别名类型的使用,感兴趣的可以了解一下
2024-01-01
教你一招完美解决vscode安装go插件失败问题
VSCode是我们开发go程序的常用工具,但是安装VSCode成功后,创建一个.go文件居然提示错误了,所以下面下面这篇文章主要给大家介绍了如何通过一招完美解决vscode安装go插件失败问题的相关资料,需要的朋友可以参考下
2022-07-07
安装Sublime Text支持Go插件的方法步骤
本文主要介绍了安装Sublime Text支持Go插件的方法步骤，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-01-01
Go语言Http Server框架实现一个简单的httpServer
这篇文章主要为大家介绍了Go语言Http Server框架实现一个简单的httpServer抽象,有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-04-04
Go语言基础模板设计模式示例详解
这篇文章主要为大家介绍了Go语言基础设计模式之模板模式的示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步
2021-11-11
Golang环境变量设置和查看工具go env详解
go env 是 Go 工具链中的一个命令，用于设置和查看当前 Golang 环境的相关信息，对于理解、编译和运行 Golang 程序非常有用，本文就给大家简单的介绍一下Golang环境变量设置和查看工具go env,需要的朋友可以参考下
2023-07-07
Go语言实现websocket推送程序
这篇文章主要介绍了Go语言实现websocket推送程序，WebSocket是基于TCP的一个双向传输数据的协议，和HTTP协议一样，是在应用层的，他的出现，是为了解决网页进行持久双向传输数据的问题
2023-01-01
go使用Viper管理配置文件的方法步骤
在项目开发中,需要把一些配置配置提取出来,方便配置和管理,可以使用Viper工具,Viper 是 Go 应用程序的完整配置解决方案,也支持从环境变量中读取,本文给大家介绍了go使用Viper管理配置文件的方法步骤,需要的朋友可以参考下
2024-07-07
一文带你了解Go语言中的I/O接口设计
I/O 操作在编程中扮演着至关重要的角色，它涉及程序与外部世界之间的数据交换，下面我们就来简单了解一下Go语言中的 I/O 接口设计吧
2023-06-06
深入解析golang中的标准库flag
Go语言内置的flag包实现了命令行参数的解析，flag包使得开发命令行工具更为简单，下面通过本文给大家详细介绍下golang中的标准库flag相关知识，感兴趣的朋友一起看看吧
2021-11-11