VIP20

本课程属于：028-矿山物联网技术 能源与矿业工程 · 共 20 门相关课程，组合学习更完整。

查看所属VIP全部课程 →

← 返回所属目录咨询 / 购买

矿山MQTT主题订阅与QoS丢包排查实战60例

共计 60 章节

可可资料掘金营 · 点击在线试看

矿山传感器MQTT主题层级设计

针对矿山井下多类传感器（瓦斯 · 风速 · 水位）

MQTT矿山传感器

基于Mosquitto搭建矿山本地Broker

在矿山本地服务器上安装并配置Mosq… · 设置监听端口 · 认证与ACL

MosquittoBroker

传感器客户端QoS等级选择与配置

根据矿山不同传感器数据的实时性与可靠… · 为瓦斯报警 · 水位监测等主题分别选择QoS 0/1…

QoS传感器客户端

订阅端通配符误匹配排查

复现订阅端使用通配符（+ · #）导致意外接收无关主题消息的问题 · 通过日志与主题树分析定位误匹配规则并…

订阅端通配符误匹…复现订阅端使用通…

QoS 1重复消息去重处理

在矿山监控订阅端实现基于消息ID或业… · 验证在QoS 1下Broker重传导…

QoS1重复消息去重处…

QoS 2丢包场景复现与抓包分析

在可控网络环境中模拟QoS 2消息丢… · 使用tcpdump抓取MQTT报文 · 分析PUBLISH/PUBREL/P…

QoS2丢包场景复现

遗嘱消息配置与掉线告警验证

为井下传感器客户端配置遗嘱消息（Wi… · 模拟设备异常断线 · 验证地面监控端能及时收到离线告警并记…

遗嘱消息配置掉线告警验证

保留消息导致新订阅者收到过期数据

复现保留消息（Retained Me… · 通过清除保留消息或调整发布策略解决数…

保留消息导致新订…Retained

矿山主题ACL权限隔离配置

配置Broker的ACL规则 · 限制不同区域传感器只能发布本区域主题 · 监控端只能订阅授权主题

ACL矿山主题

弱网下QoS 1消息丢失链路定位

在模拟井下弱网（高延迟 · 丢包）环境中 · 通过Broker日志

订阅端消息处理阻塞导致QoS降级

构造订阅端消息处理耗时过长场景 · 观察Broker积压与QoS 1消息… · 通过异步处理或增加消费者解决阻塞

QoS订阅端消息处理阻…

Clean Session对离线消息的影响测试

对比Clean Session为tr… · 订阅端离线期间QoS 1消息的保留与… · 为矿山监控端选择正确的会话保持策略

主题别名与矿山长主题优化

针对矿山层级较深的主题名称 · 启用MQTT 5主题别名（Topic… · 并验证别名映射在连接生命周期内的正确…

主题别名矿山长主题优化

共享订阅实现多监控端负载均衡

配置共享订阅（Shared Subs… · 验证消息不被重复处理且各实例负载均衡

共享订阅实现多监…Shared

QoS 0消息在矿山报警场景的适用性验证

在瓦斯超限报警主题上使用QoS 0 · 通过模拟网络抖动统计消息到达率 · 判断该等级是否满足矿山安全报警的最低…

Broker最大连接数与矿山设备规模评估

通过压测工具逐步增加MQTT连接数 · 观察Broker资源占用与拒绝连接阈… · 评估当前配置能否支撑矿山规划传感器数…

Broker最大连接数

订阅主题过多导致Broker内存增长排查

模拟大量客户端订阅不同主题 · 监控Broker内存与订阅树规模 · 定位因订阅过滤器设计不当导致的内存持…

Broker订阅主题过多导致

消息堆积与QoS 1重传风暴抑制

在订阅端消费能力不足时 · 观察QoS 1消息堆积引发的重传风暴 · 通过调整Broker最大 infli…

QoS消息堆积

矿山跨区域网关卡顿导致消息乱序

模拟跨区域网关转发延迟不一致 · 复现同一主题下QoS 1消息乱序到达 · 在订阅端增加序列号或时间戳排序机制恢…

矿山跨区域网关卡…模拟跨区域网关转…

遗嘱消息与保留消息组合的离线状态误判

