通过 NodeMCU (ESP8266) 将传感器数据上传至 MQTT 云服务

通过 NodeMCU (ESP8266) 将传感器数据上传至 MQTT 云服务

本示例将演示如何通过 基于 ESP8266 的 NodeMCU，把通过 DHT11 传感器搜集到的温、湿度数据通过 MQTT 协议将其上报到云端的 MQTT 服务，并且展示应用端如何订阅到这些数据并对之进行处理的过程。本文使用 MQTT 协议的原因在于该协议比较轻量级，节约能耗，非常适合于物联网的相关使用场景；目前各大公有云云提供商基本上都开放了基于 MQTT 协议的 IoT Hub 服务。比如 AWS 的 IoT Core，以及 Azure 的 IoT Hub 等，通过 MQTT 协议可以非常方便的将这些数据直接接入这些公有云服务。

本示例的总体架构如下

配置

硬件配置

NodeMCU board x 1：NodeMCU 是一个开源的 IoT （硬件）开发平台，NodeMCU 包含了可以运行在 ESP8266 Wi-Fi SoC芯片之上的固件,以及基于 ESP-12 模组的硬件。“NodeMCU” 缺省一般指的是固件，而不是开发套件。固件使用 Lua 脚本语言。DHT11 temperature/humidity sensor x 1：DHT11 数字温湿度传感器是一款含有已校准数字信号输出的温湿度复合传感器面包板（Breadboard ）x 1跳线（Jumper wires）若干连接图（Connection Graph）请参考如下截图

Arduino 配置

