Arduino+ESP8266通过EDP协议连接onenet平台

Arduino是许多智能硬件爱好者的首选，使用简单快捷，而ESP8266模块也是当前最为热门的WIFI模块。本项目完成了Arduino使用EDP协议通过ESP8266 WIFI模块接入OneNET服务器，并通过在接入设备中创建的应用来实现远程控制LED灯。

【1】硬件连接：

准备元件：

Arduino UNO

ESP8266 WIFI模块

USB转TTL连接线

硬件连线：

Arduino UNO USB转TTL

D2-----------------RX

D3-----------------TX

GND---------------GND

Arduino UNO ESP8266

RX-----------------TX

TX-----------------RX

GND---------------GND

其中USB转TTL连接电脑用于调试打印输出，然后Arduino的串口连接ESP8266的串口。

【2】ESP8266配置和EDP上传数据介绍：

选用ESP8266串口WIFI模块，通过AT指令控制WIFI模块接入互联网，依次完成与接入互联网、与OneNet服务器建立TCP连接、传输数据等操作。

1)配置WIFI模块；

模块配置接入OneNet，依次发送如下几个命令到WIFI模块：

AT+CWMODE=3

AT+RST

AT+CIFSR

AT+CWJAP="your ssid","password"

2)和OneNet服务器建立TCP连接，依次发送命令：

AT+CIPSTART="TCP","183.230.40.39",876 //和服务器建立TCP连接

AT+CIPMODE=1 //进入透明传输模式

AT+CIPSEND //开始传输

命令执行结果如下图所示：

关于如何使用WIFI方式接入可以详细查看：http://open.iot.10086.cn/doc/art76.html#29

3)创建设备和应用：

添加产品并创建接入设备，详细创建步骤请查看：http://open.iot.10086.cn/doc/art243.html#66。其中数据传输协议选择EDP。

在设备中添加应用，创建一个开关控件，在右侧的属性中选择对应设备的LED数据流 ·注意到属性中有开关开值和开关关值两个属性，分别默认为1,0，这里不做修改(因为代码中1为开，非1则为关) ·修改EDP命令内容为LED:(与代码对应，代码中会将冒号前的部分作为上传的数据流ID，而将冒号之后的部分作为上传是数据值) 这里的是通配符当下发命令的时候，他将会被开关的开/关值取代，稍后我们将看到命令的内容。

其中USB转TTL用于连接电脑，作为调试打印输出口，ESP8266连接arduino的串口

/*

采用外接电源单独供电，2 3口作为软串口接PC机作为调试端

1 0为串口，连接WIFI模块

*/

#include

#include "edp.c"

#include

dht11 DHT11;

#define KEY "VJqJAM2F3ztuzFGv0TIS78W5gGY=" //APIkey

//#define PUSH_ID "680788"

#define PUSH_ID NULL

// 串口

#define _baudrate 115200

#define _rxpin 3

#define _txpin 2

#define WIFI_UART Serial

#define DBG_UART dbgSerial //调试打印串口

#define DHT11PIN A0 //温湿度传感器的pin

#define MQ2 A1 //MQ-2传感器的pin

#define FMQ 9 //蜂鸣器pin

SoftwareSerial dbgSerial( _rxpin, _txpin ); // 软串口，调试打印

edp_pkt *pkt;

/*

* doCmdOk

* 发送命令至模块，从回复中获取期待的关键字

* keyword: 所期待的关键字

* 成功找到关键字返回true，否则返回false

*/

bool doCmdOk(String data, char *keyword)

{

bool result = false;

if (data != "") //对于tcp连接命令，直接等待第二次回复

{

WIFI_UART.println(data); //发送AT指令

DBG_UART.print("SEND: ");

DBG_UART.println(data);

}

if (data == "AT") //检查模块存在

delay(2000);

else

while (!WIFI_UART.available()); // 等待模块回复

delay(200);

if (WIFI_UART.find(keyword)) //返回值判断

{

DBG_UART.println("do cmd OK");

result = true;

}

else

{

DBG_UART.println("do cmd ERROR");

result = false;

}

while (WIFI_UART.available()) WIFI_UART.read(); //清空串口接收缓存

delay(500); //指令时间间隔

return result;

}

void setup()

{

char buf[100] = ;

int tmp;

pinMode(13, OUTPUT); //WIFI模块指示灯

pinMode(8, OUTPUT); //用于连接EDP控制的发光二极管

WIFI_UART.begin( _baudrate );

DBG_UART.begin( _baudrate );

WIFI_UART.setTimeout(3000); //设置find超时时间

delay(3000);

DBG_UART.println("hello world!");

delay(2000);

while (!doCmdOk("AT", "OK"));

digitalWrite(13, HIGH); // 使Led亮

while (!doCmdOk("AT+CWMODE=3", "OK")); //工作模式

while (!doCmdOk("AT+CWJAP="360","987654321"", "OK"));

while (!doCmdOk("AT+CIPSTART="TCP","183.230.40.39",876", "CONNECT"));

while (!doCmdOk("AT+CIPMODE=1", "OK")); //透传模式

while (!doCmdOk("AT+CIPSEND", ">")); //开始发送

}

void loop()

