Eclipse Paho MQTT Go客户端库使用指南

mqtt
Go
需积分: 49 0 下载量 193 浏览量 更新于2024-12-25 收藏 136KB ZIP 举报
资源摘要信息:"Eclipse Paho MQTT Go客户端是一个开源的库，它为Go语言程序提供MQTT协议的实现。MQTT（Message Queuing Telemetry Transport）是一个轻量级的消息传输协议，它通过发布/订阅模式工作，广泛应用于物联网(IoT)领域。 该库允许Go语言编写的应用程序通过MQTT协议实现与消息代理（Broker）的连接、消息的发布与订阅以及消息的接收。其特性包括支持异步操作模式，意味着应用程序可以在不阻塞主线程的情况下处理MQTT消息，这对于构建高性能的物联网应用是至关重要的。 该库支持MQTT版本3.1和3.1.1，同时也支持最新的MQTT版本5。MQTT 5提供了更多的特性和改进，例如更灵活的主题通配符和增强的认证机制。 关于安装和构建，该库提供了两种方式： 1. 使用Go模块（推荐）：通过import "github.com/eclipse/paho.mqtt.golang"来引用库，在运行go build时，依赖的包将自动下载。 2. 使用GOPATH：传统的Go项目结构，通过运行go get github.com/eclipse/paho.mqtt.golang来安装库。 使用Go模块方式时，用户可以享受到最新版本的库带来的更新和改进，但若遇到不兼容的问题或其他原因，也可以通过go get github.com/eclipse/paho.mqtt.golang@master来强制获取最新提交的代码。 标签中提供的关键词“mqtt”，“internet-of-things”，和“eclipseiot”明确指向了该库的用途和来源。"mqtt"指的是协议类型，"internet-of-things"强调了该协议在物联网应用中的重要性，而“eclipseiot”表明该库是Eclipse基金会物联网项目的一部分，Eclipse Paho是一个致力于提供开源消息传递项目，旨在为物联网设备和应用提供可靠的消息传输能力。 在文件名称列表中出现了“paho.mqtt.golang-master”，这表明文件是从项目的master分支上获取的压缩包，这通常是项目的最新开发版本。用户可以从该项目下载源代码，并且可以根据需要对源代码进行修改和扩展，以满足特定项目的需求。 总的来说，Eclipse Paho MQTT Go客户端是为Go语言开发者提供了一种简便的与MQTT代理交互的方式，支持异步消息处理，以及最新的MQTT协议版本。它非常适合用于构建需要高效消息传递能力的物联网应用，如智能家居、工业监控系统等。"

mqtt库，在亚马逊测试成功。

2019-08-05 上传
这个是MQTT的库，本人已经用这个库移植到了ESP32上，在亚马逊平台测试成功。

Go 语言开发mqtt

