MQTT客户端库-Paho GO

为了加深理解,本文是翻译文章。原文地址

Paho GO Client   
语言  GO
协议EPL AND EDL
官网地址http://www.eclipse.org/paho/
API类型Asynchronous 

描述

回到2013年10月,我转到了关于其他Paho MQTT客户端库的编写,并选择了作为一种新的语言去学习GO,还有什么比写一个MQTT客户端更好的方法去学习?该项目始于两个同事,病在2014年1月提交,并且作为开源项目持续更新的现在。

Paho GO 库还包含一个可以作为独立读写MQTT的包。

PAho Go 库目前是0.9版本,即将释放1.0的稳定版本,由于被商业和开源项目采用(例如Gobot ),该项目被积极的维护。

特性

MQTT3.1 Qos 0
MQTT3.1.1 Qos 1
LWT Q0s 2
SSL/TLS Authentication
Automatic Reconnect Throttling 

使用

安装

假设你有一个Go的开发环境,你有一个很简单的方法获取Paho Go库并运行;

go get git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git

 如下会将库下载到你的$GOPATH/src 目录下,你就可以在你的项目下添加到你的Import列表下使用该库:

git.eclipse.org/gitroot/paho/org.eclipse.paho.mqtt.golang.git

连接

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("sample")c := mqtt.NewClient(opts)
if token := c.Connect(); token.Wait() && token.Error() != nil {panic(token.Error())
}

  为了连接到MQTT代理,你必须提供两个必要的参数:代理的URL和使用的客户端ID。为此,我们创建了一个新的ClientOptions结构体实例,该结构体包含代理的Url和客户端ID。在ClientOptions结构体上操作的方法们返回一个可更改的结构体指针,这使你可以将方法连在一块。

   参考了Paho Java 库,Paho Go 库允许你在完成操作时很容易的接受一个token,该token可以被用来指示操作是否完成。token.Wait()是个阻塞函数,只有在操作完成时才返回。token.WaitTimeout()会在操作完成后等待几毫秒后返回。

连接到MQTT3.1或MQTT3.1.1

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("sample")
opts.SetProtocolVersion(4)c := mqtt.NewClient(opts)
if token := c.Connect(); token.Wait() && token.Error() != nil {panic(token.Error())
}

  Paho Go 库默认使用MQTT3.1.1协议连接代理,如果失败他会自动回调并使用MQTT3.1协议连接。SetProtocolVersion()方法允许你明确的设置连接协议,4是3.1.1,3是3.1。如果显示设置,那么回调机制是禁用的。

使用LWT(临终遗嘱)连接

LWT:该协议提供了检测方式,利用KeepAlive机制在客户端异常断开时发现问题。因此当客户端电量耗尽、崩溃或者网络断开时,消息代理会采取相应措施。

客户端会向任意点的消息代理发送“临终遗嘱”(LWT)信息,当消息代理检测到客户端离线(连接并未关闭),就会发送保存在特定主题上的 LWT 信息,让其它客户端知道该节点已经意外离线。

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("sample")
opts.SetWill("my/will/topic", "Goodbye", 1, true)c := mqtt.NewClient(opts)
if token := c.Connect(); token.Wait() && token.Error() != nil {panic(token.Error())
}

  Paho Go库有两个方法设置LWT。SetWill()和SetBinaryWill(),这两个方法都有四个参数。两个方法中的第一个参数都是字符串型的LWT订阅。第二个参数是消息体(payload),在SetWill()中是一个字符创型,在SetBinaryWill()中是byte数组。第三个参数是消息的qos类型,第四个参数是LWT的是否保持连接布尔值。

使用用户名/密码连接

opts := mqtt.NewClientOptions().AddBroker("tcp://broker.hivemq.com:1883").SetClientID("sample")
opts.SetUsername("username")
opts.SetPassword("password")c := mqtt.NewClient(opts)
if token := c.Connect(); token.Wait() && token.Error() != nil {panic(token.Error())
}

发布

