esp8266基于贝壳平台的 点亮LED和上传温湿度传感器双向传输实验

1. 首页
2. 讨论
3. ESP8266

这是一个采用esp8266 12f模块做的 在贝壳平台上点亮LED灯  和 用esp8266模块上传AM2320温湿度  的双向实验

使用Arduino IDE 编写的一个实验程序，是用HTTP协义的。

可以用微信公众号控制，也可以用贝壳APP控制，也可以在贝壳网控制

详情请看源码说明  感谢贝壳平台 传输速度快，稳定性高，协义简单。

这是连接贝壳提供的例程  http://github.com/bigiot/bigiotArduino

1：下载下来后解压，打开libraries 把ajson文件夹 复制，粘贴 到你安装arduino的libraries目录下

2：打开解压下来的文件夹 打开examples esp8266  ESP8266wifi control4 然后打开control4.ino

3：粘贴以下的代码替代control4.ino的源码,修改自己wifi帐号密码 和贝壳的设备号和key 

/*
    此文件需安装Arduino esp8266开发环境支持，环境搭建参见：http://www.bigiot.net/talk/237.html
  
  
    
   
  代码进行调整，修复了部分bug，解决了断线重连问题，此代码可以直接烧入到nodemcu模块，分享代码希望对大家有帮助
*/
//在贝壳物联上的设备，千万不要勾选加密登陆，不然会登不上的。
#include
#include
#include "dht11.h"
//=============  此处必须修该============
String DEVICEID="xxxx"; // 你的设备编号   ==
String  APIKEY = "xxxxx"; // 设备密码==
const String INPUTID="xxxx";//温度接口
const String INPUTID1="xxxx";//湿度接口
//=======================================
unsigned long lastCheckInTime = 0; //记录上次报到时间
unsigned long lastUpdateTime = 0; 
const unsigned long postingInterval = 40000; // 每隔40秒向服务器报到一次
const unsigned long updateInterval = 5000; // delay between 2 datapoints, 5s

const char* ssid     = "xxxxx";//无线名称
const char* password = "xxxxxx";//无线密码

const char* host = "www.bigiot.net";
const int httpPort = 8181;//http端口

int pins[4] = {D5,D6,D7,D8};//led pin
int state[4] = {LOW,LOW,LOW,LOW};
int arr_len = sizeof(pins)/sizeof(pins[0]);

void setup() {
  Serial.begin(115200);
  delay(1000);
  
  WiFi.begin(ssid, password);
  //默认输出关闭电频
  for(int i=0;i     pinMode(pins[i], OUTPUT);
    digitalWrite(pins[i], state[i]);
  }
  Init2320();
}

WiFiClient client;

void loop() {

  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }

  // Use WiFiClient class to create TCP connections
  if (!client.connected()) {
    if (!client.connect(host, httpPort)) {
      Serial.println("connection failed");
      delay(5000);
      return;
    }
  }

if((millis()>0)&&(millis()<10000)){//如果系统时间重新从0计算的话，就复位检测时间和更新时间
            lastCheckInTime=0;
            lastUpdateTime=0;
  }

  if(millis() - lastCheckInTime > postingInterval || lastCheckInTime==0) {//定期向服务器报到，以防断线
    checkIn();
     Serial.println("posting");
  }

  if((millis() - lastUpdateTime > updateInterval) ) {//定时采集温湿度向服务器发送
     int temp=0;
     int hut=0;
     sensors_event_t event;
  
     dht.temperature().getEvent(&event);//获取温度
    // update1(DEVICEID,INPUTID,event.temperature);//向服务器更新温度
     temp=event.temperature;
     hut=dht.humidity().getEvent(&event);//获取湿度
     hut=event.relative_humidity;
     //update1(DEVICEID,INPUTID1,event.relative_humidity);//向服务器更新湿度  
     update2(DEVICEID,INPUTID,temp,INPUTID1,hut);//向服务器更新温湿度 ,数据多的时候使用这个函数连续发送，不然一个个发送，结果只能发到一个
     Serial.print(temp);
     Serial.print("\n");
     Serial.print(hut);
     Serial.print("\n");
   
    
 }
  
  // Read all the lines of the reply from server and print them to Serial
  if (client.available()) {//读取数据
    String inputString = client.readStringUntil('\n');
    inputString.trim();
    Serial.println(inputString);
    int len = inputString.length()+1;
    if(inputString.startsWith("{") && inputString.endsWith("}")){
      char jsonString[len];
      inputString.toCharArray(jsonString,len);
      aJsonObject *msg = aJson.parse(jsonString);
      processMessage(msg);
      aJson.deleteItem(msg);          
    }
  }
}

