1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

/*************************************** Config ********************************************************/
//WiFi 配置
const char* ssid     = "TP-LINK_4252";               //WiFi账号：需要修改为所处环境的WiFi 账号
const char* password = "pp12345678";                 //WiFi密码：秘密需要修改为所处环境的WiFi 密码

//OneNet MQTT 配置
const char*    mqttServer = "183.230.40.39";          //目前 Onenet mqtt服务器 的 ip地址
const uint16_t mqttPort = 6002;                       //目前 Onenet mqtt服务器 的 端口号

//【以下三项更改时请注意保留双引号】
#define PRODUCT_ID    "364161"                        //产品ID，需要更改为你自己创建的产品的 ID     
#define API_KEY       "7GMiWLTMtluwREq1x8SAC9bko0k="  //APIKEY，需要更改为你自己创建的产品的 APIKEY
#define DEVICE_ID     "617424064"                     //APIKEY，需要更改为你自己创建的产品的 设备ID
/******************************************************************************************************/

#define ONENET_DISCONNECTED (1)                       //已经断开
#define ONENET_CONNECTED    (2)                       //已经连接上
#define ONENET_RECONNECT    (3)                       //重连成功

#define TOPIC         "LED"                           //主题

int sta_mqtt_connect;
WiFiClient     espClient;                             //创建一个 WiFi 客户端
PubSubClient   mqttClient;                            //创建一个 mqtt 客户端


//Onenet MQTT 连接
int Onenet_MQTT_Connect(void){
    int cnt = 0;
    while(!mqttClient.connected()){
       cnt++;
       Serial.println("Connect to OneNet MQTT...");
       /* 连接 Onenet 云平台*/
       if (mqttClient.connect(DEVICE_ID,PRODUCT_ID,API_KEY)) {
             Serial.println("rnconnect success!");
             return ONENET_RECONNECT;
        } else {
             Serial.print("Connect Fail!");
             Serial.println("Retry in 5 seconds");
             delay(5000);
        }
        if(cnt >=10){
          cnt = 0;
          Serial.println("Connet Failed");
          Serial.println("Please Check API_KEY and  Device ID,Product ID");
          while(1){
            delay(1);
          }
        }
    }
    return ONENET_CONNECTED;
}

//MQTT 消息回调函数
void callback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message Recive: topic[");
  Serial.print(topic);
  Serial.print("],value: ");
  
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println();

  if ((char)payload[0] == '1') {
    digitalWrite(LED_BUILTIN, LOW);
  }
  else{
    digitalWrite(LED_BUILTIN, HIGH);
  }
}

void setup() {
    //#0. 配置串口
    Serial.begin (115200);
    Serial.println("rnrnESP826(MQTT)Start:  ");
    delay(100);
    //#1. 连接WIFI
    WiFi.begin(ssid, password);
    Serial.print("Wait for WiFi Connect");
    while (WiFi.status() != WL_CONNECTED) {
          static int wait_cnt = 0;
          if(50 <= wait_cnt++){
            Serial.println("rnConnect Fialed");
            Serial.println("Please Check Your WiFi SSID and PWD or");
            Serial.println("Reset the Device and Retry");
            while(1)
            {
              Serial.print("*");
              delay(5000);
            }  
          }
          delay(500);
          Serial.print(".");
    }
    Serial.println(" ");
    
    pinMode(LED_BUILTIN, OUTPUT); 

    //#2. 客户端设置MQTT服务器 & 回调函数
    mqttClient.setServer(mqttServer,mqttPort);
    mqttClient.setClient(espClient);
    mqttClient.setCallback(callback);
}

void loop() {
  //#3.连接 Onenet
  sta_mqtt_connect = Onenet_MQTT_Connect();
  if(sta_mqtt_connect == ONENET_RECONNECT){
    mqttClient.subscribe(TOPIC,1);                          //订阅主题,消息质量 QOS = 1
    mqttClient.loop();
  }
  else if(sta_mqtt_connect == ONENET_CONNECTED){
     mqttClient.loop();
  }
}