MQTT example

Author: Tinyu-Zhao

examples/Advanced/MQTT/MQTT.ino

@@ -0,0 +1,107 @@
+/*
+*******************************************************************************
+* Copyright (c) 2021 by M5Stack
+*                  Equipped with M5Core sample source code
+*                          配套  M5Core 示例源代码
+* Visit the website for more information：https://docs.m5stack.com/en/core/gray
+* 获取更多资料请访问：https://docs.m5stack.com/zh_CN/core/gray
+*
+* describe：MQTT.
+* date：2021/11/5
+*******************************************************************************
+*/
+#include "M5Stack.h"
+#include <WiFi.h>
+#include <PubSubClient.h>
+
+WiFiClient espClient;
+PubSubClient client(espClient);
+
+// Configure the name and password of the connected wifi and your MQTT Serve host.  配置所连接wifi的名称、密码以及你MQTT服务器域名
+const char* ssid = "Explore-F";
+const char* password = "xingchentansuo123";
+const char* mqtt_server = "mqtt.m5stack.com";
+
+unsigned long lastMsg = 0;
+#define MSG_BUFFER_SIZE	(50)
+char msg[MSG_BUFFER_SIZE];
+int value = 0;
+
+void setupWifi();
+void callback(char* topic, byte* payload, unsigned int length);
+void reConnect();
+
+void setup() {
+  M5.begin();
+  M5.Power.begin();
+  setupWifi();
+  client.setServer(mqtt_server, 1883);  //Sets the server details.  配置所连接的服务器
+  client.setCallback(callback); //Sets the message callback function.  设置消息回调函数
+}
+
+void loop() {
+  if (!client.connected()) {
+    reConnect();
+  }
+  client.loop();  //This function is called periodically to allow clients to process incoming messages and maintain connections to the server.
+  //定期调用此函数，以允许主机处理传入消息并保持与服务器的连接
+
+  unsigned long now = millis(); //Obtain the host startup duration.  获取主机开机时长
+  if (now - lastMsg > 2000) {
+    lastMsg = now;
+    ++value;
+    snprintf (msg, MSG_BUFFER_SIZE, "hello world #%ld", value); //Format to the specified string and store it in MSG.  格式化成指定字符串并存入msg中
+    M5.Lcd.print("Publish message: ");
+    M5.Lcd.println(msg);
+    client.publish("M5Stack", msg);  //Publishes a message to the specified topic.  发送一条消息至指定话题
+    if(value%12==0){
+      M5.Lcd.clear();
+      M5.Lcd.setCursor(0,0);
+    }
+  }
+}
+
+void setupWifi() {
+  delay(10);
+  M5.Lcd.printf("Connecting to %s",ssid);
+  WiFi.mode(WIFI_STA);  //Set the mode to WiFi station mode.  设置模式为WIFI站模式
+  WiFi.begin(ssid, password); //Start Wifi connection.  开始wifi连接
+
+  while (WiFi.status() != WL_CONNECTED) {
+    delay(500);
+    M5.Lcd.print(".");
+  }
+  M5.Lcd.printf("\nSuccess\n");
+}
+
+void callback(char* topic, byte* payload, unsigned int length) {
+  M5.Lcd.print("Message arrived [");
+  M5.Lcd.print(topic);
+  M5.Lcd.print("] ");
+  for (int i = 0; i < length; i++) {
+    M5.Lcd.print((char)payload[i]);
+  }
+  M5.Lcd.println();
+}
+
+void reConnect() {
+  while (!client.connected()) {
+    M5.Lcd.print("Attempting MQTT connection...");
+    // Create a random client ID.  创建一个随机的客户端ID
+    String clientId = "M5Stack-";
+    clientId += String(random(0xffff), HEX);
+    // Attempt to connect.  尝试重新连接
+    if (client.connect(clientId.c_str())) {
+      M5.Lcd.printf("\nSuccess\n");
+      // Once connected, publish an announcement to the topic.  一旦连接，发送一条消息至指定话题
+      client.publish("M5Stack", "hello world");
+      // ... and resubscribe.  重新订阅话题
+      client.subscribe("M5Stack");
+    } else {
+      M5.Lcd.print("failed, rc=");
+      M5.Lcd.print(client.state());
+      M5.Lcd.println("try again in 5 seconds");
+      delay(5000);
+    }
+  }
+}

library.json

@@ -10,7 +10,7 @@
     "type": "git",
     "url": "https://github.com/m5stack/m5stack.git"
   },
-  "version": "0.3.6",
+  "version": "0.3.7",
   "framework": "arduino",
   "platforms": "espressif32"
 }

library.properties

@@ -1,5 +1,5 @@
 name=M5Stack
-version=0.3.6
+version=0.3.7
 author=M5Stack
 maintainer=M5Stack
 sentence=Library for M5Stack Core development kit
@@ -8,4 +8,4 @@ category=Device Control
 url=https://github.com/m5stack/m5stack
 architectures=esp32
 includes=M5Stack.h
-depends=M5GFX,UNIT_ENV,UNIT_4RELAY,ADXL345,FastLED,MODULE_GRBL13.2,Adafruit MCP4725,Adafruit TCS34725,Adafruit NeoPixel,MAX30100lib,MFRC522_I2C,M5_BM8563,M5_ADS1100,M5_ADS1115,M5_FPC1020A,HX711 Arduino Library,PCA9554,TinyGPSPlus,Adafruit SGP30 Sensor,FFT,TFTTerminal,ClosedCube TCA9548A,M5GFX,ArduinoJson,M5_EzData
+depends=M5GFX,UNIT_ENV,UNIT_4RELAY,ADXL345,FastLED,MODULE_GRBL13.2,Adafruit MCP4725,Adafruit TCS34725,Adafruit NeoPixel,MAX30100lib,MFRC522_I2C,M5_BM8563,M5_ADS1100,M5_ADS1115,M5_FPC1020A,HX711 Arduino Library,PCA9554,TinyGPSPlus,Adafruit SGP30 Sensor,FFT,TFTTerminal,ClosedCube TCA9548A,M5GFX,ArduinoJson,M5_EzData,PubSubClient