void processMessage(aJsonObject *msg){//收到服务器发送的数据进行处理
  aJsonObject* method = aJson.getObjectItem(msg, "M");
  aJsonObject* content = aJson.getObjectItem(msg, "C");     
  aJsonObject* client_id = aJson.getObjectItem(msg, "ID");
  if (!method) {
    return;
  }
    String M = method->valuestring;
    if(M == "say"){//判断头字符是否为say
      String C = content->valuestring;//获取人发送的数据
      String F_C_ID = client_id->valuestring;
      if(C == "play"){//判断人发送的数据进行逻辑处理       

for(int i=0;i           state[i] = HIGH;
          digitalWrite(pins[i], state[i]);
        }

        sayToClient(F_C_ID,"LED All on!");//处理后向服务器向应，做了些什么    
      }else if(C == "stop"){
        for(int i=0;i           state[i] = LOW;
          digitalWrite(pins[i], state[i]);
        }
        sayToClient(F_C_ID,"LED All off!");    
      }
      else if(C == "12"){//判断人发送的数据进行逻辑处理
                
       
        
          digitalWrite(12, HIGH);
          digitalWrite(13, LOW);
          digitalWrite(15, LOW);
          sayToClient(F_C_ID,"GREEN ON!");//处理后向服务器向应，做了些什么   
        }

         else if(C == "13"){//判断人发送的数据进行逻辑处理
       
        
          digitalWrite(12, LOW);
          digitalWrite(13, HIGH);
          digitalWrite(15, LOW);
          sayToClient(F_C_ID,"BLUE ON!");//处理后向服务器向应，做了些什么   
        }
         else if(C == "15"){//判断人发送的数据进行逻辑处理
       
        
          digitalWrite(12, LOW);
          digitalWrite(13, LOW);
          digitalWrite(15, HIGH);
          sayToClient(F_C_ID,"RED ON!");//处理后向服务器向应，做了些什么   
        }

      else{
        int pin = C.toInt();
        if(pin > 0 && pin <= arr_len){//按下字符2-4 LED三色灯可以混色输出
          pin--;
          state[pin] = !state[pin];
          digitalWrite(pins[pin], state[pin]);
        }
        sayToClient(F_C_ID,"LED pin:"+pin); 
      }
    }
}
//服务器报到函数,只有第一次报到，服务器才有报到回应。
void checkIn() {
    String msg = "{\"M\":\"checkin\",\"ID\":\"" + DEVICEID + "\",\"K\":\"" + APIKEY + "\"}\n";
    client.print(msg);
    lastCheckInTime = millis(); 
}
//向服务器对话函数，服务器向8266对话也是这样的格式，收到后在串口打出来
void sayToClient(String client_id, String content){
  String msg = "{\"M\":\"say\",\"ID\":\"" + client_id + "\",\"C\":\"" + content + "\"}\n";
  client.print(msg);
  lastCheckInTime = millis();
}

void update1(String did, String inputid, int value){//上传一个数据 的函数
  client.print("{\"M\":\"update\",\"ID\":\"");
  client.print(did);
  client.print("\",\"V\":{\"");
  client.print(inputid);
  client.print("\":\"");
  client.print(value);
  client.println("\"}}");
  lastCheckInTime = millis();
  lastUpdateTime= millis();
  Serial.print("update:");   
  Serial.print(inputid);   
  Serial.print("->");   
  Serial.println(value);   
}

//同时上传两个接口数据调用此函数
void update2(String did, String inputid1, int value1, String inputid2, int value2){
  client.print("{\"M\":\"update\",\"ID\":\"");
  client.print(did);
  client.print("\",\"V\":{\"");
  client.print(inputid1);
  client.print("\":\"");
  client.print(value1);
  client.print("\",\"");
  client.print(inputid2);
  client.print("\":\"");
  client.print(value2);
  client.println("\"}}");
 // lastCheckInTime = millis();
  lastUpdateTime= millis();
  Serial.print("update:");   
  Serial.print(inputid1);   
  Serial.print("->"); 
  Serial.print(value1);  
  Serial.print("  "); 
  Serial.print(inputid2);   
  Serial.print("->"); 
  Serial.println(value2);   
}
 

