MQTT 介绍与学习 —— 筑梦之路

之前写过的相关文章：

MQTT协议（转载）——筑梦之路_mqtt url-CSDN博客

k8s 部署mqtt —— 筑梦之路-CSDN博客

CentOS 7 搭建mqtt服务——筑梦之路_腾讯云宝塔搭 centos 7.9.2009 x86_64 建标准mqtt服务器-CSDN博客

mqtt简介

MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议），是一种基于发布/订阅（publish/subscribe）模式的"轻量级"通讯协议。 

客户端服务端
一个使用MQTT协议的应用程序或者设备，它总是建立到服务器的网络连接。客户端可以：也称为"消息代理"（Broker），可以是一个应用程序或一台设备。它是位于消息发布者和订阅者之间，它可以：
- （1）发布其他客户端可能会订阅的信息；- （1）接受来自客户的网络连接；
- （2）订阅其它客户端发布的消息；- （2）接受客户发布的应用信息；
- （3）退订或删除应用程序的消息；- （3）处理来自客户端的订阅和退订请求；
- （4）断开与服务器连接。- （4）向订阅的客户转发应用程序消息。

设计原则：

①精简，不添加可有可无的功能；

②发布/订阅（Pub/Sub）模式，方便消息在传感器之间传递，解耦Client/Server模式，带来的好处在于不必预先知道对方的存在（ip/port），不必同时运行；

③允许用户动态创建主题（不需要预先创建主题），零运维成本；

④把传输量降到最低以提高传输效率；

⑤把低带宽、高延迟、不稳定的网络等因素考虑在内；

⑥支持连续的会话保持和控制（心跳）；

⑦理解客户端计算能力可能很低；

⑧提供服务质量（ quality of service level：QoS）管理

⑨不强求传输数据的类型与格式，保持灵活性（指的是应用层业务数据）。

MQTT应用领域：

①物联网M2M通信，物联网大数据采集

②Android消息推送，WEB消息推送

③移动即时消息，例如Facebook Messenger

②智能硬件、智能家居、智能电器

⑤车联网通信，电动车站桩采集

⑥智慧城市、远程医疗、远程教育

⑦电力、石油与能源等行业市场

 MQTT协议相关概念

MQTT协议中的方法

- （1）CONNECT：客户端连接到服务器- （9）SUBACK：订阅确认
- （2）CONNACK：连接确认- （10）UNSUBSCRIBE：取消订阅
- （3）PUBLISH：发布消息- （11）UNSUBACK：取消订阅确认
- （4）PUBACK：发布确认- （12）PINGREQ：客户端发送心跳
- （5）PUBREC：发布的消息已接收- （13）PINGRESP：服务端心跳响应
- （6）PUBREL：发布的消息已释放- （14）DISCONNECT：断开连接
- （7）PUBCOMP：发布完成- （15）AUTH：认证
- （8）SUBSCRIBE：订阅请求

消息服务质量QOS

 MQTT 协议中规定了消息服务质量（Quality of Service），它保证了在不同的网络环境下消息传递的可靠性，QoS 的设计是 MQTT 协议里的重点。

MQTT 设计了 3 个 QoS 等级。

- QoS 0：消息最多传递一次。

- QoS 1：消息传递至少 1 次。

- QoS 2：消息仅传送一次。

QoS0："至多一次"，消息发布完全依赖底层TCP/IP网络。会发生消息丢失。一个消息不会被接收端应答，也不会被发送者存储并再发送。这个也被叫做“即发即弃” 

QoS1："至少一次"，确保消息到达，但消息重复可能会发生。发送者将会存储发送的信息直到发送者收到一次来自接收者的PUBACK格式的应答。

QoS2："只有一次"，确保消息到达一次。如果接收端接收到了一个QoS为2的PUBLISH消息，它将相应地处理PUBLISH消息，并通过PUBREC消息向发送方确认。

PUBLISH:发布消息 PUBREC:发布收到 PUBREL:发布释放 PUBCOMP:发布完成

 发送订阅不同QOS情况下是如何生效的

topic通配符匹配规则 

 

物联网级消息中间件EMQ 

EMQ X Broker 是基于高并发的 Erlang/OTP 语言平台开发，支持百万级连接和分布式集群架构，发布订阅模式的开源 MQTT 消息服务器。

