MQTT协议介绍

背对背依靠 2023-03-31 原文

一：MQTT

1、MQTT协议说明

（ Message Queuing Telemetry Transport）消息队列传输探测，一种基于发布/订阅模式的轻量级消息传输协议

2、MQTT协议来源

在1999年的时候，Andy Stanford-Clark和 Arlen Nipper需要一种通过卫星连接原油管道数据采集监控系统的协议，以最大限度地减少电池损耗和带宽。所以发明了MQTT协议。

3、MQTT协议使用场景

适用于低带宽和不稳定网络环境的物联网应用场景，在这样的场景中，可以用极少的代码为联网设备提供实时可靠的消息服务。

MQTT 协议广泛应用于物联网、移动互联网、智能硬件、车联网、智慧城市、远程医疗、电力、石油与能源等领域。

4、MQTT协议的特点

易于实现
轻量高效，节省带宽，最小报文仅为 2 个字节。
使用TCP进行连接，实现稳定、可靠的网络连接
基于发布订阅模型，支持双工通信。
灵活性、扩展性很强。

5、C/S和pub/sub的区别

C/S模式：客户端能够直接和服务器进行通信

pub/sub：将发送消息的发布者 publisher与接收消息的订阅者 subscribers进行分离，publisher 与 subscribers 并不会直接通信，他们甚至都不清楚对方是否存在，他们之间的交流由第三方组件 broker 代理。

发布-订阅模式的优点：

消除了传统c/s模式之间的直接通信，把通信这个操作交给了 broker 进行代理，并在空间、时间、同步三个维度上进行了解藕。

6、消息过滤

broker 能够对消息进行过滤，使每个订阅者只接收自己感兴趣的消息。

过滤选项：

（1）基于主题的过滤：MQTT 是基于 subject 的消息过滤的，每条消息都会有一个 topic ，接收客户端会向 borker 订阅感兴趣的 topic，订阅后，broker 就会确保客户端收到发布到 topic 中的消息。

（2）基于内容过滤：broker 会根据特定的内容过滤消息，接受客户端会经过过滤他们感兴趣的内容。

（3）基于类型过滤：使用面向对象的语言时，基于消息（事件）的类型过滤是一种比较常见的过滤方式。

7、MQTT和消息队列区别

消息队列：一条消息只能被一个客户端所消费
MQTT：每个订阅者都会受到消息，每个订阅者有相同的负载（数据信息）

8、MQTT Client

publisher 和 subscriber 都属于 MQTT Client。之所以有发布者和订阅者这个概念，其实是一种相对的概念，就是指当前客户端是在发布消息还是在接收消息

MQTT 客户端是指运行 MQTT 库并通过网络连接到 MQTT broker 的任何设备，这些设备可以从微控制器到成熟的服务器。

9、MQTT broker

broker 负责接收所有消息，过滤消息，确定是哪个 client 订阅了每条消息，并将消息发送给对应的 client.
broker 还负责保存会话数据，这些数据包括订阅的和错过的消息。broker 还负责客户端的身份验证和授权。

10、MQTT连接

连接是client和broker之间的连接。 client 就会向 broker 发起 CONNECT 消息，代理会使用 CONNACK 消息和状态码进行响应。

一旦 client 和 broker 的连接建立后，broker 就会使客户端的连接一直处于打开状态，直到 client 发出断开命令或者连接中断。

11、消息类型说明

发布消息

当 MQTT client 在连接到 broker 之后就可以发送消息了，MQTT 使用的是基于 topic 主题的过滤。每条消息都应该包含一个 topic ，broker 可以使用 topic 将消息发送给感兴趣的 client。
每条消息还会包含一个负载(Payload)，Payload 中包含要以字节形式发送的数据。（数据格式由数据的发布者确定）

订阅消息

client 会向 broker 发送 SUBSCRIBE 消息来接收有关感兴趣的 topic，这个 SUBSCRIBE 消息非常简单，它包含了一个唯一的数据包标识和一个订阅列表。

确认消息

client 在向 broker 发送 SUBSCRIBE 消息后，为了确认每个订阅，broker 会向 client 发送 SUBACK 确认消息。

退订消息：

取消订阅也需要 broker 的确认，此时 broker 会向 client 发送一个 UNSUBACK 消息，这个 UNSUBACK 消息非常简单，只有一个 packetId 数据标识符。

12、topic 相关概念

在 MQTT 中，Topic 是指 broker 为每个连接的 client 过滤消息的 UTF-8 字符串。Topic 是一种分层的结构，可以由一个或者多个 Topic 组成。每个 Topic 由 / 进行分割。

与传统的消息队列相比，MQTT Topic 非常轻量级，client 在发布或订阅之前不需要先创建所需要的 Topic，broker 在接收每个 Topic 前不用进行初始化操作。

