Mqtt连接mCotton - 版本历史

2018年11月23日 (五) 10:24 502748957@qq.com

2018-11-23T10:24:31Z

2018年5月14日 (一) 07:41 Radiumray9@gmail.com

2018-05-14T07:41:49Z

Radiumray9@gmail.com：创建页面，内容为“{| style="width: 800px;" |- |
'''HTTPGET'''

描述
本示例会实现…”

2018-05-14T07:41:09Z

创建页面，内容为“{| style="width: 800px;" |- | '''HTTPGET''' 描述 本示例会实现…”

新页面

{| style="width: 800px;"
|-
|
'''HTTPGET'''
 
描述
本示例会实现一个用mqtt连接mCotton的例子
 
需要调用<code style="color: #E87E05">#include <ESP8266.h></code>头文件。
 
所用方法
*wifi.mqttSetServer(MQTTSERVER, MQTT_PORT)设置mqtt服务器
*wifi.mqttConnect(ID, USER, PASS)连接mqtt服务器
*wifi.getMqttJson()获取mqtt服务器下发数据
*wifi.mqttSetDiveceIDToken(ID, PASS)设置diveceID和Token
*wifi.mqttSetSubscrib(SUBSCRIBTOPIC)设置订阅
*wifi.mqttPublish(PUBLISHTOPIC, jsonData)发布消息
*wifi.mqttPublishM(jsonData)简短方法发布消息

实例
*
<source lang="c++">
#include <ESP8266.h>
#include <aJSON.h>

#ifdef ESP32
#error "This code is not recommended to run on the ESP32 platform! Please check your Tools->Board setting."
#endif

/**
**CoreUSB UART Port: [Serial1] [D0,D1]
**Core+ UART Port: [Serial1] [D2,D3]
**/
#if defined(__AVR_ATmega32U4__) || defined(__AVR_ATmega1284P__) || defined (__AVR_ATmega644P__) || defined(__AVR_ATmega128RFA1__)
#define EspSerial Serial1
#define UARTSPEED 115200
#endif

/**
**Core UART Port: [SoftSerial] [D2,D3]
**/
#if defined (__AVR_ATmega168__) || defined (__AVR_ATmega328__) || defined (__AVR_ATmega328P__)
#include <SoftwareSerial.h>
SoftwareSerial mySerial(2, 3); /* RX:D2, TX:D3 */

#define EspSerial mySerial
#define UARTSPEED 9600
#endif

#define SSID "your ssid"
#define PASSWORD "your password"
#define MQTTSERVER "mCotton.microduino.cn"
#define ID "your divice id"
#define USER "your divice id"
#define PASS "your divice token"
#define SUBSCRIBTOPIC "ca/your divice id"
#define SUBSCRIBTOPICP "cp/your divice id"
#define PUBLISHTOPIC "dp/your divice id"
#define MQTT_PORT (1883)

static const uint8_t stateLEDPin=4;

#define INTERVAL_sensor 2000
unsigned long sensorlastTime = millis();

float tempOLED, humiOLED, lightnessOLED, gasOLED;

String mCottenData;
String jsonData;

ESP8266 wifi(&EspSerial);

void setup(void) {
Serial.begin(115200);

pinMode(stateLEDPin,OUTPUT);
digitalWrite(stateLEDPin,LOW);

while (!Serial); // wait for Leonardo enumeration, others continue immediately
Serial.print(F("setup begin\r\n"));
delay(100);

WifiInit(EspSerial, UARTSPEED);

Serial.print(F("FW Microduino Version:"));
Serial.println(wifi.getMVersion().c_str());

// if (wifi.setUart(57600)) {
// Serial.print(F("set uart ok\r\n"));
// } else {
// Serial.print(F("set uart err\r\n"));
// }

if (wifi.setOprToStation()) {
Serial.print(F("to station ok\r\n"));
} else {
Serial.print(F("to station err\r\n"));
}

// wifi.setAutoConnect(false);
// wifi.restart();

if (wifi.joinAP(SSID, PASSWORD)) {
wifi.setWiFiconnected(true);
Serial.print(F("Join AP success\r\n"));
Serial.print(F("IP:"));
Serial.println(wifi.getMLocalIP().c_str());
} else {
wifi.setWiFiconnected(false);
Serial.print(F("Join AP failure\r\n"));
Serial.print(F("Make sure your SSID, PASS correctly!\r\n"));
while (true) {
mCottenData = wifi.getMqttJson();
if (mCottenData != "") {
mCottenData.trim();
Serial.println(mCottenData);
}
}
}

if (wifi.mqttSetServer(MQTTSERVER, MQTT_PORT)) {
Serial.print(F("mqtt set server ok\r\n"));
} else {
Serial.print(F("mqtt set server err\r\n"));
}
if (wifi.mqttConnect(ID, USER, PASS)) {
wifi.setMqttConnected(true);
digitalWrite(stateLEDPin,HIGH);
Serial.print(F("mqtt connect ok\r\n"));
} else {
wifi.setMqttConnected(false);
Serial.print(F("mqtt connect err\r\n"));
while (true) {
mCottenData = wifi.getMqttJson();
if (mCottenData != "") {
mCottenData.trim();
Serial.println(mCottenData);
}
}
}
if (wifi.mqttSetDiveceIDToken(ID, PASS)) {
Serial.print(F("mqtt set device ID Token ok\r\n"));
} else {
Serial.print(F("mqtt set device ID Token err\r\n"));
}
if (wifi.mqttSetSubscrib(SUBSCRIBTOPIC)) {
Serial.print(F("mqtt set subscrib ca topic ok\r\n"));
} else {
Serial.print(F("mqtt set subscrib ca topic err\r\n"));
}
if (wifi.mqttSetSubscrib(SUBSCRIBTOPICP)) {
Serial.print(F("mqtt set subscrib cp topic ok\r\n"));
} else {
Serial.print(F("mqtt set subscrib cp topic err\r\n"));
}

jsonData = "{\"Humidity\":66.66}";
if (wifi.mqttPublish(PUBLISHTOPIC, jsonData)) {
Serial.print(F("mqtt publish ok\r\n"));
} else {
Serial.print(F("mqtt publish err\r\n"));
}

}

void loop(void) {

mCottenData = wifi.getMqttJson();

if (mCottenData != "") {
mCottenData.trim();

Serial.println(mCottenData);

if (mCottenData.equals("WIFI DISCONNECT")) {
wifi.setWiFiconnected(false);
wifi.setMqttConnected(false);
digitalWrite(stateLEDPin,LOW);
} else if (mCottenData.equals("WIFI Connected")) {
wifi.setWiFiconnected(true);
} else if (mCottenData.equals("MQTT: Disconnected")) {
wifi.setMqttConnected(false);
digitalWrite(stateLEDPin,LOW);
} else if (mCottenData.equals("MQTT: Connected")) {
if (wifi.mqttSetDiveceIDToken(ID, PASS)) {
Serial.print(F("mqtt set device ID Token ok\r\n"));
} else {
Serial.print(F("mqtt set device ID Token err\r\n"));
}
if (wifi.mqttSetSubscrib(SUBSCRIBTOPIC)) {
Serial.print(F("mqtt set subscrib ca topic ok\r\n"));
} else {
Serial.print(F("mqtt set subscrib ca topic err\r\n"));
}
if (wifi.mqttSetSubscrib(SUBSCRIBTOPICP)) {
Serial.print(F("mqtt set subscrib cp topic ok\r\n"));
} else {
Serial.print(F("mqtt set subscrib cp topic err\r\n"));
}
wifi.setMqttConnected(true);
digitalWrite(stateLEDPin,HIGH);
}

if (!wifi.isWiFiconnected()) {
return;
}

if (wifi.isMqttConnected()) {
if (mCottenData.startsWith("{") && mCottenData.endsWith("}")) {

uint8_t length = mCottenData.length();
char buf[length + 1];
mCottenData.toCharArray(buf, length + 1);

aJsonObject* root = aJson.parse(buf);
aJsonObject* state = aJson.getObjectItem(root, "undefined");

if (strcmp(state->valuestring, "true") == 0) {
Serial.println(F("ON"));
}
if (strcmp(state->valuestring, "false") == 0) {
Serial.println(F("OFF"));
}
}
}
}

if (wifi.isMqttConnected()) {
if (sensorlastTime > millis())
sensorlastTime = millis();
if (millis() - sensorlastTime > INTERVAL_sensor) {

float temp = map(analogRead(A2), 0, 1023, 0, 255);
float humi = map(analogRead(A1), 0, 1023, 0, 255);
float lightness = map(analogRead(A0), 0, 1023, 0, 255);
tempOLED = temp;
humiOLED = humi;
lightnessOLED = lightness;
jsonData = "{\"Humidity\":";
jsonData += String(humi);
jsonData += ",\"Temperature\":";
jsonData += String(temp);
jsonData += ",\"Lightness\":";
jsonData += String(lightness);
jsonData += "}";

if (wifi.mqttPublishM(jsonData)) {
Serial.print(F("mqtt publishM ok\r\n"));
} else {
Serial.print(F("mqtt publishM err\r\n"));
}

sensorlastTime = millis();

}
}

}
</source>
|}
 
 
[[MCookie-WiFi/zh|返回mCookie-WiFi界面]]

@@ 第265行： / 第265行： @@
+}
 </source>
 |}
 <br>
 <br>
 <p style="font-size:115%">[[MCookie-WiFi/zh|返回mCookie-WiFi界面]]</p>

