|
ESP8266+MQTT- #include "onenet.h"
- extern unsigned char esp8266_buf[256];
- //==========================================================
- // 函数名称: OneNET_DevLink
- // 函数功能: 与onenet创建连接
- // 入口参数: 无
- // 返回参数: 1-成功 0-失败
- // 说明: 与onenet平台建立连接
- //==========================================================
- _Bool OneNET_DevLink(void)
- {
-
- MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
- unsigned char *dataPtr;
-
- _Bool status = 1;
-
- printf("OneNET_DevLink\r\n");
- printf("PROID: %s, AUIF: %s, DEVID:%s\r\n", PROID, AUTH_INFO, DEVID);
-
- if(MQTT_PacketConnect(PROID, AUTH_INFO, DEVID, 256, 0, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0)
- {
- ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传平台
-
- dataPtr = ESP8266_GetIPD(250); //等待平台响应
- if(dataPtr != NULL)
- {
- if(MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK)
- {
- switch(MQTT_UnPacketConnectAck(dataPtr))
- {
- case 0:printf("Tips: 连接成功\r\n");status = 0;
- break;
-
- case 1:printf("WARN: 连接失败:协议错误\r\n");
- break;
- case 2:printf("WARN: 连接失败:非法的clientid\r\n");
- break;
- case 3:printf("WARN: 连接失败:服务器失败\r\n");
- break;
- case 4:printf("WARN: 连接失败:用户名或密码错误\r\n");
- break;
- case 5:printf("WARN: 连接失败:非法链接(比如token非法)\r\n");
- break;
-
- default:printf("ERR: 连接失败:未知错误\r\n");
- break;
- }
- }
- }
-
- MQTT_DeleteBuffer(&mqttPacket); //删包
- }
- else
- printf( "WARN: MQTT_PacketConnect Failed\r\n");
-
- return status;
-
- }
- unsigned char OneNET_FillBuf(char *buf)
- {
-
- char text[32];
-
- memset(text, 0, sizeof(text));
-
- strcpy(buf, ",;");
-
- memset(text, 0, sizeof(text));
- sprintf(text, "Tempreture,%2.1f;", 23.4);
- strcat(buf, text);
-
- memset(text, 0, sizeof(text));
- sprintf(text, "Humidity,%2.1f;", 66.8);
- strcat(buf, text);
-
- return strlen(buf);
- }
- //json格式打包函数,type=5的方式
- int MqttSample_PackDataByJson5(char *buf)
- {
-
- char text[32];
-
- memset(text, 0, sizeof(text));
-
- strcpy(buf, ",;");
-
- memset(text, 0, sizeof(text));
- sprintf(text, "Tempreture,%2.1f;", 23.4);
- strcat(buf, text);
-
- memset(text, 0, sizeof(text));
- sprintf(text, "Humidity,%2.1f;", 66.8);
- strcat(buf, text);
-
- return strlen(buf);
- }
- //MQTT协议采用type=2方式封装数据函数(二进制发送数据)
- //payload:存储打包的数据
- //bin是发送的数组的首地址
- //size是数组的长度
- int MqttSample_PackDataByBinary2(u8 *payload,u8 *bin, uint32_t size)
- {
- int payload_len;
- char json[]="{\"ds_id\":\"binary\"}";
- unsigned short json_len;
-
- payload_len = 1 + 2 + strlen(json)/sizeof(char);
- json_len = strlen(json)/sizeof(char);
-
- //Byte1,数据点类型指示:type=2,二进制数据
- payload[0] = '\x02';
- //Byte2、Byte3指示后面json字符串长度
- payload[1] = (json_len & 0xFF00) >> 8;
- payload[2] = json_len & 0xFF;
- //把json复制到t_payload数组中
- memcpy(payload+3, json, json_len);
-
-
- payload[payload_len] = (size & 0xFF000000)>>24;
- payload[payload_len+1]=(size & 0x00FF0000)>>16;
- payload[payload_len+2]=(size & 0x0000FF00)>>8;
- payload[payload_len+3]=(size & 0x000000FF);
-
- for(u32 i=0; i<size+4; i++)
- {
- payload[payload_len+4+i]=bin[i];
- }
-
- return payload_len+size+4;
- }
- //==========================================================
- // 函数名称: OneNET_SendData
- // 函数功能: 上传数据到平台
- // 入口参数: buf: 存储打包数据的数组
- // type: 发送数据的格式
- // bin: 要发送的二进制数组的首地址
- // size: 要发送的二进制数组大长度
- // 返回参数: 无
- // 说明:
- //==========================================================
- void OneNET_SendData(u8 *buf,u8 type,u8 *bin,u16 size)
- {
-
- MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
-
- short body_len = 0;
-
- switch(type)
- {
- case 5:body_len = OneNET_FillBuf((char *)buf); //获取当前需要发送的json数据流的总长度
- break;
- case 2:body_len = MqttSample_PackDataByBinary2(buf,bin, size); //获取当前需要发送的二进制打包数组的长度
- break;
-
- default:
- break;
- }
-
- if(body_len)
- {
- if(MQTT_PacketSaveData(DEVID,body_len, NULL, type, &mqttPacket) == 0) //封包
- {
- for(int i=0; i < body_len; i++)
- mqttPacket._data[mqttPacket._len++] = buf[i];
-
- ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传数据到平台
- printf("Send %d Bytes\r\n", mqttPacket._len);
-
- MQTT_DeleteBuffer(&mqttPacket); //删包
- }
- else
- printf("WARN: EDP_NewBuffer Failed\r\n");
- }
- }
- //==========================================================
- // 函数名称: OneNET_RevPro
- // 函数功能: 平台返回数据检测
- // 入口参数: dataPtr:平台返回的数据
- // 返回参数: 无
- // 说明:
- //==========================================================
- void OneNET_RevPro(unsigned char *cmd)
- {
-
- MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
-
- char *req_payload = NULL;
- char *cmdid_topic = NULL;
- unsigned char type = 0;
-
- short result = 0;
- char *dataPtr = NULL;
- char numBuf[10];
- int num = 0;
-
- type = MQTT_UnPacketRecv(cmd);
- switch(type)
- {
- case MQTT_PKT_CMD: //命令下发
-
- result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload); //解出topic和消息体
- if(result == 0)
- {
- printf("cmdid: %s, req: %s\r\n", cmdid_topic, req_payload);
-
- if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0) //命令回复组包
- {
- printf("Tips: Send CmdResp\r\n");
-
- ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回复命令
- MQTT_DeleteBuffer(&mqttPacket); //删包
- }
- }
-
- break;
-
- case MQTT_PKT_PUBACK: //发送Publish消息,平台回复的Ack
-
- if(MQTT_UnPacketPublishAck(cmd) == 0)
- printf("Tips: MQTT Publish Send OK\r\n");
-
- break;
-
- default:
- result = -1;
- break;
- }
-
- ESP8266_ClearBuff(); //清空缓存
-
- if(result == -1)
- return;
-
- dataPtr = strchr(req_payload, '{'); //搜索'}'
- if(dataPtr != NULL && result != -1) //如果找到了
- {
- dataPtr++;
-
- while(*dataPtr >= '0' && *dataPtr <= '9') //判断是否是下发的命令控制数据
- {
- numBuf[num++] = *dataPtr++;
- }
-
- num = atoi((const char *)numBuf); //转为数值形式
-
- if(strstr((char *)req_payload, "redled")) //搜索"redled"
- {
- if(num == 1) //控制数据如果为1,代表开
- {
- LED0 = 0;
- }
- else if(num == 0) //控制数据如果为0,代表关
- {
- LED0 = 1;
- }
- }
- //下同
- else if(strstr((char *)req_payload, "greenled"))
- {
- if(num == 1)
- {
- LED1 = 0;
- }
- else if(num == 0)
- {
- LED1 = 1;
- }
- }
- else if(strstr((char *)req_payload, "allled"))
- {
- if(num == 1)
- {
- LED0 = 0;
- LED1 = 0;
- }
- else if(num == 0)
- {
- LED0 = 1;
- LED1 = 1;
- }
- }
- }
- if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
- {
- MQTT_FreeBuffer(cmdid_topic);
- MQTT_FreeBuffer(req_payload);
- }
- }
复制代码- #include "main.h"
- int main()
- {
-
- u16 timeCount = 0; //发送间隔变量
- u8 *dataPtr = NULL;
- u8 data[10]={0x12,0x23,0x45,0x68,0x79,0xAB,0x00,0xEF};
- u8 buf[256];
-
- Stm32_Clock_Init(9); //系统时钟设置
- uart_init(72,9600); //串口初始化为9600
- delay_init(72); //延时初始化
- LED_Init(); //初始化与LED连接的硬件接口
-
- ESP8266_Init(); //初始化ESP8266
-
- while(OneNET_DevLink()) //接入OneNET
- delay_ms(500);
- delay_ms(250);
-
- while(1)
- {
- if(++timeCount >= 1000) //发送间隔5s
- {
- printf( "OneNET_SendData\r\n");
- OneNET_SendData(buf,2,data,8); //发送数据
-
- timeCount = 0;
- ESP8266_ClearBuff();
- }
-
-
- dataPtr = ESP8266_GetIPD(0);
- if(dataPtr != NULL)
- OneNET_RevPro(dataPtr);
- delay_ms(10);
-
- }
- }
复制代码
|
|