手机、ESP32单片机、MQTT服务器连接实验

# 首先要下载源代码包，目前最高版本是1.6.9
wget http://mosquitto.org/files/source/mosquitto-1.6.9.tar.gz
# 下载后，首先是解压
tar zxfv mosquitto-1.6.9.tar.gz
# 进入解压后的目录
cd mosquitto-1.6.9
# 先编译
make
# 最后安装
make instal

mosquitto -c /etc/mosquitto/mosquitto.conf -d

#include <WiFi.h> //wlan连接库，有很多种，如esp8266.h……等
#include <PubSubClient.h>//发布订阅库，也可以使用mqtt.h
#include "DHT.h" //这是一个读取DHT温湿度仪的库，用这个库能省点事。这个库也有很多种，这是其中一个。

#define DHTPIN 15 //定义15号口为DHT11温湿度仪的控制口。
#define DHTTYPE DHT11 //定义DHT温湿度仪的类型。如DHT11、DHT21、DHT22，这个要根据实际来选。

DHT dht(DHTPIN, DHTTYPE); //构造函数

const char* ssid = "ssid"; //WIFI的ID
const char* password = "password"; //WIFI的PASSWORD
const char* mqtt_server = "*.*.*.*"; // mqtt服务器的地址。
const char* TOPIC = "ledconc"; // 订阅信息主题
const char* client_id = "cid_dnt_led";//设备的客户端编号
char* sh = new char[10]; //定义两个字符串数组，用来存放温湿度的浮点数转换过来的字符串。
char* st = new char[10];

WiFiClient espClient;  // 定义WLAN实例
PubSubClient client(espClient);  // 定义PubSubClient的实例

long lastMsg = 0;     // 记录上一次发送信息的时间。

void setup() {
  dht.begin(); //初始化DHT11温湿度仪。
  pinMode(18, OUTPUT); // 定义18号口连接LED灯，设为输出方式
  //连接WIFI，如果连接不成功，则等待0.5秒后，继续连接。
  delay(10);
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED)
  {
    delay(500);
  }
  //
  client.setServer(mqtt_server, 1883);//设定MQTT服务器与使用的端口
  client.setCallback(leddev); //设定回调程序，当ESP32收到订阅消息时会调用此方法
}

void leddev(char* topic, byte* payload, unsigned int length)
{
  if ((char)payload[0] == ‘1‘)
  {
    digitalWrite(18, HIGH);   // 亮灯
  }
  else
  {
    digitalWrite(18, LOW);   // 熄灯
  }
}

void reconnect() {
  while (!client.connected()) {
    if (client.connect(client_id))
    {
      client.subscribe(TOPIC);
    }
    else
    {
      delay(5000);
    }
  }
}
void loop() {
  if (!client.connected()) //如果MQTT服务器连接不成功，则反复重试，连接成功后重新订阅。
  {
    reconnect();
  }
  delay(2000);
  float h = dht.readHumidity(); //获取温湿度，是float格式 的。 
  float t = dht.readTemperature();
  dtostrf(h, 2, 2, sh); // dtostrf()函数将float格式转换为字符串。
  dtostrf(t, 2, 2, st);
  client.loop();
  long now = millis();
  if (now - lastMsg > 2000)//每过2秒，发送温湿度数据。
  {
    lastMsg = now;
    client.publish("temperature", st);
    client.publish("humidity", sh);
  }
}