最新要闻
- 焦点简讯:吃日料、听京剧 库克时隔3年再访中国:6年前还去过ofo小黄车总部
- 全球观焦点:酷派新品发布会定档4月3日:三款新机待发
- 世界聚焦:2023增长最快的手机品牌!一加Ace 2首销日销量在第三方平台遥遥领先
- 天天观察:B站弹幕射击《爆裂魔女》5月30日停运 共运营592天
- 任天堂Switch 2不会远了!开发者已收到新主机开发工具
- 世界信息:周日阳光可期抓紧洗晒 下周四冷空气再袭降水将达到中雨
- 世界百事通!比亚迪F品牌再曝谍照 主攻40-60万市场/下半年预售
- 天天资讯:38岁985文科硕士被迫送外卖!本人再发声:已脱下孔乙己长衫 应聘道士被拒
- 云南一县城禁止“脏车入城”:有明显污迹、车轮粘泥不许在城区行驶
- 百元就能畅享8K 流畅清爽无广告!当贝盒子H3视频评测
- 当前快讯:刘浩存在新片《龙马精神》首映礼上哭了:感谢成龙带自己拍戏
- 环球今头条!GPT-4被指威胁公共安全!OpenAI遭第三方组织投诉
- 英特尔以强大产品力,迎接生成式AI的广阔机遇
- 热消息:直播间卖卫星 最低200万!罗永浩:真的 把卫星价格打下来
- Redmi Note 12 Turbo晒战绩:16GB+1TB开售5分钟超过全行业历史销量之和
- 每日热闻!这就离谱!A7S3传感器用来拍Vlog 索尼ZV-E1开启预售
手机
iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- iphone11大小尺寸是多少?苹果iPhone11和iPhone13的区别是什么?
- 警方通报辅警执法直播中被撞飞:犯罪嫌疑人已投案
- 男子被关545天申国赔:获赔18万多 驳回精神抚慰金
- 3天内26名本土感染者,辽宁确诊人数已超安徽
- 广西柳州一男子因纠纷杀害三人后自首
- 洱海坠机4名机组人员被批准为烈士 数千干部群众悼念
家电
【环球报资讯】MQTT协议介绍
一: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 truepersistence_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 usernameroot@ubuntu1804:~# mkdir /mosquittoroot@ubuntu1804:~# mosquitto_passwd -c /mosquitto/pwdfile tomPassword: Reenter password: # 3. 权限配置vim /mosquitto/aclfile
例如:配置mqtt broker的非匿名模式
# 1. 修改配置文件root@ubuntu1804:~# vim /etc/mosquitto/mosquitto.conf pid_file /var/run/mosquitto.pidpersistence truepersistence_location /var/lib/mosquitto/log_dest file /var/log/mosquitto/mosquitto.loginclude_dir /etc/mosquitto/conf.dallow_anonymous falsepassword_file /mosquitto/pwdfileacl_file /mosquitto/aclfileport 1883protocol mqtt# 2. 添加mqtt broker的用户名和权限root@ubuntu1804:~# mosquitto_passwd -c /mosquitto/pwdfile tomPassword: Reenter password: root@ubuntu1804:~# vim /mosquitto/aclfile user tomtopic write /#topic read /## 3. 重启mqttroot@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
关键词:
-
世界热资讯!开心档之Go 语言环境安装
Go语言环境安装Go语言支持以下系统:LinuxFreeBSDMacOSX(也称为Darwin)Windows安装包下载地址为:https: golang org dl 。如
来源: 【环球报资讯】MQTT协议介绍
世界热资讯!开心档之Go 语言环境安装
DIM中的一些知识点(慢更)
新消息丨每日机构分析:3月31日
全球实时:国家发展改革委:国内汽、柴油价格每吨分别降低335元和320元
焦点简讯:吃日料、听京剧 库克时隔3年再访中国:6年前还去过ofo小黄车总部
全球观焦点:酷派新品发布会定档4月3日:三款新机待发
世界聚焦:2023增长最快的手机品牌!一加Ace 2首销日销量在第三方平台遥遥领先
天天观察:B站弹幕射击《爆裂魔女》5月30日停运 共运营592天
任天堂Switch 2不会远了!开发者已收到新主机开发工具
世界信息:周日阳光可期抓紧洗晒 下周四冷空气再袭降水将达到中雨
每日快讯!卸载SQL Server 2012图文教程
环球报道:你还在手写 join 联表查询?MyBatis-Plus 这样写太香了!
天天新动态:Python 数字类型之 int float
每日观点:收评:两市红盘震荡创指涨0.69% 人工智能板块涨幅居前
世界百事通!比亚迪F品牌再曝谍照 主攻40-60万市场/下半年预售
天天资讯:38岁985文科硕士被迫送外卖!本人再发声:已脱下孔乙己长衫 应聘道士被拒
云南一县城禁止“脏车入城”:有明显污迹、车轮粘泥不许在城区行驶
百元就能畅享8K 流畅清爽无广告!当贝盒子H3视频评测
当前快讯:刘浩存在新片《龙马精神》首映礼上哭了:感谢成龙带自己拍戏
环球今头条!GPT-4被指威胁公共安全!OpenAI遭第三方组织投诉
基于Go/Grpc/kubernetes/Istio开发微服务的最佳实践尝试 - 2/3
【焦点热闻】如何实现根据环境切换不同配置?
数据丢失不用怕,火山引擎 DataLeap 提供排查解决方案
英特尔以强大产品力,迎接生成式AI的广阔机遇
【全球快播报】北京启动存量住房交易“带押过户”模式
热消息:直播间卖卫星 最低200万!罗永浩:真的 把卫星价格打下来
Redmi Note 12 Turbo晒战绩:16GB+1TB开售5分钟超过全行业历史销量之和
每日热闻!这就离谱!A7S3传感器用来拍Vlog 索尼ZV-E1开启预售
vivo X Fold2影像曝光:IMX866主摄、潜望长焦取消
天天实时:一键获取测试脚本,轻松验证“TSBS 时序数据库性能基准测试报告”
天天快看点丨windows系统 批量处理文件名称
Python Django投稿系统代码
环球今头条!日本最早将于2024年度在新东名高速公路部分区间设置自动驾驶车道
环球即时看!小姐姐秒种草!雅迪冠能摩登发布:独创复古女王风
当前速讯:你家乡上榜没?中国省级“癌症地图”出炉:肺癌列第一 “穷癌”下降“富癌”上升
3299元性价比封神!AMD Zen4 104MB缓存锐龙7 7800X3D价格公布
迅雷临时文件读取错误怎么回事?迅雷临时文件读取错误怎么解决?
色带打印机怎么换色带?色带的正确安装方法是什么?
win10版本号与操作系统版本号有什么区别?怎么查看win10版本号?
英雄联盟狮子狗叫什么?英雄联盟狮子狗连招介绍
诺基亚X3上市时间是什么时候?诺基亚X3手机参数
CloudCanal 落地 DB2 数据迁移同步功能
观天下!hdfs disk balancer 磁盘均衡器
全球百事通!Python 应用 - jieba 分词 1:进行批量文本分词_艽野尘梦 better 的博客 - CSDN 博客
全球滚动:数论分块简介
【速看料】Mysql之SQL语句基础1
环球快报:2磅蛋糕是几寸适合多少人吃_2磅蛋糕是几寸
新消息丨贾跃亭宣布历史时刻:为梦想窒息FF 91量产!老外狠拆台展示车架或未全面投产
Windows 11 2024版发布了!首个官方ISO镜像免费下载
环球观点:调查显示:超半数受访者认为学历还是敲门砖
环球今热点:男子将父亲骨灰撒入大海被抓?为啥不能私自撒?
全球消息!庆祝索尼第一方游戏登陆XGP:微软推出Xbox限定主机
交互触摸大屏概念整理
速讯:全网最全的权限系统设计方案,不接受反驳!
要闻速递:[Redis]Redis概述
JSON多层嵌套复杂结构数据扁平化处理转为行列数据
微速讯:飞沫传播图片_飞沫传播
每日讯息!【财经分析】“意料之中”与“预期之外” 一季度债市踌躇中展现韧性
国产商用卫星上架电商:折后200万起
全球讯息:双电机三把锁!比亚迪F品牌“SF”谍照再曝光:或于6月发布
天天通讯!43万起 新一代长轴版奔驰GLC开售 网友:给我一个不买理想L9的理由
当前信息:《流浪地球2》摄影指导:没觉得中国电影比别人差
焦点热议:广东检出1例“恐龙血”:Hh孟买血型系统 比Rh还稀有
宿州埇桥:烧鸡展翅飞出一片“新天地”
Twitter营销教程_编程入门自学教程_菜鸟教程-免费教程分享
世界速递!skywalking插件工作原理剖析
全网最详细中英文ChatGPT-GPT-4示例文档-类比语句智能生成从0到1快速入门——官网推荐的48种最佳应用场景(附python/node.js/curl命
全球观察:利用Jackson序列化实现数据脱敏
特斯拉Model 3起火殃及宝马新车 车主索赔法院如此判决
新疆阿瓦提长绒棉:清爽透气纯棉背心9.9元/件狂促
小伙戒指卡手遇130名消防员演训:正好现场教学 科普一定不能硬拽
每日热门:城会玩!印度法官无法判决向ChatGPT求助 专家称或成全球法院系统标配
专为小姐姐打造!雅迪冠能Q9发布:超级续航+超级好看
环球讯息:清明将至,我省各地倡导文明祭祀育新风—— 追思亲人,如何更好“重情”
当前消息!Microsoft Edge 分屏 推荐
国家统计局:3月份采购经理指数延续扩张走势
世界速看:社保基金2022年四季度新进30股 增持64股
天天快看点丨法拉第未来发布会只展示了个车架 贾跃亭还有这些问题需要回答
女子带孩子吃饭故意往菜里扔头发 店家看监控发现:网友吐槽教坏孩子
号称德国500年纯酿造法!特斯拉推出啤酒GigaBier:3瓶卖667元
全球通讯!微软、索尼等巨头纷纷退出:全球最大游戏展E3宣布取消
当前速看:15.86万元起 新款大众途岳上市:换1.5T发动机、能喝92号油
助力“科技+产业+金融”良性发展 上海首单非公开科创债发行
让退化的森林再获新生
天天滚动:比亚迪不去美国 照样做大哥
世界观速讯丨海底捞2022年营收347亿!“最牛打工妹”杨利娟接任后扭亏为盈赚了13亿
天天热资讯!4G比5G更成熟 越来越多用户认可?三大运营商猛推5G 2025年将连接超10亿
熔断和降级有什么区别?
资讯:国际金融市场早知道:3月31日
全球播报:上证报:美元拐点将至,分析师称人民币资产或有望成为避险资产
当前播报:冯小刚主演 中国版《忠犬八公》今日上映:日本版曾感动无数人
视讯!发布/上市时间来了!NV RTX 4070国行售价大曝光:玩家直呼老黄良心了
读SQL进阶教程笔记03_自连接
pcm音频的录制、播放及转换
全球观点:非洲致命疾病 出现症状24小时内死亡:医生直呼病毒可怕引外界担心
快报:媒体:谁在开发“一键脱衣”App 行为龌龊已触犯法律 应严惩开发者
环球热文:新疆新鑫矿业(03833.HK)2022年度纯利增44.4%至7.45亿元 末期息0.15元
【世界新视野】美国火车又双叒叕脱轨了:装乙醇车厢爆炸起火
SSD还要降价!今年是涨不回来了