下载并安装​​CH340G USB​​ 驱动安装 ESP8266模块安装 PubSubClient 库 (by Nick O'Leary) Sketch -> Include Library -> Manage Libraries... -> Type PubSub in Search field -> Install

MQTT 云服务配置

在本文中我们选用由 EMQX Cloud​ 提供的公共 MQTT Broker 服务作为 broker 接入地址，broker 接入信息如下:

Broker:broker.emqx.ioTCP Port:1883Websocket Port:8083

ESP8266 代码编写

首先我们将导入ESP8266WiFi和PubSubClient库，ESP8266WiFi 库能够将 ESP8266 连接到 Wi-Fi 网络，PubSubClient 库能使 ESP8266 连接到 MQTT 服务器发布消息及订阅主题。

#include #include #include #include "DHT.h"

设置 Wi-Fi 名称和密码，以及 MQTT 服务器连接地址和端口

// WiFiconst char *ssid = "mousse"; // Enter your WiFi nameconst char *password = "qweqweqwe"; // Enter WiFi passwordconst char *mqtt_broker = "broker.emqx.io";const char *topic = "temp_hum/emqx";const char *mqtt_username = "emqx";const char *mqtt_password = "public";const int mqtt_port = 1883;

打开一个串行连接，以便于输出程序的结果并且连接到 Wi-Fi 网络

// Set software serial baud to 115200;Serial.begin(115200);// connecting to a WiFi networkWiFi.begin(ssid, password);while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.println("Connecting to WiFi..");}

设置 MQTT Broker 信息

//connecting to a mqtt brokerclient.setServer(mqtt_broker, mqtt_port);client.setCallback(callback);//connecting to a mqtt brokerwhile (!client.connected()) { String client_id = "esp8266-client-"; client_id += String(WiFi.macAddress()); Serial.printf("The client %s connects to the public mqtt broker\n", client_id.c_str()); if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) { Serial.println("Public emqx mqtt broker connected"); } else { Serial.print("failed with state "); Serial.print(client.state()); delay(2000); }}

MQTT 服务器连接成功后初始化温湿度传感器

dht.begin();

读取温湿度传感器数据以 json 格式上报数据

float temp = dht.readTemperature();float hum = dht.readHumidity();// json serializeDynamicJsonDocument data(256);data["temp"] = temp;data["hum"] = hum;// publish temperature and humiditychar json_string[256];serializeJson(data, json_string);// {"temp":23.5,"hum":55}Serial.println(json_string);client.publish(topic, json_string, false);

完整代码```c #include #include #include #include "DHT.h"// WiFi const charssid = "mousse"; // Enter your WiFi name const char password = "qweqweqwe"; // Enter WiFi password// MQTT Broker const charmqtt_broker = "broker.emqx.io"; const char topic = "temp_hum/emqx"; const charmqtt_username = "emqx"; const char mqtt_password = "public"; const int mqtt_port = 1883;// DHT11 #define DHTPIN D4 #define DHTTYPE DHT11 // DHT 11 unsigned long previousMillis = 0;WiFiClient espClient; PubSubClient client(espClient); DHT dht(DHTPIN, DHTTYPE);void setup() {

// Set software serial baud to 115200;Serial.begin(115200);// connecting to a WiFi networkWiFi.begin(ssid, password);while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.println("Connecting to WiFi..");}Serial.println("Connected to the WiFi network");//connecting to a mqtt brokerclient.setServer(mqtt_broker, mqtt_port);client.setCallback(callback);//connecting to a mqtt brokerwhile (!client.connected()) { String client_id = "esp8266-client-"; client_id += String(WiFi.macAddress()); Serial.printf("The client %s connects to the public mqtt broker\n", client_id.c_str()); if (client.connect(client_id.c_str(), mqtt_username, mqtt_password)) { Serial.println("Public emqx mqtt broker connected"); } else { Serial.print("failed with state "); Serial.print(client.state()); delay(2000); }}// dht11 begindht.begin();

}

void loop() { client.loop(); unsigned long currentMillis = millis(); // temperature and humidity data are publish every five second if (currentMillis - previousMillis >= 5000) { previousMillis = currentMillis; float temp = dht.readTemperature(); float hum = dht.readHumidity(); // json serialize DynamicJsonDocument data(256); data["temp"] = temp; data["hum"] = hum; // publish temperature and humidity char json_string[256]; serializeJson(data, json_string); // {"temp":23.5,"hum":55} Serial.println(json_string); client.publish(topic, json_string, false); } }

### 运行测试1. 请使用 [Arduino IDE](将完整代码上传到 ESP8266，并打开串口监视器 ![esp_con.png](建立 MQTT X 客户端 与 MQTT 服务器的连接, 并测试温湿度数据接收 ![mqttx_sub.png](使用 Python 客户端订阅温湿度数据 ```python # python 3.x import random from paho.mqtt import client as mqtt_client BROKER = 'broker.emqx.io' PORT = 1883 TOPIC = "temp_hum/emqx" # generate client ID with pub prefix randomly CLIENT_ID = "python-mqtt-tcp-sub-{id}".format(id=random.randint(0, 1000)) USERNAME = 'emqx' PASSWORD = 'public' def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected to MQTT Broker!") client.subscribe(TOPIC) else: print("Failed to connect, return code {rc}".format(rc=rc), ) def on_message(client, userdata, msg): print("Received `{payload}` from `{topic}` topic".format( payload=msg.payload.decode(), topic=msg.topic)) def connect_mqtt(): client = mqtt_client.Client(CLIENT_ID) client.username_pw_set(USERNAME, PASSWORD) client.on_connect = on_connect client.on_message = on_message client.connect(BROKER, PORT) return client def run(): client = connect_mqtt() client.loop_forever() if __name__ == '__main__': run()

总结

至此为止，完成了从 NodeMCU 采集数据，并上传到 EMQ 提供的 MQTT 云服务，最后由 Python 写的后端程序对数据进行处理的简单过程。但在实际的生产应用中，会需要更高的要求，比如，

更加安全的连接方式对物联网数据进行实时处理对数据进行持久化更大规模的连接要求

EMQX 企业版​，及其物联网 MQTT 云服务在解决上述问题已经提供了很好的解决方案，有兴趣的读者可以参考相关链接了解更多的信息。

为了实现数据的高安全性（避免上传到云端），降低业务处理时延，以及数据传输成本，在解决方案中可以考虑采用边缘计算。Azure IoT Edge 和 AWS 的 Greengrass 提供了在边缘端的解决方案。EMQ 也提供了开源的超轻量级边缘物联网实时数据分析 (IoT Edge streaming analytics) 方案 ​​Kuiper​​。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。