4：用笔记本新建一个C文件 然后将温湿度的代码粘进去。然后在arduino工程中添加这个文件，这个文件改名为dht11.h

#ifndef __DHT11_H__
#define __DHT11_H__

// DHT Temperature & Humidity Sensor
// Unified Sensor Library Example
// Written by Tony DiCola for Adafruit Industries
// Released under an MIT license.

// Depends on the following Arduino libraries:
// - Adafruit Unified Sensor Library: https://github.com/adafruit/Adafruit_Sensor
// - DHT Sensor Library: https://github.com/adafruit/DHT-sensor-library

#include
#include
#include

#define DHTPIN            4         // Pin which is connected to the DHT sensor.

// Uncomment the type of sensor in use:
//#define DHTTYPE           DHT11     // DHT 11 
#define DHTTYPE           DHT22     // DHT 22 (AM2302)
//#define DHTTYPE           DHT21     // DHT 21 (AM2301)

// See guide for details on sensor wiring and usage:
//   https://learn.adafruit.com/dht/overview

DHT_Unified dht(DHTPIN, DHTTYPE);

uint32_t delayMS;

void Init2320() {

  // Initialize device.
  dht.begin();
//  Serial.println("DHTxx Unified Sensor Example");
  // Print temperature sensor details.
  sensor_t sensor;
  dht.temperature().getSensor(&sensor);
//  Serial.println("------------------------------------");
//  Serial.println("Temperature");
//  Serial.print  ("Sensor:       "); Serial.println(sensor.name);
//  Serial.print  ("Driver Ver:   "); Serial.println(sensor.version);
//  Serial.print  ("Unique ID:    "); Serial.println(sensor.sensor_id);
//  Serial.print  ("Max Value:    "); Serial.print(sensor.max_value); Serial.println(" *C");
//  Serial.print  ("Min Value:    "); Serial.print(sensor.min_value); Serial.println(" *C");
//  Serial.print  ("Resolution:   "); Serial.print(sensor.resolution); Serial.println(" *C");  
//  Serial.println("------------------------------------");
  // Print humidity sensor details.
  dht.humidity().getSensor(&sensor);
//  Serial.println("------------------------------------");
//  Serial.println("Humidity");
//  Serial.print  ("Sensor:       "); Serial.println(sensor.name);
//  Serial.print  ("Driver Ver:   "); Serial.println(sensor.version);
//  Serial.print  ("Unique ID:    "); Serial.println(sensor.sensor_id);
//  Serial.print  ("Max Value:    "); Serial.print(sensor.max_value); Serial.println("%");
//  Serial.print  ("Min Value:    "); Serial.print(sensor.min_value); Serial.println("%");
//  Serial.print  ("Resolution:   "); Serial.print(sensor.resolution); Serial.println("%");  
//  Serial.println("------------------------------------");
  // Set delay between sensor readings based on sensor details.
  delayMS = sensor.min_delay / 1000;
}

void Display2320() {
  // Delay between measurements.
  delay(delayMS);
  // Get temperature event and print its value.
  sensors_event_t event;  
  dht.temperature().getEvent(&event);

  if (isnan(event.temperature)) {
   // Serial.println("Error reading temperature!");
  }
  else {
//    Serial.print("Temperature: ");
    Serial.print(event.temperature);
//    Serial.println(" *C");

  }
  // Get humidity event and print its value.
  dht.humidity().getEvent(&event);
  if (isnan(event.relative_humidity)) {
   // Serial.println("Error reading humidity!");
  }
  else {
//    Serial.print("Humidity: ");
   Serial.print(event.relative_humidity);
//    Serial.println("%");

  }
}

#endif

5:贝壳网注册自己的帐号  在控制面版里，新建自己的设备 ，为这个设备添加两个数据流 然后将程序编译下载到esp8266上。

打开新建的设备 点击对话输入以下命令

我在程序上设置的数据控制LDE的命令为双引号内：“12” “13” “15” “play” “stop”        

LDE输出为高电平亮，低电平灭。

打开数据流 可以看到湿度和温度在每隔5秒就上传到贝壳上  

实现双向数据传输   

还可以下载贝壳的APP进行控制，微信公众号也可以这个贝壳官网有下载

大家有什么看不明的，可以私信我这个帐号，也可以在贴中发问谢谢大家

最后发现在这里粘出来的代码不能正常显示 下面上传了源码

https://pan.baidu.com/s/196C3QQZtEMQnfdsGJx8gRg

评论：共8条