EMQ官网：https://www.emqx.cn/

为什么选择EMQ X ?从支持 MQTT5.0、稳定性、扩展性、集群能力等方面考虑，EMQX 的表现应该是最好的。

EMQX的特点

  • EMQ X 目前为开源社区中最流行的 MQTT 消息中间件；

  • EMQ X 是开源社区中第一个支持 5.0协议规范的消息服务器，并且完全兼容 MQTT V3.1 和 V3.1.1 协议。

  • 除了 MQTT 协议之外，EMQ X 还支持MQTT-SN、CoAP、 LwM2M、LoRaWAN 和 WebSocket 等物联网协议

  • 单机支持百万连接，集群支持千万级连接；毫秒级消息转发。

  • 易于安装和使用；

  • 中国本地的技术支持服务；

  • 扩展模块和插件，EMQ X 提供了灵活的扩展机制，支持企业的一些定制场景；

  • 桥接

  • 共享订阅

docker运行

docker run -tid --name emqx -p 1883:1883 -p 8083:8083 -p 8081:8081 -p 8883:8883 -p 8084:8084 -p 18083:18083  emqx/emqx:v4.1.0

 EMQDashboard

EMQ X 提供了 Dashboard 以方便用户管理设备与监控相关指标。通过 Dashboard可以查看服务器基本信息、负载情况和统计数据，可以查看某个客户端的连接状态等信息甚至断开其连接，也可以动态加载和卸载指定插件。

访问地址 http://192.168.100.100:18083 来查看Dashboard，**默认用户名是 admin，密码是 public*

客户端调试工具MQTTX

 MQTT X 是 EMQ 开源的一款优雅的跨平台 MQTT 5.0 桌面客户端，它支持 macOS, Linux, Windows。

MQTT X 的 UI 采用了聊天界面形式，简化了页面操作逻辑，用户可以快速创建连接，允许保存多个客户端，方便用户快速测试 MQTT/MQTTS 连接，及 MQTT 消息的订阅和发布。

延迟消息

 EMQ X 的延迟发布功能可以实现按照用户配置的时间间隔延迟发布 PUBLISH 报文的功能。模块开启emqx_mod_delayed

延迟发布主题的具体格式如下：

$delayed/{DelayInterval}/{TopicName}

-delayed：使用delayed 作为主题前缀的消息都将被视为需要延迟发布的消息。

- {DelayInterval}: 指定该 MQTT 消息延迟发布的时间间隔，单位是秒，允许的最大间隔是 4294967 秒。

- {TopicName}: MQTT 消息的主题名称。

1.在Websocket上订阅主题：t2/a

2.在Websocket上发布消息主题：topic:  $delayed/10/t2/a

共享订阅

 不带群组的共享订阅

格式：

$queue/{TopicName}

带群组的共享订阅

格式：

$share/<group-name>/{TopicName}

开源分布式LOT平台：

 https://gitee.com/pnoker/iot-dc3

文档地址：  https://doc.dc3.site/

 

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

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

相关文章

轻量封装WebGPU渲染系统示例＜50＞- Json数据描述材质等场景信息

轻量封装WebGPU渲染系统示例＜50＞- Json数据描述材质等场景信息

当前示例源码github地址: https://github.com/vilyLei/voxwebgpu/blob/feature/material/src/voxgpu/sample/DataDrivenScene2.ts 当前示例运行效果: 此示例基于此渲染系统实现&#xff0c;当前示例TypeScript源码如下: json场景数据: {"renderer": {"mtplE…
阅读更多...
Java网络编程，使用UDP实现TCP(三), 基本实现四次挥手

Java网络编程，使用UDP实现TCP(三), 基本实现四次挥手

简介 四次挥手示意图 在四次挥手过程中&#xff0c;第一次挥手中的Seq为本次挥手的ISN&#xff0c; ACK为 上一次挥手的 Seq1&#xff0c;即最后一次数据传输的Seq1。挥手信息由客户端首先发起。 实现步骤&#xff1a; 下面是TCP四次挥手的步骤&#xff1a; 第一次挥手&…
阅读更多...
LV.13 D4 uboot使用 学习笔记

