ESP8266和MQTT協(xié)議修改版源程序

ID:718503 · 發(fā)表于 2020-5-5 23:38

ESP8266+MQTT

#include "onenet.h"
extern unsigned char esp8266_buf[256];
//==========================================================
// 函數(shù)名稱： OneNET_DevLink
// 函數(shù)功能：與onenet創(chuàng)建連接
// 入口參數(shù)：無
// 返回參數(shù)： 1-成功 0-失敗
// 說明：與onenet平臺建立連接
//==========================================================
_Bool OneNET_DevLink(void)
{
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //協(xié)議包
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); //等待平臺響應(yīng)
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: 連接失敗：協(xié)議錯誤\r\n");
break;
case 2:printf("WARN: 連接失敗：非法的clientid\r\n");
break;
case 3:printf("WARN: 連接失敗：服務(wù)器失敗\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格式打包函數(shù)，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協(xié)議采用type=2方式封裝數(shù)據(jù)函數(shù)（二進制發(fā)送數(shù)據(jù)）
//payload:存儲打包的數(shù)據(jù)
//bin是發(fā)送的數(shù)組的首地址
//size是數(shù)組的長度
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，數(shù)據(jù)點類型指示：type=2,二進制數(shù)據(jù)
payload[0] = '\x02';
//Byte2、Byte3指示后面json字符串長度
payload[1] = (json_len & 0xFF00) >> 8;
payload[2] = json_len & 0xFF;
//把json復(fù)制到t_payload數(shù)組中
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;
}
//==========================================================
// 函數(shù)名稱： OneNET_SendData
// 函數(shù)功能：上傳數(shù)據(jù)到平臺
// 入口參數(shù)： buf: 存儲打包數(shù)據(jù)的數(shù)組
// type: 發(fā)送數(shù)據(jù)的格式
// bin: 要發(fā)送的二進制數(shù)組的首地址
// size: 要發(fā)送的二進制數(shù)組大長度
// 返回參數(shù)：無
// 說明：
//==========================================================
void OneNET_SendData(u8 *buf,u8 type,u8 *bin,u16 size)
{
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //協(xié)議包
short body_len = 0;
switch(type)
{
case 5:body_len = OneNET_FillBuf((char *)buf); //獲取當前需要發(fā)送的json數(shù)據(jù)流的總長度
break;
case 2:body_len = MqttSample_PackDataByBinary2(buf,bin, size); //獲取當前需要發(fā)送的二進制打包數(shù)組的長度
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); //上傳數(shù)據(jù)到平臺
printf("Send %d Bytes\r\n", mqttPacket._len);
MQTT_DeleteBuffer(&mqttPacket); //刪包
}
else
printf("WARN: EDP_NewBuffer Failed\r\n");
}
}
//==========================================================
// 函數(shù)名稱： OneNET_RevPro
// 函數(shù)功能：平臺返回數(shù)據(jù)檢測
// 入口參數(shù)： dataPtr：平臺返回的數(shù)據(jù)
// 返回參數(shù)：無
// 說明：
//==========================================================
void OneNET_RevPro(unsigned char *cmd)
{
MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //協(xié)議包
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: //命令下發(fā)
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) //命令回復(fù)組包
{
printf("Tips: Send CmdResp\r\n");
ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回復(fù)命令
MQTT_DeleteBuffer(&mqttPacket); //刪包
}
}
break;
case MQTT_PKT_PUBACK: //發(fā)送Publish消息，平臺回復(fù)的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') //判斷是否是下發(fā)的命令控制數(shù)據(jù)
{
numBuf[num++] = *dataPtr++;
}
num = atoi((const char *)numBuf); //轉(zhuǎn)為數(shù)值形式
if(strstr((char *)req_payload, "redled")) //搜索"redled"
{
if(num == 1) //控制數(shù)據(jù)如果為1，代表開
{
LED0 = 0;
}
else if(num == 0) //控制數(shù)據(jù)如果為0，代表關(guān)
{
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);
}
}

復(fù)制代碼

#include "main.h"
int main()
{
u16 timeCount = 0; //發(fā)送間隔變量
u8 *dataPtr = NULL;
u8 data[10]={0x12,0x23,0x45,0x68,0x79,0xAB,0x00,0xEF};
u8 buf[256];
Stm32_Clock_Init(9); //系統(tǒng)時鐘設(shè)置
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) //發(fā)送間隔5s
{
printf( "OneNET_SendData\r\n");
OneNET_SendData(buf,2,data,8); //發(fā)送數(shù)據(jù)
timeCount = 0;
ESP8266_ClearBuff();
}
dataPtr = ESP8266_GetIPD(0);
if(dataPtr != NULL)
OneNET_RevPro(dataPtr);
delay_ms(10);
}
}

復(fù)制代碼

帳號		自動登錄	找回密碼
密碼			立即注冊

久久久久久久999_99精品久久精品一区二区爱城_成人欧美一区二区三区在线播放_国产精品日本一区二区不卡视频_国产午夜视频_欧美精品在线观看免费

ESP8266和MQTT協(xié)議修改版 源程序

ESP8266和MQTT協(xié)議修改版源程序