复现遗嘱消息与保留消息同时使用时 · 新订阅者收到过期离线状态的问题 · 通过状态主题设计或消息过期属性修正误…

遗嘱消息保留消息组合的离…

MQTT 5消息过期属性在矿山数据中的应用

为矿山实时监测主题设置消息过期时间（… · 验证过期消息不会被投递给晚连接的订阅… · 避免使用陈旧数据

MQTT5消息过期属性

订阅端QoS降级协商排查

当发布端使用QoS 2而订阅端最大Q… · 通过抓包确认Broker实际投递Qo… · 排查因协商降级导致的可靠性预期偏差

矿山主题命名冲突与保留消息覆盖

复现不同设备误用同一主题发布保留消息… · 通过主题命名规范与ACL限制消除冲突

矿山主题命名冲突保留消息覆盖

Broker持久化配置与重启后消息恢复验证

配置Broker持久化会话与消息存储 · 模拟Broker重启 · 验证QoS 1离线消息在重启后能否正…

Broker持久化配置

订阅端心跳超时导致频繁重连排查

调整Keep Alive与心跳超时参… · 观察弱网下客户端频繁断连重连对QoS… · 定位并优化心跳配置

订阅端心跳超时导…Keep

矿山传感器批量上线时的主题订阅风暴

模拟大量传感器同时上线并订阅主题 · 观察Broker的SUBSCRIBE… · 通过错峰上线或订阅合并缓解订阅风暴

矿山传感器批量上…模拟大量传感器同…

QoS 2四步握手丢包定位与重传分析

在QoS 2流程中人为丢弃PUBRE… · 通过抓包分析发布端重传PUBLISH… · 验证Broker对重复PUBLISH…

QoS2四步握手丢包定…

订阅过滤器重叠导致消息重复投递

复现同一客户端使用多个重叠订阅过滤器… · 通过合并订阅解决

订阅过滤器重叠导…复现同一客户端使…

矿山监控端消息积压的消费速率评估

统计单位时间内订阅端实际消费消息数与… · 计算消费缺口 · 评估是否需要增加消费者或提升处理性能

矿山监控端消息积…统计单位时间内订…

TLS加密下MQTT连接失败排查

为矿山MQTT通信启用TLS · 模拟证书过期或主机名不匹配导致连接失… · 通过客户端错误码与Broker日志定…

基于主题的矿山数据分流与规则引擎验证

利用Broker规则引擎或桥接功能 · 将不同主题的传感器数据分流到不同后端 · 验证分流规则不丢失QoS 1消息且主…

基于主题的矿山数…规则引擎验证

离线消息队列溢出导致QoS 1丢包

配置Broker离线消息队列上限 · 模拟订阅端长时间离线导致队列溢出 · 观察QoS 1消息被丢弃的现象并调整…

QoS离线消息队列溢出…

矿山多级主题订阅权限继承验证

设计基于主题层级的ACL继承规则 · 验证父级主题授权能否正确覆盖子级订阅 · 排查因权限继承错误导致的订阅失败

矿山多级主题订阅…ACL

客户端ID冲突导致连接互踢与消息丢失

复现两个客户端使用相同Client… · 观察QoS 1消息在连接切换过程中的… · 通过唯一ID规范解决

MQTT桥接跨矿区消息丢失排查

配置两个矿区Broker之间的MQT… · 模拟桥接链路中断后恢复 · 验证QoS 1消息在桥接方向的补发行…

MQTT桥接跨矿区消息丢…

订阅端消息确认延迟对QoS 1重传的影响

人为延迟订阅端PUBACK发送 · 观察发布端重传计时器触发与Broke… · 分析确认延迟对消息重复率的影响

QoS订阅端消息确认延…

矿山主题通配符订阅性能对比测试

对比使用精确主题 · 单层通配符和多层通配符订阅时Brok… · 为大规模主题订阅选择高效过滤器

矿山主题通配符订…对比使用精确主题

Broker日志级别调整定位QoS丢包

将Broker日志级别调整为debu… · 复现QoS 1消息丢失场景 · 从日志中提取消息入队

矿山传感器时间戳与消息顺序校验

在订阅端校验消息内时间戳与接收顺序 · 识别因网络乱序或重传导致的时序错乱 · 并设计告警抑制规则避免误报

矿山传感器时间戳消息顺序校验

