RT-Thread 第 8 课时：LwIP 网络基础 + MQTT 软件包上云
前言导读
前面搞定：内核线程、驱动外设、文件存储、日志归档；本节课直击物联网核心 —— 联网上云：先懂 LwIP 轻量级 TCP/IP 协议栈，再用 RT-Thread 官方 MQTT 软件包，实现设备连接 MQTT 服务器、订阅主题、发布传感器数据，完成「终端采集→本地存储→云端上报」全链路。
前置：已会设备配置、FinSH、有 ESP8266/ETH 网口模块、搭建 MQTT 测试服务器。
一、课时学习目标
- 理解 LwIP 协议栈、SAL 套接字抽象层原理
- 学会 WiFi 模块 (ESP8266) 驱动配网、联网调试
- 掌握 TCP/UDP 基础套接字编程
- 熟练使用 RT-Thread MQTT 软件包：连接 / 订阅 / 发布
- 实现 AHT10 温湿度数据实时上报 MQTT 云端
二、核心概念：LwIP + SAL 网络架构
2.1 LwIP 是什么
LwIP = 轻量级 TCP/IP 协议栈，专为嵌入式 MCU 设计：
- 支持 TCP/UDP/ICMP/DHCP
- 内存占用小，适配 STM32 等单片机组网
- RT-Thread 原生深度适配，开箱即用
2.2 SAL 套接字抽象层
上层统一标准 Socket 接口，下层兼容：
- WiFi 网卡、以太网、4G 模组
- 业务代码不用改，换联网模块直接兼容
2.3 联网整体流程
硬件模组驱动 → 网卡注册 → DHCP 获取 IP → Socket 通信 → MQTT 应用
三、实操 1：ESP8266 WiFi 配网（基础必备）
3.1 Studio 配置开启
- 开启 AT 组件、ESP8266 驱动
- 绑定串口 (如 uart2) 对应 WiFi 模块
- 配置 WiFi 名称 / 密码
3.2 FinSH 联网调试命令
wifi scan # 扫描周边WiFi wifi join SSID PWD # 连接WiFi ifconfig # 查看本机IP、网关、网卡状态 ping 4.2.2.2 # 测试外网通断判断标准：拿到 IP、ping 通，说明底层网络链路正常。
四、实操 2：原生 TCP Socket 通信（理解网络）
4.1 基础 Socket 核心 API
socket() // 创建套接字 connect() // 连接服务器 send() // 发送数据 recv() // 接收数据 close() // 关闭连接4.2 简易 TCP 客户端 Demo
#include <rtthread.h> #include <sys/socket.h> #include <netdb.h> #define SERVER_IP "192.168.1.100" #define SERVER_PORT 8080 void tcp_client_thread(void *arg) { int sockfd; struct sockaddr_in server_addr; char buf[64] = "Hello TCP Server\r\n"; // 创建socket sockfd = socket(AF_INET, SOCK_STREAM, 0); server_addr.sin_family = AF_INET; server_addr.sin_port = htons(SERVER_PORT); inet_aton(SERVER_IP, &server_addr.sin_addr); // 连接服务器 connect(sockfd, (struct sockaddr*)&server_addr, sizeof(server_addr)); while(1) { send(sockfd, buf, rt_strlen(buf), 0); rt_thread_mdelay(2000); } }五、实操 3：MQTT 软件包上云（本节课重点）
5.1 MQTT 核心优势
物联网标准协议：
- 发布 / 订阅模式
- 轻量、低流量、稳定
- 适配阿里云 / 腾讯云 / 华为云 / 私有 MQTT 服务器
5.2 RT-Thread 配置 MQTT
- Env/Studio 下载 MQTT 官方软件包
- 配置 MQTT 服务器地址、端口、设备 ID
- 开启心跳、重连机制
5.3 关键 MQTT 主题约定
- 上报主题：
device/xxx/upload - 控制下发主题：
device/xxx/cmd
5.4 完整 MQTT 发布温湿度 Demo
#include <rtthread.h> #include <mqttclient.h> // MQTT配置 #define MQTT_BROKER "tcp://192.168.1.100:1883" #define DEVICE_ID "rtthread_sensor_01" #define TOPIC_UP "device/sensor/upload" // 定时上报线程 void mqtt_upload_thread(void *arg) { float temp, humi; char payload[128]; while(1) { // 读取AHT10数据 aht10_read_data(&temp, &humi); // 拼接JSON报文 rt_snprintf(payload, sizeof(payload), "{\"device\":\"%s\",\"temp\":\"%.2f\",\"humi\":\"%.2f\"}", DEVICE_ID, temp, humi); // MQTT发布消息 mqttclient_publish(TOPIC_UP, payload, rt_strlen(payload), 0, 0); rt_kprintf("MQTT上报：%s\r\n", payload); rt_thread_mdelay(5000); } }5.5 MQTT 订阅接收云端指令
实现云端下发指令，控制板载 LED 开关：
- 订阅指令主题
- 收到消息解析 JSON
- 调用 PIN 驱动翻转 LED 电平
六、工程完整业务架构（终极整合）
AHT10采集线程 → 消息队列 → 本地文件存储(FatFS) → MQTT云端上报(LwIP) 云端指令 → MQTT订阅 → 消息解析 → 控制LED/继电器外设 日志全程输出 → ulog分级打印一套架构 = 标准商用物联网终端模板。
七、FinSH 网络排错必用命令
ifconfig # 看IP网卡 ping # 测网络连通 mqtt status # 查看连接状态 list_netdev # 查看网络设备八、本节课避坑总结
- 必须先 WiFi 联网拿到 IP，再跑 MQTT
- MQTT 设备 ID 全网唯一，防止冲突掉线
- 网络线程加心跳 + 自动重连，断网自动恢复
- 高频上报数据一定要加缓冲区，防网络阻塞
- JSON 报文严格格式，云端解析报错大多是符号问题
九、课后作业
- 对接公共免费 MQTT 服务器，实现跨网上报
- 云端下发指令，控制 OLED 切换显示界面
- 断网缓存：离线数据存 Flash，联网后补传
下一课最终章预告
第 9 课时：综合终极项目：全屋环境监测物联网终端（全程整合调试 + 优化 + 低功耗）把前面 8 节课所有知识点，合成一个可直接落地、可烧录量产的完整项目。