2018-05-21 上传
go语言实现的mqtt [

gharchive.org：GH Archive是一个项目，用于记录公共GitHub时间轴，对其进行存档，并使其易于访问以进行进一步分析

2021-02-27 上传
GH档案 全世界的开源开发人员正在从事数百万个项目的工作：编写代码和文档，修复和提交错误，等等。 GH Archive是一个项目，用于记录公共GitHub活动，对其进行存档，并使其易于访问以进行进一步分析。 有关更多详细信息，请访问 。 执照 MIT，有关此存储库中的代码和文档，请参阅 。 网站内容（gh-pages分支）也在下发布，它使您可以出于几乎任何目的使用该内容，但不会授予您任何商标许可，只要您注意以下内容即可：许可并给予信用，例如： 根据许可使用的基于内容。 请注意，此库不包含GH归档数据集（事件档案/数据）。 数据集包括可能受第三方权利约束的材料。

org.eclipse.paho.mqtt.golang:http的分叉

2021-07-10 上传
go get git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git 客户端依赖于 Google 的包，也可以使用以下命令轻松安装： go get code.google.com/p/go.net/websocket 用法和API 详细的 API 文档可以...

编译 paho.mqtt protobuf

2024-04-03 上传
你可以从 paho.mqtt 的 GitHub 仓库中找到该文件：https://github.com/eclipse/paho.mqtt.golang/blob/master/paho.mqtt.proto 3. 使用 protoc 编译器将 paho.mqtt.proto 文件编译成对应的语言代码。具体的命令行...

package main import ( "fmt" "log" "os" "time" "github.com/goburrow/modbus" "github.com/tarm/serial" MQTT "github.com/eclipse/paho.mqtt.golang" ) // 定义回调函数，处理订阅的消息 var f MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) { fmt.Printf("TOPIC: %s\n", msg.Topic()) fmt.Printf("MSG: %s\n", msg.Payload()) } func main() { // 创建新的客户端 opts := MQTT.NewClientOptions().AddBroker("tcp://localhost:1883") opts.SetClientID("golang-client") opts.SetDefaultPublishHandler(f) c := MQTT.NewClient(opts) if token := c.Connect(); token.Wait() && token.Error() != nil { panic(token.Error()) } // 订阅主题 if token := c.Subscribe("golang/topic", 0, nil); token.Wait() && token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } // 连接串口 c := &serial.Config{Name: "/dev/ttyS0", Baud: 115200} s, err := serial.OpenPort(c) if err != nil { log.Fatal(err) } // 创建 Modbus 从机实例 handler := modbus.NewRTUClientHandler(s) handler.BaudRate = 115200 handler.DataBits = 8 handler.Parity = "N" handler.StopBits = 1 handler.SlaveId = 1 handler.Timeout = 5 * time.Second defer handler.Close() client := modbus.NewClient(handler) // 读取寄存器 results, err := client.ReadHoldingRegisters(1, 2) if err != nil { log.Fatal(err) } fmt.Println(results) // 输出读取到的寄存器值 // 设置寄存器 err = client.WriteMultipleRegisters(1, 2, []byte{0x01, 0x02}) if err != nil { log.Fatal(err) } // 发布消息 for i := 0; i < 5; i++ { text := fmt.Sprintf("this is msg #%d!", i) token := c.Publish("golang/topic", 0, false, text) token.Wait() } time.Sleep(3 * time.Second) // 断开连接 if token := c.Unsubscribe("golang/topic"); token.Wait() && token.Error() != nil { fmt.Println(token.Error()) os.Exit(1) } c.Disconnect(250) }

2023-02-06 上传
它还引入了 paho.mqtt.golang 包，用于处理 MQTT 协议相关的功能。 在 main 函数中，定义了一个名为 f 的 MQTT.MessageHandler 类型的变量，这个变量是一个匿名函数，用于处理订阅的消息。 接下来，程序创建了一个...

把这段代码转化为python代码（package service import ( "encoding/json" "errors" "fmt" "gin-syudy/api/device/req" "gin-syudy/define" "gin-syudy/models" "gin-syudy/mqtt" "gin-syudy/tools/resp" "gin-syudy/utils" mq "github.com/eclipse/paho.mqtt.golang" "github.com/gin-gonic/gin" "log" "net/http" "strconv" "time" ) // DeviceController 控制设备 // @BasePath /api/v1 // @Description 启动对应设备 // @Tags 启动设备 // @param identity query string false "Identity" // @param controllerId query string false "controllerId" // @param controlState query string false "controlState" // @Success 200 {object} resp.Response "{"code":200,"data":[...]}" // @Failure 502 {object} resp.Response "{"code":502,"data":[...]}" // @Router /api/v1/device/start [Post] func DeviceController(c *gin.Context) { device := new(models.DeviceBasic) write := new(mqtt.Write) device.Identity = c.Query("identity") id, _ := strconv.Atoi(c.Query("controllerId")) fmt.Println(id) state, _ := strconv.Atoi(c.Query("controllerState")) fmt.Println(state) write.Id = uint32(id) write.State = uint32(state) if device.Identity == "" { resp.RespFail(c, http.StatusBadGateway, errors.New("必填参数为空"), resp.FoundFail) return } deviceBasic := device.GetTopicByIdentity() subTopic := "Device/" + deviceBasic.ItemName + "/" + deviceBasic.BridgeName + "/control" + deviceBasic.Secret fmt.Println(subTopic) sendTopic := "Host/" + deviceBasic.ItemName + "/" + deviceBasic.BridgeName + "/control" + deviceBasic.Secret fmt.Println(sendTopic) dataChan := make(chan *mqtt.StartDataResp, 1) mqtt.SubscribeMessage(subTopic, func(client mq.Client, message mq.Message) { fmt.Printf("MESSAGE : %s\n", message.Payload()) fmt.Printf("TOPIC : %s\n", message.Topic()) subscribeStartData := new(mqtt.StartDataResp) err := json.Unmarshal(message.Payload(), &subscribeStartData) if err != nil { resp.RespFail(c, http.StatusBadGateway, err, "回调函数格式不正确") return } dataChan <- subscribeStartData }) startData := new(mqtt.StartData) startData.SampTime = time.Now().String() startData.CommandID = utils.GetUUid() startData.Write = write data, _ := json.Marshal(startData) err := mqtt.SendMessage(sendTopic, data) if err != nil { resp.RespFail(c, http.StatusBadGateway, err, resp.FoundFail) return } responseMessage := <-dataChan err, _ = mqtt.Unsubscribe(sendTopic) if err != nil { resp.RespFail(c, http.StatusBadGateway, err, "取消订阅失败") return } resp.RespOK(c, responseMessage, "控制成功") }）

2023-06-07 上传
import paho.mqtt.client as mqtt from flask import jsonify, request from service.models import DeviceBasic from service.mqtt import SendMessage, SubscribeMessage, Unsubscribe from service.tools.resp ...

go-mqtt:Eclipse Paho Go MQTT 客户端的开发分支

2021-07-12 上传
go get git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git 客户端依赖于 Google 的包，也可以使用以下命令轻松安装： go get code.google.com/p/go.net/websocket 用法和API 详细的 API 文档可以...

Eclipse Paho Go MQTT 客户端开发与使用指南

点击了解资源详情
***/gitroot/paho/org.eclipse.paho.mqtt.golang.git ``` 此外，该客户端还依赖于Google的网络包，开发者同样可以使用以下命令来安装： ``` ***/p/***/websocket ``` 关于使用方法和API文档，开发者可以通过Go语言的...

Eclipse Paho MQTT Go客户端-Golang开发

2021-05-26 上传
Eclipse Paho MQTT Go客户端此存储库包含Eclipse Paho MQTT Go客户端库的源代码。...安装和构建此客户端旨在与标准Go工具一起使用，因此安装非常简单：go get github.com/eclipse/paho.mqtt.golang T
XanaHopper
  • 粉丝: 42
  • 资源: 4725
上传资源 快速赚钱

最新资源