1. #include <aliIotLink.h>
    2. #include <ESP8266WiFi.h>
    3. #include <ArduinoJson.h>
    4. #include <Wire.h>
    5. #include <Adafruit_BMP085.h>
    7. Adafruit_BMP085 bmp;
    9. const char* ssid = "OCROBOT";
    10. const char* password = "jikegongfang";
    12. String updateAlinkJson(uint16_t _id, JsonObject &_AliIotJson);
    13. void working(uint16_t delayTime);
    15. WiFiClient espClient;   //实例化 wifi网络
    16. PubSubClient client(espClient); //将网络传入MQTT
    17. AliIotLink aliLink(client);  //将mqtt传入服务
    18. bool led_status = 0; //默认是关闭的
    20. //回调函数
    21. void Callbacks(char* topic, byte* payload, unsigned int length)
    22. {
    24.   String LED_topic = "/sys/a1agPKQ3fSf/sensor1/thing/service/property/set";
    25.   if (strcmp(topic, LED_topic.c_str()) == 0)
    26.   {
    27.     StaticJsonBuffer<128> jsonBuffer;
    28.     JsonObject& payloadData =  jsonBuffer.parseObject(payload);
    29.     led_status = payloadData["params"]["led"];  //获取开关设置信息
    30.     digitalWrite(D1,led_status);
    31.     Serial.println(led_status);
    32.   }
    34. }
    35. void setup()
    36. {
    37.   Serial.begin(115200);
    38.   bmp.begin();   //传感器初始化
    39.   pinMode(D1, OUTPUT); //初始化led灯
    41.   WiFi.mode(WIFI_STA);   //配置为客户端模式
    42.   WiFi.begin(ssid, password);  //初始化并且链接wifi
    43.   while (WiFi.status() != WL_CONNECTED) {
    44.     delay(500);
    45.     Serial.print(".");
    46.   }
    48.   //aliLink.subTopic("/sys/a1agPKQ3fSf/sensor1/thing/service/property/set");   //订阅
    49.   //aliLink.subTopic("/sys/a1agPKQ3fSf/sensor1/thing/event/property/set_reply");   //订阅
    50.   //阿里云初始化
    51.   aliLink.setCallback(Callbacks);
    52.   aliLink.begin("sensor1", "a1agPKQ3fSf", "J0lvZSntI0ZYfpqkQ4h40OU7WOxoAYgH"); //完成初始化配置 三元素(DeviceName,ProductKey,DeviceSecret)
    53. }
    54. void loop()
    55. {
    57.   if (aliLink.state() != 0)
    58.   {
    59.     Serial.println(aliLink.state());
    60.   }
    61.   aliLink.loop();
    63.   working(5000); //定时上报业务（15秒一次上报）
    64. }
    66. // 构建Alink协议的要求
    67. String updateAlinkJson(uint16_t _id, JsonObject &_AliIotJson)
    68. {
    69.   StaticJsonBuffer<256> jsonBuffer;
    70.   JsonObject& AlinkJson = jsonBuffer.createObject();
    71.   AlinkJson["id"] = _id;
    72.   AlinkJson["version"] = "1.0";
    73.   AlinkJson["params"] = _AliIotJson;
    74.   //AlinkJson["method"] = "/sys/a1agPKQ3fSf/sensor1/thing/event/property/post";
    75.   AlinkJson["method"] = "thing.event.property.post";
    76.   String JsonStr;
    77.   AlinkJson.printTo(JsonStr);
    78.   return JsonStr;
    79. }
    81. //定时上报传感器数据与状态
    82. void working(uint16_t delayTime)
    83. {
    84.   uint32_t thisTime = millis();
    85.   if ((thisTime % delayTime) == 0)
    86.   {
    87.     StaticJsonBuffer<130> jsonBuffer;
    88.     JsonObject& paramsJson = jsonBuffer.createObject();
    89.     //paramsJson["led"] = led1;
    90.     paramsJson["temperature"] = bmp.readTemperature();
    91.     paramsJson["atmosphere"] = bmp.readPressure();
    92.     String data = updateAlinkJson(random(1, 100), paramsJson);
    94.     char outputTopic[] = "/sys/a1agPKQ3fSf/sensor1/thing/event/property/post" ;
    95.     aliLink.publish(outputTopic, data.c_str());
    96.     //Serial.println(data);
    97.   }
    98. }