1. 从一块DHT11到MQTT Broker这套链路到底在解决什么问题很多人第一次接触温湿度传感器脑子里想的都是接上线、读个数这么简单。但真到动手的时候问题就来了DHT11读出来的数据怎么传到电脑上怎么传到手机上怎么让远在另一个房间的设备也能看到这时候你会发现单纯一个传感器是孤岛它只会老老实实地把温湿度值输出到一根数据线上剩下的全靠你自己想办法。我这次要聊的就是把一块WiFi温湿度传感器从裸数据变成可订阅的MQTT消息的完整过程。核心链路其实就三段传感器采集 → WiFi模块联网 → MQTT协议上报。听起来简单但每一段都有坑尤其是2.4GHz频段和MQTT接入这两个环节新手翻车的概率极高。先说清楚适用人群。如果你手里有ESP8266、ESP32这类带WiFi的模组或者买的是成品WiFi温湿度传感器比如某些支持MQTT直连的型号这篇文章能帮你把配置流程走通。如果你用的是DHT11这种经典传感器配一个独立的WiFi模块同样适用。前提是你得有一个能用的MQTT Broker本地搭建或者用公共测试服务器都行。为什么非要走MQTT直接用HTTP POST不行吗行但MQTT更适合传感器场景。HTTP是请求-响应模式每次上报都要建立连接、发请求、等响应开销大MQTT是发布-订阅模式设备连上Broker之后保持长连接有数据就发没数据就静默功耗和流量都低得多。而且MQTT支持一对多分发一个传感器发布多个客户端订阅天然适合多端查看的场景。注意本文只讨论2.4GHz频段的WiFi配置。5GHz频段虽然速度快但绝大多数低成本WiFi模组包括ESP8266根本不支持5GHz这是硬件层面的限制不是配置能解决的。2. 2.4GHz频段配置为什么你的设备死活连不上WiFi2.1 频段不匹配是最常见的连不上原因我见过太多人拿着ESP8266在那折腾半天密码输了一遍又一遍就是连不上。最后发现路由器开的是5GHz频段设备压根搜不到。这不是设备坏了是物理层不兼容。WiFi频段分2.4GHz和5GHz两个大类。2.4GHz的频率范围是2.400GHz到2.497GHz5GHz是5.15GHz到5.85GHz。ESP8266、ESP32部分型号支持5GHz但价格高、以及市面上大多数廉价WiFi模块射频前端只支持2.4GHz。你路由器如果只开了5GHz设备扫描的时候根本看不到这个SSID。解决办法很简单进路由器管理后台把2.4GHz频段打开。现在很多路由器是双频合一也就是2.4G和5G用同一个SSID设备会自动选择。但问题在于有些廉价WiFi模块在双频合一的环境下会犯迷糊它可能尝试连5GHz然后失败又不会自动回退到2.4GHz。所以我的建议是把2.4GHz和5GHz的SSID分开设置比如HomeWiFi_2.4G和HomeWiFi_5G让传感器明确连2.4G那个。2.2 信道选择别挤在1、6、11之外的地方2.4GHz频段一共有14个信道但真正不重叠的只有1、6、11这三个。如果你路由器设的是其他信道比如3、8、13虽然设备也能连但干扰会明显增大。尤其是在公寓楼里周围几十个WiFi信号挤在一起信道选不好丢包率能高到让你怀疑人生。我一般建议把路由器2.4GHz信道固定在1、6或11。怎么选用手机装个WiFi分析仪看看周围哪个信道最空。如果实在懒得分析默认选6大多数情况下够用。还有一个容易被忽略的点信道带宽。2.4GHz支持20MHz和40MHz两种带宽。40MHz理论上速度快一倍但在拥挤环境下反而更容易受干扰。传感器这种低速率应用20MHz完全够用稳定性优先。2.3 加密方式与密码的特殊字符WiFi加密方式主要有WPA2-PSK、WPA3-PSK、WPA/WPA2混合这几种。ESP8266的固件对WPA3支持有限如果你路由器设的是WPA3 only设备可能连不上。稳妥的做法是设成WPA2-PSKAES兼容性最好。密码方面尽量避免特殊字符。虽然理论上WPA2支持各种符号但有些WiFi模块的固件在处理$、#、这类字符时会有bug导致握手失败。我一般建议密码只用大小写字母和数字长度12位以上既安全又不会踩坑。另外如果你路由器开了MAC地址过滤记得把传感器的MAC地址加白名单。ESP8266的MAC地址通常印在模块背面或者你可以先连一次串口启动日志里会打印出来。2.4 实测用串口日志定位连接失败的原因光说理论没用我拿一块ESP8266DHT11的板子实测一遍。烧录好固件之后打开串口监视器波特率115200你会看到类似这样的输出Connecting to WiFi... ..... WiFi connect failed, status: 1这里的status码很关键。ESP8266的WiFi.status()返回值含义如下状态码含义常见原因0WL_IDLE_STATUS正在切换状态正常中间态1WL_NO_SSID_AVAIL找不到指定SSID2WL_SCAN_COMPLETED扫描完成3WL_CONNECTED连接成功4WL_CONNECT_FAILED连接失败5WL_CONNECTION_LOST连接丢失6WL_DISCONNECTED已断开如果看到status 1先检查SSID是不是2.4G的再检查路由器有没有隐藏SSID。如果看到status 4八成是密码错了或者加密方式设成了WPA3。提示有些路由器默认开启了AP隔离或客户端隔离这会导致设备连上WiFi但无法与局域网内其他设备通信。如果你发现传感器连上了但MQTT连不上先把这个功能关掉。3. MQTT接入实操从Broker搭建到主题设计3.1 先搞清楚MQTT的基本模型MQTT的核心概念就三个Broker代理服务器、Publisher发布者、Subscriber订阅者。传感器是Publisher它把温湿度数据发布到一个叫主题的地址上你的手机、电脑是Subscriber订阅这个主题就能收到数据。Broker是中间人负责转发消息。主题Topic是分层级的用斜杠分隔比如home/bedroom/temperature。发布者往这个主题发消息订阅者订阅home/bedroom/#就能收到所有子主题的消息。#是通配符匹配多层是单层通配符比如home//temperature能匹配home/bedroom/temperature和home/livingroom/temperature。QoS服务质量有三个等级0表示最多发一次可能丢1表示至少发一次可能重复2表示恰好发一次开销最大。传感器数据用QoS 0或1就够了QoS 2没必要。3.2 本地搭建一个MQTT BrokerMosquitto最省事公共MQTT测试服务器比如test.mosquitto.org能用但不稳定而且数据是公开的。自己搭一个更靠谱。Windows和Linux都能装Mosquitto我分别说一下。Windows下安装Mosquitto去Mosquitto官网下载安装包一路下一步。安装完之后默认配置文件在C:\Program Files\mosquitto\mosquitto.conf。默认配置只监听本地回环地址也就是只有本机能连。要让局域网内其他设备连上需要改两处listener 1883 0.0.0.0 allow_anonymous true第一行让Broker监听所有网卡的1883端口第二行允许匿名连接。生产环境当然要设密码但测试阶段先跑通再说。改完配置之后用命令行启动mosquitto -c C:\Program Files\mosquitto\mosquitto.conf -v-v参数会打印详细日志方便调试。启动成功的话你会看到类似Opening ipv4 listen socket on port 1883的输出。Linux下安装MosquittoUbuntu/Debian系直接aptsudo apt update sudo apt install mosquitto mosquitto-clients安装完之后Mosquitto默认就启动了监听1883端口。配置文件在/etc/mosquitto/mosquitto.conf。同样要允许局域网访问需要加listener 1883 0.0.0.0 allow_anonymous true然后重启服务sudo systemctl restart mosquitto验证Broker是否正常工作开两个终端。第一个终端订阅一个主题mosquitto_sub -h localhost -t test/topic -v第二个终端往同一个主题发消息mosquitto_pub -h localhost -t test/topic -m hello如果第一个终端打印出test/topic hello说明Broker工作正常。3.3 主题设计别等设备多了再改主题设计是个容易被忽视但很重要的事。我见过有人把所有传感器都往temperature一个主题上发结果三个房间的温度混在一起根本分不清哪个是哪个。正确的做法是按位置和类型分层home/floor1/bedroom/temperature home/floor1/bedroom/humidity home/floor1/livingroom/temperature home/floor1/livingroom/humidity这样订阅的时候home/floor1//temperature能拿到所有房间的温度home/floor1/bedroom/#能拿到卧室的所有数据。扩展性也好以后加设备直接往对应层级加就行。还有一点主题名不要用中文。虽然MQTT协议本身支持UTF-8但有些客户端和Broker对中文主题的处理不一致容易出问题。用英文或拼音稳妥。3.4 传感器端代码以ESP8266为例我用Arduino IDE写一个最小可用的示例。需要装两个库DHT sensor library和PubSubClient。前者读DHT11后者做MQTT通信。#include ESP8266WiFi.h #include PubSubClient.h #include DHT.h #define DHTPIN D4 #define DHTTYPE DHT11 const char* ssid HomeWiFi_2.4G; const char* password yourpassword; const char* mqtt_server 192.168.1.100; const int mqtt_port 1883; const char* topic_temp home/floor1/bedroom/temperature; const char* topic_humi home/floor1/bedroom/humidity; WiFiClient espClient; PubSubClient client(espClient); DHT dht(DHTPIN, DHTTYPE); void setup_wifi() { delay(10); WiFi.begin(ssid, password); while (WiFi.status() ! WL_CONNECTED) { delay(500); } } void reconnect() { while (!client.connected()) { if (client.connect(ESP8266Client)) { // 连接成功 } else { delay(5000); } } } void setup() { dht.begin(); setup_wifi(); client.setServer(mqtt_server, mqtt_port); } void loop() { if (!client.connected()) { reconnect(); } client.loop(); float t dht.readTemperature(); float h dht.readHumidity(); if (!isnan(t) !isnan(h)) { char tempStr[8]; char humiStr[8]; dtostrf(t, 4, 1, tempStr); dtostrf(h, 4, 1, humiStr); client.publish(topic_temp, tempStr); client.publish(topic_humi, humiStr); } delay(10000); }这段代码有几个关键点。setup_wifi()里没有超时处理实际用的时候建议加个计数器连不上就重启避免死循环。reconnect()里client.connect()的参数是Client ID同一个Broker上Client ID不能重复否则会互相踢下线。如果你有多块板子Client ID要加后缀区分。dtostrf是把浮点数转成字符串DHT11的精度是整数但DHT22是小数所以统一按浮点处理。delay(10000)是10秒上报一次DHT11的采样周期不能低于1秒10秒很安全。3.5 订阅端验证用mosquitto_sub看数据板子烧录好之后在电脑上订阅mosquitto_sub -h 192.168.1.100 -t home/floor1/bedroom/# -v正常的话每10秒会打印两行home/floor1/bedroom/temperature 25.3 home/floor1/bedroom/humidity 58.0如果只看到一行或者什么都没有检查主题名是否拼写一致大小写敏感。4. 踩坑实录那些让我熬夜排查的典型故障4.1 连上WiFi但MQTT频繁掉线这个坑我踩过不止一次。现象是传感器能连上WiFiMQTT也能连上但过几分钟就掉线然后自动重连循环往复。排查了半天最后发现是路由器的问题。有些路由器会定期清理空闲客户端而MQTT的长连接在路由器看来就是空闲的。解决办法有两个一是把MQTT的Keep Alive时间设短一点让设备定期发心跳包二是在路由器里把传感器的MAC地址加入静态DHCP或永不踢出列表。PubSubClient默认的Keep Alive是15秒可以在client.connect()的时候指定client.connect(ESP8266Client, NULL, NULL, NULL, NULL, NULL, NULL, NULL, true);最后一个参数是cleanSession设为false可以让Broker保留会话重连之后不用重新订阅。但Keep Alive时间是在PubSubClient的构造函数里设的默认15秒一般够用。4.2 DHT11读数为NaNDHT11读不出来isnan(t)返回true。原因通常有三个接线不对、供电不足、采样太快。DHT11有三根线VCC、DATA、GND。DATA线需要接一个4.7kΩ到10kΩ的上拉电阻很多模块自带了但如果你用的是裸传感器必须自己加。供电方面DHT11工作电压是3.3V到5.5VESP8266的3.3V输出如果电流不够也会导致读数失败。可以试试从外部电源单独给DHT11供电。采样太快也是常见问题。DHT11的 datasheet 明确写了采样周期不低于1秒但有些人放在loop()里不加延时每秒读几十次结果就是NaN。加个delay(2000)以上问题基本解决。4.3 MQTT连接返回码5Not Authorized如果你给Broker设了密码但设备端没填对client.connect()会返回5。PubSubClient的connect()有多个重载版本带用户名密码的版本是这样的client.connect(ESP8266Client, username, password);注意如果你的Broker配置了allow_anonymous false但设备端没传用户名密码也会返回5。检查Mosquitto的配置文件确认allow_anonymous和password_file的设置是否匹配。4.4 局域网内其他设备连不上Broker传感器能连上但手机连不上。最常见的原因是Windows防火墙。Mosquitto安装的时候Windows会弹窗问是否允许通过防火墙如果你点了取消那局域网访问就被挡了。解决办法进Windows防火墙的入站规则找到Mosquitto相关的规则确保是允许。如果没有手动加一条允许TCP 1883端口入站。Linux下则是iptables或ufw的问题。Ubuntu默认的ufw如果开了需要放行1883sudo ufw allow 18834.5 主题订阅收不到消息但发布显示成功这个坑很隐蔽。client.publish()返回true只代表消息成功交给了ESP8266的TCP栈不代表Broker收到了。如果WiFi信号弱TCP重传失败消息就丢了。排查方法在Broker端开日志看有没有收到PUBLISH包。Mosquitto启动时加-v参数会打印所有消息。如果Broker日志里没有那就是网络问题如果有但订阅端没收到那就是主题匹配问题。还有一种可能订阅端用了QoS 1但发布端用了QoS 0某些Broker实现下会导致消息不投递。统一QoS等级能避免这个问题。5. 从能用到好用稳定性与扩展性的几个改进方向5.1 断线重连要加退避策略上面示例代码里的reconnect()是每5秒重试一次简单但不够优雅。如果Broker挂了所有设备每5秒同时重连会造成惊群效应。更好的做法是加指数退避void reconnect() { int retryDelay 1000; while (!client.connected()) { if (client.connect(ESP8266Client)) { retryDelay 1000; } else { delay(retryDelay); retryDelay min(retryDelay * 2, 30000); } } }这样第一次等1秒第二次2秒第三次4秒最多等30秒。Broker恢复之后设备不会一窝蜂涌上来。5.2 数据持久化别让历史数据白白丢掉MQTT本身不存历史数据消息转发完就没了。如果你想看温度曲线需要额外做持久化。最简单的办法是在订阅端把数据写进数据库。用Python的paho-mqtt库订阅然后写SQLiteimport paho.mqtt.client as mqtt import sqlite3 import json conn sqlite3.connect(sensor.db) c conn.cursor() c.execute(CREATE TABLE IF NOT EXISTS readings (timestamp DATETIME DEFAULT CURRENT_TIMESTAMP, topic TEXT, value REAL)) def on_message(client, userdata, msg): value float(msg.payload.decode()) c.execute(INSERT INTO readings (topic, value) VALUES (?, ?), (msg.topic, value)) conn.commit() client mqtt.Client() client.on_message on_message client.connect(192.168.1.100, 1883, 60) client.subscribe(home/floor1/bedroom/#) client.loop_forever()这样每一条消息都会落库后面用Grafana或者自己写个网页就能画曲线。5.3 多传感器统一管理主题规范要提前定如果你有多个房间、多种传感器主题规范一定要提前定好。我推荐的结构是{位置}/{设备类型}/{指标}比如bedroom/dht11/temperature、livingroom/dht22/humidity。这样订阅的时候/dht11/temperature能拿到所有DHT11的温度bedroom/#能拿到卧室所有数据。设备端Client ID也要规范建议用{位置}-{设备类型}-{MAC后四位}比如bedroom-dht11-a3f2。这样在Broker的日志里一眼就能看出是哪个设备。5.4 安全加固从匿名到认证测试阶段用匿名连接没问题但正式用的时候一定要加认证。Mosquitto支持用户名密码认证配置方法sudo mosquitto_passwd -c /etc/mosquitto/passwd myuser然后改配置文件allow_anonymous false password_file /etc/mosquitto/passwd设备端连接的时候带上用户名密码client.connect(ESP8266Client, myuser, mypassword);如果数据敏感还可以上TLS加密。但ESP8266做TLS握手比较吃力内存占用高一般家用场景用用户名密码就够了。5.5 固件OTA别为了改一行代码去拔插设备设备装到墙上之后再想改代码就麻烦了。ESP8266支持OTAOver-The-Air升级也就是通过WiFi刷固件。Arduino IDE里有个ArduinoOTA库基本用法#include ArduinoOTA.h void setup() { // ... WiFi连接代码 ... ArduinoOTA.begin(); } void loop() { ArduinoOTA.handle(); // ... 其他代码 ... }烧录一次带OTA的固件之后以后就可以在Arduino IDE里直接选网络端口上传不用再插USB线。注意OTA和MQTT的loop()要协调好别让OTA阻塞太久导致MQTT掉线。6. 几个容易被忽略的细节和我的个人习惯DHT11的精度是±2°C和±5%RH说实话不太准。如果你对精度有要求建议换DHT22或者SHT30。SHT30是I2C接口比DHT系列稳定得多价格也就贵几块钱。我现在的方案是SHT30配ESP32走I2C读数从来没出过NaN。MQTT Broker的选型上Mosquitto适合家用和小型部署EMQX适合大规模场景。如果你只是几个传感器Mosquitto足够了资源占用低配置简单。EMQX功能多但吃内存树莓派上跑有点吃力。还有一点别把Broker暴露到公网。我见过有人直接把1883端口映射到外网结果被扫到之后疯狂发垃圾消息。如果确实需要外网访问用MQTT over WebSocket或者加一层反向代理至少上个TLS。最后说个实操习惯我每次改完配置都会先用mosquitto_sub和mosquitto_pub在本地验证一遍确认Broker没问题再去调设备端。这样能把问题范围缩小不至于设备、网络、Broker三头一起查效率高很多。