c.Publish("test/topic", 1, false, "Example Payload")if token := c.Publish("test/topic", 1, false, "Example Payload"); token.Wait() && token.Error() != nil {fmt.Println(token.Error())
}

  上述中,c是mqtt.NewClient()返回的mqtt.Client。发布 使用4个参数;发布消息的字符串型的topic,消息的qos质量,是否保持消息连接的bool,或者既可以是字符串形式也可以是byte数组的消息体(payload)。并且我示范了如何使用和不适用token进行消息发布。

发布保留连接信息

c.Publish("test/topic", 1, true, "Example Payload")

订阅

var msgRcvd := func(client *mqtt.Client, message mqtt.Message) {fmt.Printf("Received message on topic: %s\nMessage: %s\n", message.Topic(), message.Payload())
}if token := c.Subscribe("example/topic", 0, msgRcvd); token.Wait() && token.Error() != nil {fmt.Println(token.Error())
}

  Subscribe()使用3个参数,一个订阅的字符串形式的topic,订阅的qos质量和一个在接受到匹配订阅消息时的函数回调。回调函数必须有一个func(*mqtt.Client,mqtt.Message)的结构。当回调函数为空(nil)的时候,在库接受到消息后会调用客户端的默认消息处理程序(如果设置)。可以在结构体ClientOptions的SetDefaultPublishHandler()中设置。

取消订阅

c.Unsubscribe("example/topic")if token := c.Unsubscribe("example/topic"); token.Wait() && token.Error() != nil {fmt.Println(token.Error())
}

  Unsubscribe()可以接受多余一个的取消订阅的topic的参数,每个topic使用单独的字符串型数组参数分开。

断开连接

c.Disconnect(250)

  Disconnect()使用一个参数,该参数为线程中结束任何工作的毫秒数。

使用SSL/TLS

opts := mqtt.NewClientOptions().AddBroker("ssl://iot.eclipse.org:8883").SetClientID("sample")c := mqtt.NewClient(opts)
if token := c.Connect(); token.Wait() && token.Error() != nil {panic(token.Error())
}

  你可以非常简单的通过改变代理URL来连接到具有SSL/TLS的代理;ssl,tls或者tcps都被client支持并且安全的连接。此处假设你连接的是使用系统已知证书的代理。如果你使用自我签名的证书你需要使用 TLS。使用ClientOptions的SetTlSConfig()配置。Paho Go库的Sample文件夹中有此示例代码。

转载于:https://www.cnblogs.com/veviDP/p/8900748.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/414201.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

RabbitMQ简单介绍+Windows环境安装

文章目录 文章目录文章目录1、RabbitMQ简介2、RabbitMQ与其他MQ有什么不同3、RabbitMQ环境安装3.1 安装erlang3.2 安装rabbitmq-server4. RabbitMQ管理平台介绍1、RabbitMQ简介 RabbitMQ 是一个由 erlang 开发的 AMQP(Advanced Message Queue )的开源实…

工作285:判断绑定逻辑