QoS 1消息在Broker内存与磁盘间的流转验证

配置Broker消息持久化到磁盘 · 模拟内存压力 · 验证QoS 1消息从内存刷写到磁盘再…

订阅端断线重连后重复订阅排查

复现客户端断线重连时未清理旧订阅导致… · 通过会话状态检查与订阅去重逻辑解决消…

订阅端断线重连后…复现客户端断线重…

矿山报警主题的QoS与保留策略组合验证

为瓦斯报警主题组合使用QoS 1与保… · 验证新订阅者能立即获知当前报警状态 · 同时避免历史报警重复触发

QoS矿山报警主题的

MQTT 5原因码在订阅失败排查中的应用

构造订阅被ACL拒绝 · 主题过滤器非法等场景 · 读取SUBACK原因码

矿山边缘网关消息缓存与补传验证

在边缘网关实现断网期间本地缓存QoS… · 恢复后按序补传的逻辑 · 验证补传过程不丢失且不重复

矿山边缘网关消息…补传验证

Broker最大报文大小限制导致发布失败

模拟传感器发布超过Broker最大报… · 观察连接断开或发布失败现象 · 通过分片或调整限制解决

Broker最大报文大小限制…

订阅端QoS 2消息重复投递排查

在QoS 2流程中模拟PUBCOMP… · 观察发布端重传PUBLISH与Bro… · 排查订阅端是否收到重复消息并验证协议…

矿山主题订阅延迟与消息时效性评估

测量从传感器发布到监控端接收的端到端… · 分析QoS等级 · 网络跳数和Broker负载对延迟的影…

矿山主题订阅延迟消息时效性评估

基于MQTT 5用户属性的消息过滤验证

在发布消息时附加用户属性标识矿区编号 · 订阅端根据用户属性进行二次过滤 · 验证属性传递完整性并排查过滤遗漏

Broker集群下主题订阅同步与消息丢失排查

搭建双节点Broker集群 · 模拟节点故障切换 · 验证订阅关系同步与QoS 1消息在切…

Broker集群下主题订阅同…

矿山传感器固件升级主题的QoS选择验证

为固件升级指令主题选择QoS 2并验… · 对比QoS 1下可能出现的重复执行问…

QoS矿山传感器固件升…

订阅端消息处理异常导致QoS 1未确认排查

模拟订阅端业务处理抛出异常未发送PU… · 观察Broker重传与消息堆积 · 通过异常捕获与确认机制修复

QoS订阅端消息处理异…

矿山主题命名空间隔离与多租户验证

为不同承包商设计独立主题命名空间 · 通过ACL与订阅过滤器验证租户间消息… · 排查越界订阅导致的数据泄露

矿山主题命名空间…多租户验证

MQTT over WebSocket在矿山监控大屏的连通性排查

配置Broker支持WebSocke… · 使矿山监控大屏通过WebSocket… · 排查跨域

QoS 1消息在NAT超时下的丢失复现

模拟井下设备经过NAT网关后长时间无… · 复现QoS 1消息丢失 · 通过调整Keep Alive或使用T…

订阅端消息确认与业务处理顺序一致性验证

验证订阅端在异步处理消息时先确认后处… · 改为处理完成后再确认 · 并测试QoS 1下的可靠性提升

订阅端消息确认业务处理顺序一致…

矿山Broker连接数突增的限流与降级验证

配置Broker最大连接数限制与连接… · 模拟传感器批量重连 · 验证限流生效且已连接客户端不受影响

基于主题的矿山数据保留周期与清理验证

为不同主题设置保留消息的过期时间或定… · 验证过期保留消息被清除 · 避免新订阅者获取过期矿山状态

基于主题的矿山数…清理验证

MQTT 5订阅标识符在消息路由中的应用

使用订阅标识符区分同一客户端的不同订… · 验证消息携带正确标识符 · 便于订阅端按来源分流处理

MQTT5订阅标识符

矿山弱网模拟环境下的QoS等级对比测试

使用网络损伤仪模拟丢包 · 延迟 · 抖动

QoS矿山弱网模拟环境…

Broker消息投递确认超时参数调优

调整Broker的QoS 1消息投递… · 在弱网环境下测试不同参数组合对消息丢… · 选出最优配置

Broker消息投递确认超时…