@@ 第10行： / 第10行： @@
 <br>
 <p style="color: #E87E05;font-size:135%">所用方法</p>
-*wifi.mqttSetServer(MQTTSERVER, MQTT_PORT)设置mqtt服务器
+*wifi.mqttSetServer(MQTTSERVER, MQTT_PORT)     设置mqtt服务器
-*wifi.mqttConnect(ID, USER, PASS)连接mqtt服务器
+*wifi.mqttConnect(ID, USER, PASS)     连接mqtt服务器
-*wifi.getMqttJson()获取mqtt服务器下发数据
+*wifi.getMqttJson()     获取mqtt服务器下发数据
-*wifi.mqttSetDiveceIDToken(ID, PASS)设置diveceID和Token
+*wifi.mqttSetDiveceIDToken(ID, PASS)     设置diveceID和Token
-*wifi.mqttSetSubscrib(SUBSCRIBTOPIC)设置订阅
+*wifi.mqttSetSubscrib(SUBSCRIBTOPIC)     设置订阅
-*wifi.mqttPublish(PUBLISHTOPIC, jsonData)发布消息
+*wifi.mqttPublish(PUBLISHTOPIC, jsonData)     发布消息
-*wifi.mqttPublishM(jsonData)简短方法发布消息
+*wifi.mqttPublishM(jsonData)     简短方法发布消息
 <p style="color: #E87E05;font-size:135%">实例</p>

Mqtt连接mCotton - 版本历史

2018年11月23日 (五) 10:24 502748957@qq.com

2018年5月14日 (一) 07:41 Radiumray9@gmail.com

Radiumray9@gmail.com：创建页面，内容为“{| style="width: 800px;" |- | '''HTTPGET''' 描述 本示例会实现…”

Radiumray9@gmail.com：创建页面，内容为“{| style="width: 800px;" |- |
'''HTTPGET'''

描述
本示例会实现…”