{

static int edp_connect = 0;

bool trigger = false;

edp_pkt rcv_pkt;

unsigned char pkt_type;

int i, tmp;

char num[10];

int wd; //温度

int sd; //湿度

int mq; //气体

char wd1[10]; //字符串格式温度

char sd1[10]; //字符串格式湿度

char mq1[10]; //字符串格式气体

int chk = DHT11.read(DHT11PIN);//读DHT11

mq = analogRead(MQ2);

if(mq>=200)

digitalWrite(FMQ, HIGH); //蜂鸣器响

/* EDP 连接 */

if (!edp_connect)

{

while (WIFI_UART.available()) WIFI_UART.read(); //清空串口接收缓存

packetSend(packetConnect(ID, KEY)); //发送EPD连接包

while (!WIFI_UART.available()); //等待EDP连接应答

if ((tmp = WIFI_UART.readBytes(rcv_pkt.data, sizeof(rcv_pkt.data))) > 0 )

{

rcvDebug(rcv_pkt.data, tmp);

if (rcv_pkt.data[0] == 0x20 && rcv_pkt.data[2] == 0x00 && rcv_pkt.data[3] == 0x00)

{

edp_connect = 1;

DBG_UART.println("EDP connected.");

}

else

DBG_UART.println("EDP connect error.");

}

packetClear(&rcv_pkt);

}

wd = (float)DHT11.temperature;//获取温度

sd = (float)DHT11.humidity;//获取湿度

trigger = wd; //传感器是否工作

if (edp_connect && trigger)

{

DBG_UART.print("temperature: ");

DBG_UART.println((float)DHT11.temperature, 2);

DBG_UART.print("humidity: ");

DBG_UART.println((float)DHT11.humidity, 2);

DBG_UART.print("MQ-2: ");

DBG_UART.println(analogRead(MQ2));

sprintf(wd1,"%d",wd); //int型转换char型

sprintf(sd1,"%d",sd); //int型转换char型

sprintf(mq1,"%d",mq); //int型转换char型

packetSend(packetDataSaveTrans(PUSH_ID, "WD", wd1)); //发送数据存储包 当PUSH_ID不为NULL时转发至PUSH_ID

delay(100);

packetSend(packetDataSaveTrans(NULL, "SD", sd1)); //发送的数据必须为字符串 ""

delay(100);

packetSend(packetDataSaveTrans(NULL, "MQ", mq1));

delay(2000);

}

while (WIFI_UART.available())

{

readEdpPkt(&rcv_pkt);

if (isEdpPkt(&rcv_pkt))

{

pkt_type = rcv_pkt.data[0];

switch (pkt_type)

{

case CMDREQ:

char edp_command[50];

char edp_cmd_id[40];

long id_len, cmd_len, rm_len;

char datastr[20];

char val[10];

memset(edp_command, 0, sizeof(edp_command));

memset(edp_cmd_id, 0, sizeof(edp_cmd_id));

edpCommandReqParse(&rcv_pkt, edp_cmd_id, edp_command, &rm_len, &id_len, &cmd_len);

DBG_UART.print("rm_len: ");

DBG_UART.println(rm_len, DEC);

delay(10);

DBG_UART.print("id_len: ");

DBG_UART.println(id_len, DEC);

delay(10);

DBG_UART.print("cmd_len: ");

DBG_UART.println(cmd_len, DEC);

delay(10);

DBG_UART.print("id: ");

DBG_UART.println(edp_cmd_id);

delay(10);

DBG_UART.print("cmd: ");

DBG_UART.println(edp_command);

//数据处理与应用中EDP命令内容对应

//本例中格式为 datastream:[1/0]

sscanf(edp_command, "%[^:]:%s", datastr, val);//datastr为数据流名

if (atoi(val) == 1)

digitalWrite(8, HIGH); // 使Led亮

else

digitalWrite(8, LOW); // 使Led灭

packetSend(packetDataSaveTrans(NULL, datastr,val)); //将新数据值上传至数据流

break;

default:

DBG_UART.print("unknown type: ");

DBG_UART.println(pkt_type, HEX);

break;

}

}

//delay(4);

}

if (rcv_pkt.len > 0)

packetClear(&rcv_pkt);

delay(150);

//packetSend(packetDataSaveTrans(NULL, "text", 5)); //将新数据值上传至数据流

}

/*

* readEdpPkt

* 从串口缓存中读数据到接收缓存

*/

bool readEdpPkt(edp_pkt *p)

{

int tmp;

if ((tmp = WIFI_UART.readBytes(p->data + p->len, sizeof(p->data))) > 0 )

{

rcvDebug(p->data + p->len, tmp);

p->len += tmp;

}

return true;

}

/*

* packetSend

* 将待发数据发送至串口，并释放到动态分配的内存

*/

void packetSend(edp_pkt* pkt)

{

if (pkt != NULL)

{

WIFI_UART.write(pkt->data, pkt->len); //串口发送

WIFI_UART.flush();

free(pkt); //回收内存

}

}

void rcvDebug(unsigned char *rcv, int len)

{

int i;

DBG_UART.print("rcv len: ");

DBG_UART.println(len, DEC);

for (i = 0; i

{

DBG_UART.print(rcv[i], HEX);

DBG_UART.print(" ");

}

DBG_UART.println("");

}

4)源码：

Arduino_EDP.zip

其中Arduino开发板的D13作为被控制的LED灯，在程序中添加设备ID和APIKey。

调试串口显示：

onenet云平台应用：

玩得趣科技教育携手趣讨教，感谢趣讨教网的分享，感谢趣讨教的技术支持！趣讨教-一群大牛分享技术交流的平台！