LV.13 D4 uboot使用 学习笔记

一、uboot环境变量命令 1.1 uboot模式 自启动模式 uboot 启动后若没有用户介入&#xff0c;倒计时结束后会自动执行自启动环境变量 (bootcmd) 中设置的命令&#xff08;一般作加载和启动内核&#xff09; 交互模式 倒计时结束之前按下任意按键 uboot 会进…
阅读更多...
异地现场工控设备，如何实现远程配置、调试？

异地现场工控设备，如何实现远程配置、调试？

南京某企业专注于工业物联领域&#xff0c;在相关项目中往往会在各个点位部署基于Linux系统的中控主机&#xff0c;实现各类物联设备信息的采集、汇总。但是&#xff0c;由于各点位分散多地&#xff0c;且数量达到了上百个&#xff0c;虽然中控主机具备4G物联网接入能力&#x…
阅读更多...
【Vue】elementUI表格，导出Excel

【Vue】elementUI表格，导出Excel

系列文章 【Vue】vue增加导航标签 本文链接&#xff1a;https://blog.csdn.net/youcheng_ge/article/details/134965353 【Vue】Element开发笔记 本文链接&#xff1a;https://blog.csdn.net/youcheng_ge/article/details/133947977 【Vue】vue&#xff0c;在Windows IIS平台…
阅读更多...
设计模式——策略模式（Strategy Pattern）

设计模式——策略模式（Strategy Pattern）

概述 策略模式又叫政策模式&#xff0c;是一种对象行为型模式。它是将定义的算法家族分别封装起来&#xff0c;让它们之间可以互相替换&#xff0c;从而让算法的变化不会影响到使用算法的用户。策略模式的主要目的是将算法的定义与使用分开&#xff0c;也就是将算法的行为和环…
阅读更多...
小程序使用Nodejs作为服务端，Nodejs与与MYSQL数据库相连

小程序使用Nodejs作为服务端，Nodejs与与MYSQL数据库相连

小程序使用Nodejs作为服务端，Nodejs与MYSQL数据库相连 一、搭建环境二、配置Nodejs三、与小程序交互四、跨域处理/报错处理五、nodejs连接mysql数据库六、微信小程序连接nodejs报错七、小程序成功与服务端相连，且能操作数据库一、搭建环境 新建空文件夹：Win + R进入cmd命令界…
阅读更多...
Unity 控制刚体的移动与旋转的方法

Unity 控制刚体的移动与旋转的方法

在场景创建一个Cube,并添加刚体&#xff0c;如图&#xff1a; 编写脚本&#xff1a; using System.Collections; using System.Collections.Generic; using UnityEngine;[RequireComponent(typeof(Rigidbody))] public class RibRotate : MonoBehaviour {//private Vector3 mo…
阅读更多...
C语言----文件操作(二)

C语言----文件操作(二)

在上一篇文章中我们简单介绍了在C语言中文件是什么以及文件的打开和关闭操作&#xff0c;在实际工作中&#xff0c;我们不仅仅是要打开和关闭文件&#xff0c;二是需要对文件进行增删改写。本文将详细介绍如果对文件进行安全读写。 一&#xff0c;以字符形式读写文件&#xff…
阅读更多...
中通单号查询，中通快递物流查询，对需要的单号进行备注

中通单号查询，中通快递物流查询，对需要的单号进行备注

批量查询中通快递单号的物流信息&#xff0c;对需要的单号进行备注。 所需工具&#xff1a; 一个【快递批量查询高手】软件 中通快递单号若干 操作步骤&#xff1a; 步骤1&#xff1a;运行【快递批量查询高手】软件&#xff0c;并登录 步骤2&#xff1a;点击主界面左上角的“…
阅读更多...
iOS使用CoreText完成txt阅读器

iOS使用CoreText完成txt阅读器

CoreText是一个高效处理字符和字形转换和进行文字排版的框架&#xff0c;API基于C语言。 常见的CoreText类介绍 &#xff08;1&#xff09;、CFAttributedStringRef 属性字符串&#xff0c;用于存储需要绘制的文字字符和字符属性 &#xff08;2&#xff09;、CTFramesetterR…
阅读更多...
JVM学习之JVM概述

JVM学习之JVM概述

