MQTT协议的初浅认识之推送订阅
背景
了解MQTT怎么建立连接之后,现在重点来了解MQTT怎么推送,订阅两个方面。
概念
先见一张图:
这张图是依旧借鉴HiveMQ的图,来讲述MQTT协议的推送和订阅的过程。推送和订阅,我们很容易理解。这里里面的推送客户端和订阅客户端,在上篇文章MQTT协议的初浅认识之连接建立中也都提到过,都是属于MQTT的客户端。这里面有一个比较陌生的概念是Topic,即话题这个概念。
话题
这个东西在MQTT里面很灵活,客户端订阅的对象其实也就是话题。话题主要有话题主题+正斜杠组成。如下:
话题其实就是由话题主题+正斜杆,组成的一个字符串,客户端订阅了这个话题字符串之后,就可以接收这个MQTT推送过来关于这个话题的消息。中间件也是根据话题,来分发从推送客户端推送到中间件的消息。
话题通配符
单级:+
表示不接收间隔多个话题级别,如下图:
匹配的消息结果,如下:
多级:#
表示接收多级间隔话题,如下:
匹配消息,如下:
开头:$
表示以什么开头的消息,这个不常用。
推送消息
MQTT客户端可以在连接到中间件后立即发布消息。MQTT中间件利用基于话题的消息进行过滤。每条消息必须包含一个话题,中间件可以使用该话题将消息转发给感兴趣的客户端。通常,每条消息都有包含一个的MQTT载荷与数据有关。客户端决定了有效负载的结构。发送客户端(发布者)决定是否要发送二进制数据,文本数据,甚至是完整的数据。XML或JSON。
参考说明:
- packetId:消息id
- topicName:话题标识
- qos:通讯质量级别,分为三个级别,对应着三种不同的通讯方式,这个很重要的。
- retainFlag:此标志定义中间件是否将消息保存为指定话题的最后一个默认消息值。当新客户端订阅某个话题时,他们会收到该主题上保留的最后一条消息。
- payload:载荷,业务内容就在这里。
- dupFlag:是否已经重复发送消息标识。
当客户端向MQTT中间件发送消息以进行发布时,中间件会读取该消息,确认消息(根据QoS级别)并处理该消息。中间件处理消息包括确定哪些客户已订阅该话题并将消息发送给他们。
最初发布消息的客户端只关心向中间件发送PUBLISH消息。一旦中间件收到PUBLISH消息,中间件就有责任将消息传递给所有订阅客户端。发布客户端不会获得有关是否有人对发布的消息感兴趣或有多少订阅客户端从中间件接收消息的任何反馈。
订阅消息
客户端订阅消息,相对于推送消息结构要简单的多,主要包括两个部分:
- packetId:消息id;
- qos+topic:通讯质量级别和话题数组
中间件收到客户端端的订阅SUBSCRIBE消息后,中间件会回答SUBACK消息。
SUBACK消息
参数说明:
- packetId:消息id
- returnCode:返回代码
返回代码说明:
Return Code | Return Code Response |
---|---|
0 | Success – Maximum QoS 0 |
1 | Success – Maximum QoS 1 |
2 | Success – Maximum QoS 2 |
128 | Failure |
整个订阅过程,如图:
参考
MQTT Essentials Part 5: MQTT Topics & Best Practices
MQTT Essentials Part 4: MQTT Publish, Subscribe & Unsubscribe

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
白话SpringCloud | 第四章:服务消费者(Ribbon+Feign)
前言 上两章节,介绍了下关于注册中心-Eureka的使用及高可用的配置示例,本章节开始,来介绍下服务和服务之间如何进行服务调用的,同时会讲解下几种不同方式的服务调用。 一点知识 在SpringCloud体系中,我们知道服务之间的调用是通过http协议进行调用的。而注册中心的主要目的就是维护这些服务的服务列表。我们知道,在Spring中,提供了RestTemplate。RestTemplate是Spring提供的用于访问Rest服务的客户端。而在SpringCloud中也是使用此服务进行服务调用的。 同时在微服务中,一般上服务都不会进行单点部署的,都会至少部署2台及以上的。现在我们有了注册中心进行服务列表的维护,就需要一个客户端负载均衡来进行动态服务的调用。 所以开始示例前,我们先来大致了解下关于负载均衡和RestTemplate的相关知识点。其实后面实例的Ribbon和Feign最后的调用都是基于RestTemplate的。使用比较简单~ 何为负载均衡 负载均衡(Load Balance)是分布式系统架构设计中必须考虑的因素之一,它通常是指,将请求/数据**【均匀】分摊**到多个操作单...
- 下一篇
Android开发应用程序生成以太坊钱包
Android应用程序以太坊钱包生成,要做的工作不少,不过如果我们一步一步来应该也比较清楚: 1.在app/build.gradle中集成以下依赖项: compile ('org.web3j:core-android:2.2.1') web3j核心是用于从服务器下载以太坊区块链数据的核心类库。它通常用于以太坊开发。 2.我们将设计一个Android UI示例,屏幕上将有文本编辑和按钮。在EditText中,将要求用户输入钱包的密码。然后在按钮的单击事件上,我们将开始发送密码的过程。以下是layout.xml文件: <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" android:id="@+id/content" android:layout_height="match_parent" android:layout_width="match_parent" android:orientation=...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2全家桶,快速入门学习开发网站教程
- MySQL8.0.19开启GTID主从同步CentOS8
- Docker安装Oracle12C,快速搭建Oracle学习环境
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS7安装Docker,走上虚拟化容器引擎之路
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS6,7,8上安装Nginx,支持https2.0的开启