13、topic的通配符

当客户端订阅 Topic 时，它可以订阅已发布消息的确切 Topic，也可以使用通配符来同时订阅多个 Topic。通配符有两种：单级和多级。

单级通配符

单级通配符可以替换 Topic 的一个级别，+ 号代表 Topic 中的单级通配符。

多级通配符

多级通配符涵盖多个 Topic，# 代表 Topic 中的多级通配符。为了让 broker 能够确定和哪些 Topic 匹配，多级通配符必须作为 Topic 中的最后一个字符放置，并以 / 开头。

当 client 订阅带有多级通配符的 Topic 时，不论 Topic 有多长多深，它都会收到通配符之前 Topic 的所有消息。如果你只将 Topic 定义为 # 的话，那么你将会收到所有的消息

二：MQTT客户端工具

1、mosquitto

Mosquitto 是一种流行的MQTT代理和客户端库，它可以用于实现MQTT通信

mosquitto是一款实现了消息推送协议 MQTTv5.0, v3.1.1, v3.1 的开源消息代理软件，提供轻量级的，支持可发布/可订阅的的消息推送模式，使设备对设备之间的短消息通信变得简单，比如现在应用广泛的低功耗传感器，手机、嵌入式计算机、微型控制器等移动设备。

Mosquitto 安装之后默认提供了 mosquitto_pub和mosquitto_sub两个命令行 MQTT 客户端工具。

# 下载地址
	https://github.com/eclipse/mosquitto
# 官网
	https://mosquitto.org/

mosquitto_pub：

用于向mqtt broker 发送消息

相关参数：

-h 	# 指定要连接mqtt broker的地址 默认为localhost
-p 	# 指定mqtt broker的端口号
-u 	# 指定在与代理进行身份验证时要使用的用户名
-P 	# 指定在与代理进行身份验证时要使用的密码
-m 	# 消息内容
-t 	# 指定发送消息的topic名称
-i  # 用于为连接到MQTT代理的客户端分配一个唯一的客户端ID

例如：发布消息

# 将连接到本地主机上运行的MQTT代理，并发布消息“Hello, MQTT”到主题“topic/test”上。

mosquitto_pub -h localhost -t "topic/test" -m "Hello, MQTT"

# 例如 向地址为10.0.0.33发送topic为/xyz，消息为"How are you to to to?"的消息
mosquitto_pub -h 10.0.0.33 -t "/xyz" -i "client3" -m "How are you to to to?" -u bruce -P lan1532

mosquitto_sub:

用于向mqtt broker 订阅消息。

当一个MQTT客户端发布一个消息到一个特定的主题时，MQTT代理将把这个消息发送给所有订阅了这个主题的MQTT客户端。

-h 	# 指定要连接mqtt broker的地址 默认为localhost
-p 	# 指定mqtt broker的连接端口号
-u 	# 指定在与代理进行身份验证时要使用的用户名
-P 	# 指定在与代理进行身份验证时要使用的密码（大写P）
-m 	# 消息内容
-t 	# 指定订阅的topic名称 
-i  # 用于为连接到MQTT代理的客户端分配一个唯一的客户端ID

# 为了确保MQTT broker正确地将消息传递给所有订阅者，它需要对每个连接到它的客户端进行唯一标识，这就是客户端ID的作用。

例如：订阅消息

# 连接到本地主机上运行的MQTT代理，并订阅主题“topic/test”上的所有消息。
mosquitto_sub -h localhost -t "topic/test" 

# 例如：
mosquitto_sub -h localhost -t "/xyz" -i "client1"  -u bruce -P lan1532

配置文件说明：

pid_file /var/run/mosquitto.pid

# 消息持久存储
persistence true
persistence_location /var/lib/mosquitto/

# 日志文件存放位置
log_dest file /var/log/mosquitto/mosquitto.log

# 存放子配置文件位置
include_dir /etc/mosquitto/conf.d

# 指定端口号
port 1883

# 指定协议为MQTT协议 如果需要外网可以访问，就必须指定mqtt协议
protocol mqtt

# 设置最大连接数
max_connections -1

# 禁止匿名访问 默认是允许匿名用户访问的
allow_anonymous false

mqtt broker 账号密码的创建：

如果关闭了匿名用户访问，需要mqtt broker指定的账号密码才能发布或者订阅消息。

mosquitto_passwd：用于Mosquitto用户认证配置

# 格式
mosquitto_passwd [ -H hash ] [ -c | -D ] passwordfile username
# 选项
    -c  # 是创建一个新的文件，只保存一个用户
    -b  # 在文件中新增一个用户在最后
    -D  # 从文件中删除指定用户
    -H  # 指定密码加密方式

配置要点：

