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);
}
}

复制代码