📡 物联网消息队列 & MQTT 集成实战
📘 30章 · 从入门到项目
01
物联网消息队列概述
MQTT协议起源 · 物联网通信挑战 · 消息队列在IoT中的角色
02
MQTT核心概念
发布/订阅模型 · 主题(Topic) · 服务质量(QoS) · 保留消息
03
MQTT Broker选型
Mosquitto · EMQX · VerneMQ对比，如何选择适合的Broker
04
Mosquitto安装与配置
在Linux/Windows上安装Mosquitto，基础配置文件解析
05
MQTT客户端开发(Python)
使用paho-mqtt库实现发布者和订阅者
06
MQTT遗嘱消息
遗嘱消息机制 · 应用场景 · 代码实现
07
MQTT保留消息
保留消息原理 · 与普通消息的区别 · 实战用法
08
MQTT通配符
单级通配符+ · 多级通配符# · 主题过滤最佳实践
09
MQTT安全机制
用户名/密码认证 · TLS/SSL加密 · 证书配置
10
MQTT WebSocket
通过WebSocket桥接MQTT，浏览器端订阅实现
11
消息队列基础
什么是消息队列 · 为什么需要消息队列 · 常见MQ产品对比
12
RabbitMQ入门
RabbitMQ核心概念 · 安装 · Hello World示例
13
RabbitMQ交换机
Direct · Topic · Fanout · Headers 四种交换机详解
14
RabbitMQ队列与绑定
队列声明 · 绑定键 · 死信队列
15
RabbitMQ消息确认
生产者确认 · 消费者确认 · 消息持久化
16
Kafka入门
Kafka核心概念 · 分区机制 · 与MQTT的差异
17
Kafka生产者与消费者
Python操作Kafka，生产与消费消息
18
Kafka分区与偏移量
分区策略 · 偏移量提交 · 重平衡
19
MQTT与Kafka桥接
为什么需要桥接 · 桥接方案对比 · EMQX桥接Kafka
20
EMQX桥接Kafka实战
配置EMQX规则引擎，将MQTT消息转发到Kafka
21
MQTT与RabbitMQ桥接
RabbitMQ MQTT插件，实现双向通信
22
数据流处理
从MQTT到消息队列，再到数据存储的完整链路
23
物联网数据模型
设备影子 · 数字孪生 · 状态同步设计
24
海量设备连接管理
连接池 · 会话保持 · 心跳机制
25
消息去重与幂等性
QoS语义 · 去重策略 · 幂等消费设计
26
物联网网关模式
协议转换 · 边缘计算 · MQTT网关实现
27
监控与告警
MQTT Broker监控 · 消息队列监控 · Prometheus集成
28
性能调优
MQTT参数调优 · Kafka参数调优 · 网络延迟优化
29
实战项目一：智能家居数据采集
传感器 → MQTT → Kafka → 数据库
30
实战项目二：工业设备远程监控
MQTT + RabbitMQ + WebSocket