# 1. 配置文件中加入一下配置    
password_file /mosquitto/pwdfile  #  认证配置
acl_file /mosquitto/aclfile       #  权限配置

# 2. #创建用户和密码  mosquitto_passwd -c /mosquitto/pwdfile username
root@ubuntu1804:~# mkdir /mosquitto

root@ubuntu1804:~# mosquitto_passwd -c /mosquitto/pwdfile tom
Password: 
Reenter password: 

# 3. 权限配置
vim /mosquitto/aclfile

例如：配置mqtt broker的非匿名模式

# 1. 修改配置文件
root@ubuntu1804:~# vim /etc/mosquitto/mosquitto.conf 
pid_file /var/run/mosquitto.pid
persistence true
persistence_location /var/lib/mosquitto/
log_dest file /var/log/mosquitto/mosquitto.log
include_dir /etc/mosquitto/conf.d
allow_anonymous false
password_file /mosquitto/pwdfile
acl_file /mosquitto/aclfile
port 1883
protocol mqtt

# 2. 添加mqtt broker的用户名和权限
root@ubuntu1804:~# mosquitto_passwd -c /mosquitto/pwdfile tom
Password: 
Reenter password: 

root@ubuntu1804:~# vim /mosquitto/aclfile 
user tom
topic write  /#
topic read  /#

# 3. 重启mqtt
root@ubuntu1804:~# systemctl restart mosquitto.service 

# 4. 发起监听
root@ubuntu1804:~# mosquitto_sub -h localhost -t "/xyz" -p 1883   -u tom -P redhat

# 5. 发送消息
root@ubuntu1804:~# mosquitto_pub -h 10.0.0.33 -t "/xyz" -i "client3" -m "How are you to tom ?" -u tom -P redhat -p 1883

监听特定的topic：

发布消息：

2、MQTTX 工具

EMQX：一款应用广泛的大规模分布式物联网 MQTT 服务器。自 2013 年在 GitHub 发布开源版本以来，目前全球下载量已超千万，累计连接物联网关键设备超过 1 亿台。

MQTT X ：一款开源的跨平台桌面客户端，它简单易用且提供全面的 MQTT 5.0 功能、特性测试，可运行在macOS, Linux 和 Windows 上。

# emqx官网： https://www.emqx.io/zh/downloads?os=Windows
# 项目地址： https://github.com/emqx/MQTTX
# 下载地址： https://github.com/emqx/MQTTX/releases
# 官网：     https://mqttx.app/zh。

链接：

https://www.cnblogs.com/qumogu/p/16007609.html

https://segmentfault.com/a/1190000021106683

https://segmentfault.com/a/1190000040216396

MQTT 协议 strong mosquitto code Linux

有关MQTT协议介绍的更多相关文章