/*绑定id逻辑分析*/dialog() {/*传给当前的account_id进行接收*/putAction("/account/" this.account_id "/bind_ff_account_id", {remote_account_id: this.BindData[this.form.index].id,pavg: this.BindData[this.form.index].avatar_url,plugin_key:…

对象(一)

基本特征:面向对象编程有三个基本特征:封装、继承、多态; 面向对象思想:JavaScript 语言是通过一种叫做 原型(prototype)的方式来实现面向对象编程的。对象(object)则是依靠 构造器&…

intellij idea 在Java控制台报java: 错误: 无效的源发行版:16

一共有三个地方要设置 第一个地方File->Project Structure->Project,全部修改为对应的JDK版本,例如如果是1.8,language level就选择8对应的包, 第二个地方File->Project Structure->Modules 也有个language level,一…

RabbitMQ六种队列模式-主题模式

前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题模式 [本文] 从前面的几篇我们依次经历了 exchange 模式从 fanout > direct 的转变过程,在 fanout …

工作286:v-model没有值会报错

</span></el-row><el-form-item label"刊例价"><span>&#xffe5;</span> {{ form.price }}</el-form-item><el-form-item label"任务名称"><!-- {{form.name}}--><el-input :disabled"viewList…

exe4j打包jar包生成exe文件BUG日记

参考了很多资料,生成需要的包以及设置文件目录: 不过我用的是IntelliJ IDEA 2021.3.3,所以java打包成jar的步骤以及配置有点不同; 首先设置导出配置:File->Project Strure->Artifacts MANIFEST.MF最好保存在src目录下,避免生成的jar包再打包成Exe时找不到主类: …

工作283:抽离出新页面优化

<template><!--绑定了一个 控制是否为全屏fullscreen close-on-click-modal 是否通过点击model进行关闭 visible是否显示弹出框 close关闭按钮 --><el-dialog open"open" :title"fullTitle" width"80%" :fullscreen"false&q…

RabbitMQ六种队列模式-路由模式

前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 [本文] RabbitMQ六种队列模式-主题模式 本文带大家了解 RabbitMQ 队列模式中的路由模式。 其实只要看过上篇发布模式后&#xff0c;相信路由…

CAS Client 3.2.1 配置详解

CAS Client 3.2.1 配置详解 http://www.pinhuba.com/casclient/101256.htm 摘要: CAS作为开源的单点登陆框架已经非常的流行了。由于它对已有系统的入侵性小&#xff0c;支持的语言多&#xff0c;备受广大开发者关注&#xff1b;CAS作为开源的单点登陆框架已经非常的流行了。由…

已经改成UTF-8了,git提交properties还是乱码

原因idea的File Encoding勾选了Transparent native-to-ascii conversion 如果团队中都勾选了则无所谓、如果有的勾选、有的没勾选合并代码会出现乱码。

RabbitMQ六种队列模式-发布订阅模式

前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 [本文] RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题模式 上文的工作队列模式是直接在生产者与消费者里声明好一个队列&#xff0c;这种情况下消息只会对应同类…

工作288:跨组件传值

putAction("/order/"this.$parent.$parent.ListId"/status",{status:-1,remark: this.remark}).then(res>{this.$message({message: 退回已提交,type: success});this.$emit("ok")this.dialogVisiblefalse跨组件传值

javafx HBOX按钮右对齐

<HBox spacing"20" alignment"CENTER_LEFT"> <!---关键在这里----><HBox HBox.hgrow"ALWAYS"></HBox><JFXButton prefWidth"100" fx:id"dialogCommitButton" prefHeight"40" textAlig…

景山公园

转载于:https://www.cnblogs.com/optor/p/8928938.html

RabbitMQ六种队列模式-工作队列模式

前言 RabbitMQ六种队列模式-简单队列 RabbitMQ六种队列模式-工作队列 [本文] RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题模式 上文我们了解了 RabbitMQ 六种队列模式中的简单队列&#xff0c;代码也是非常的简单&#xff0c;比较…

工作289:父子组件传值控制弹窗关闭

resetreson <template><el-dialogtitle"审核退回":visible.sync"dialogVisible"width"30%"append-to-body><el-form ref"form"><el-form-item label"退回原因" ><el-input v-model"remark…

Redhat Linux 7.3 虚拟机通过USB挂载NTFS格式的移动硬盘

分为如下几个步骤&#xff1a; 一、设置本地yum&#xff0c;安装gcc&#xff08;如果本机已经安装gcc&#xff0c;则跳过此步&#xff09; 在虚拟机连接linux iso安装盘查看光盘挂载情况mkdir /isomount /dev/cdrom /isocd /etc/yum.repos.d/vi local.repo[local] namelocal ba…

RabbitMQ六种队列模式-简单队列模式

前言 RabbitMQ六种队列模式-简单队列 [本文] RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列模式-主题模式 在官网的教程中&#xff0c;描述了如上六类工作队列模式&#xff1a; 简单队列模式&#xff1a;最简…

工作290:重置新增的mode

/*4 GY定义 找到该组件下面的add方法*/add() {/* 5GY定义 给当前属性下面的title赋值*/this.title "新增";/*重置新增的mode*/this.mode[]this.show();this.IsShowtrue;this.attrthis.viewMode false;this.approveMode false/* 7GY定义 给当前的form赋值 并进行对…