JVM的整体结构 Hotspot VM是目前市面上高性能虚拟机代表作之一 它采用解释器与即时编译器并存的架构 在今天&#xff0c;Java程序的运行性能已经达到了可以和C/C程序一较高下的地步 Java代码执行流程 具体图为 JVM架构模型 Java编译器输入的指令流基本上是一种基于 栈的指令…
阅读更多...
大创项目推荐 垃圾邮件(短信)分类算法实现 机器学习 深度学习

大创项目推荐 垃圾邮件(短信)分类算法实现 机器学习 深度学习

文章目录 0 前言2 垃圾短信/邮件 分类算法 原理2.1 常用的分类器 - 贝叶斯分类器 3 数据集介绍4 数据预处理5 特征提取6 训练分类器7 综合测试结果8 其他模型方法9 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 垃圾邮件(短信)分类算…
阅读更多...
Github与Gitlab

Github与Gitlab

学习目标 能够使用GitHub创建远程仓库并使用能够安装部署GitLab服务器能够使用GitLab创建仓库并使用掌握CI/CD的概念掌握蓝绿部署, 滚动更新,灰度发布的概念 GitHub是目前最火的开源项目代码托管平台。它是基于web的Git仓库&#xff0c;提供公有仓库和私有仓库&#xff0c;但私…
阅读更多...
Amortized Bootstrapping of LWE：使用 BFV 打包处理

Amortized Bootstrapping of LWE：使用 BFV 打包处理

参考文献&#xff1a; [AP13] Alperin-Sheriff J, Peikert C. Practical bootstrapping in quasilinear time[C]//Annual Cryptology Conference. Berlin, Heidelberg: Springer Berlin Heidelberg, 2013: 1-20.[MS18] Micciancio D, Sorrell J. Ring packing and amortized F…
阅读更多...
下午好~ 我的论文【CV边角料】（第三期）

下午好~ 我的论文【CV边角料】（第三期）

文章目录 CV边角料Pixel ShuffleSENetCBAMGlobal Context Block (GC)Criss-Cross Attention modules (CC) CV边角料 Pixel Shuffle Real-Time Single Image and Video Super-Resolution Using an Efficient Sub-Pixel Convolutional Neural Network pixelshuffle算法的实现流…
阅读更多...
初识GroovyShell

初识GroovyShell

文章目录 前言一、GroovyShell二、maven三、解决方案四、关键代码4.1 数据库配置表(pg)4.2 入参4.3 分页查询 总结 前言 项目背景&#xff1a;查询多个表的数据列表和详情&#xff0c;但不想创建过多的po、dao、resp等项目文件。 一、GroovyShell Apache Groovy是一种强大的…
阅读更多...
rabbitmq-windows安装使用-简易后台界面-修改密码

rabbitmq-windows安装使用-简易后台界面-修改密码

文章目录 1.下载2.安装3.安装 RabbitMQ4.后台访问5.修改密码 1.下载 将erlang运行时和rabbitmq-windows版本&#xff0c;上传在csdn&#xff0c;下载链接。https://download.csdn.net/download/m0_67316550/88633443 2.安装 右键&#xff0c;以管理员身份运行rabbitmq。启动…
阅读更多...
如何安装LUT预设？达芬奇/FCP/PR怎么安装LUT预设.cube格式文件的教程

如何安装LUT预设？达芬奇/FCP/PR怎么安装LUT预设.cube格式文件的教程

在下载的LUT调色预设压缩文件包中&#xff0c;通常两个包含不同格式的LUT文件&#xff1a; .cube 和 .xmp 包含的 .cube 文件几乎与主流的视频编辑和色彩校正软件兼容&#xff0c;并且还可以在 Adobe Photoshop 等一些照片应用程序中使用。如果主要是将这些 LUT 用于视频剪辑项…
阅读更多...
Redis-数据结构

Redis-数据结构

参考资料 极客时间Redis&#xff08;亚风&#xff09; Redis数据结构 SDS sds(Simple Dynamic String) 字符串接结构体: struct --attribute_- ((-_packed__)) sdshdr8{uint8_t len&#xff1b;/* buf已保祥的字符串字节数&#xff0c;不包含结束标示*/uint8_t alloc&#…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023