Unity 热更新技术 | （三） Lua语言基本介绍及下载安装 - 2
?博客主页：https://xiaoy.blog.csdn.net?本文由呆呆敲代码的小Y原创，首发于CSDN??学习专栏推荐：Unity系统学习专栏?游戏制作专栏推荐：游戏制作?Unity实战100例专栏推荐：Unity实战100例教程?欢迎点赞?收藏⭐留言?如有错误敬请指正！?未来很长，值得我们全力奔赴更美好的生活✨------------------❤️分割线❤️-------------------------
CAN协议的学习与理解 - 2
最近在学习CAN，记录一下，也供大家参考交流。推荐几个我觉得很好的CAN学习，本文也是在看了他们的好文之后做的笔记首先是瑞萨的CAN入门，真的通透；秀！靠这篇我竟然2天理解了CAN协议！实战STM32F4CAN！原文链接：https://blog.csdn.net/XiaoXiaoPengBo/article/details/116206252CAN详解（小白教程）原文链接：https://blog.csdn.net/xwwwj/article/details/105372234一篇易懂的CAN通讯协议指南1一篇易懂的CAN通讯协议指南1-知乎(zhihu.com)视频推荐CAN总线个人知识总
ruby - HTTP POST 上的 SSL 错误(未知协议(protocol)) - 2
尝试通过SSL连接到ImgurAPI时出现错误。这是代码和错误:API_URI=URI.parse('https://api.imgur.com')API_PUBLIC_KEY='Client-ID--'ENDPOINTS={:image=>'/3/image',:gallery=>'/3/gallery'}#Public:Uploadanimage##args-Theimagepathfortheimagetoupload#defupload(image_path)http=Net::HTTP.new(API_URI.host)http.use_ssl=truehttp.verify
物联网MQTT协议详解 - 2
一、什么是MQTT协议MessageQueuingTelemetryTransport：消息队列遥测传输协议。是一种基于客户端-服务端的发布/订阅模式。与HTTP一样，基于TCP/IP协议之上的通讯协议，提供有序、无损、双向连接，由IBM（蓝色巨人）发布。原理：（1）MQTT协议身份和消息格式有三种身份：发布者（Publish）、代理（Broker）（服务器）、订阅者（Subscribe）。其中，消息的发布者和订阅者都是客户端，消息代理是服务器，消息发布者可以同时是订阅者。MQTT传输的消息分为：主题（Topic）和负载（payload）两部分Topic，可以理解为消息的类型，订阅者订阅（Su
H2数据库配置及相关使用方式一站式介绍（极为详细并整理官方文档） - 2
目录H2数据库入门以及实际开发时的使用1.H2数据库的初识1.1H2数据库介绍1.2为什么要使用嵌入式数据库？1.3嵌入式数据库对比1.3.1性能对比1.4技术选型思考2.H2数据库实战2.1H2数据库下载搭建以及部署2.1.1H2数据库的下载2.1.2数据库启动2.1.2.1windows系统可以在bin目录下执行h2.bat2.1.2.2同理可以通过cmd直接使用命令进行启动：2.1.2.3启动后控制台页面：2.1.3spring整合H2数据库2.1.3.1引入依赖文件2.1.4数据库通过file模式实际保存数据的位置2.2H2数据库操作2.2.1Mysql兼容模式2.2.2Mysql模式
ruby-on-rails - Rails 和 MQTT : Subscribe to topic in background at server startup? - 2
我想在服务器启动时在我的Rails应用程序中订阅一个mqtt主题，并保持订阅始终处于事件状态和运行状态。我正在使用这个mqttgem进行mqtt通信:https://github.com/njh/ruby-mqtt这是我现在拥有的:在application.rb中:config.after_initializedomqttSub=BackgroundMQTT.newmqttSub.runend后台MQTT类:classMQTTSubscriberdefrunThread.newdoMQTT::Client.connect(:host=>'localhost',:port=>1883,)
网络实验之RIPV2协议（一） - 2
一、RIPV2协议简介 RIP(RoutingInformationProtocol)路由协议是一种相对古老，在小型以及同介质网络中得到了广泛应用的一种路由协议。RIP采用距离向量算法，是一种距离向量协议。RIP-1是有类别路由协议（ClassfulRoutingProtocol），它只支持以广播方式发布协议报文。RIP-1的协议报文无法携带掩码信息，它只能识别A、B、C类这样的自然网段的路由，因此RIP-1不支持非连续子网（DiscontiguousSubnet）。RIP-2是一种无类别路由协议（ClasslessRoutingProtocol），支持路由标记，在路由策略中可根据路由标记对
MQTTX工具上的 mqtt mqtts ws wss的区别，以及常见问题解答 - 2
ws --> WebSocket非加密（端口8083）wss-->WebSocketSSL加密（端口8084）mqtt-->mqtt非加密（端口1883）mqtts-->mqtt加密（端口8884）WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据初学者容易出现以下几个错误：连接地址没有指明协议：WebSocket作为一种通信协议，其使用 ws (非加密)、wss(SSL加密)作为协议标识。MQTT.js客户端支持多种协议，连接地址需指明协议类型；连接地址没有指明端口：MQTT并未对WebSocket接入端口做出规定，EMQX上默认使用 8083
Spring Cloud Gateway 服务网关的部署与使用详细介绍 - 2
为什么需要服务网关传统的单体架构中只需要开放一个服务给客户端调用，但是微服务架构中是将一个系统拆分成多个微服务，如果没有网关，客户端只能在本地记录每个微服务的调用地址，当需要调用的微服务数量很多时，它需要了解每个服务的接口，这个工作量很大。有了网关之后，网关作为系统的唯一流量入口，封装内部系统的架构，所有请求都先经过网关，由网关将请求路由到合适的微服务。使用网关的好处1）简化客户端的工作。网关将微服务封装起来后，客户端只需同网关交互，而不必调用各个不同服务；（2）降低函数间的耦合度。一旦服务接口修改，只需修改网关的路由策略，不必修改每个调用该函数的客户端，从而减少了程序间的耦合性（3）解放开发
基于ActiveMQ搭建MQTT服务备忘（二）：webapp集成 - 2
（1）为什么写这个话题（Why）读万卷书不如行千里路。这次搭建MQTT服务，遇到了一些误解，特此记录备忘。主要包括：（1）服务（Broker）的账户管理与网页管理平台的账户（2）与web应用的集成（Spring系）（2）ActiveMQ版本选择因为JAVA环境是JDK8，所以按兼容性考虑选择了ActiveMQ5.15的最后版本5.15.15。如果你是JDK11则可考虑ActiveMQ的最新版本5.17或5.18。ActiveMQ支持MQTTv3.1.1andv3.1。（3）ActiveMQ与web应用的集成主要介绍与Spring系的webapp集成（SpringBoot和SpringMVC）。