|
|
#ifndef __MQTT_H
#define __MQTT_H
#define BUFF_UNIT 512 //緩沖區長度
#define R_NUM 8 //接收緩沖區個數
#define T_NUM 8 //發送緩沖區個數
#define C_NUM 8 //命令緩沖區個數
#define MQTT_TxData(x) u2_TxData(x) //串口2負責800C的數據發送
#define PRODUCTKEY "a1XrG0NTzDE" //產品ID
#define PRODUCTKEY_LEN strlen(PRODUCTKEY) //產品ID長度
#define DEVICENAME "D001" //設備名
#define DEVICENAME_LEN strlen(DEVICENAME) //設備名長度
#define DEVICESECRE "368cfb4efb9036f422daed21fe519b30" //設備秘鑰
#define DEVICESECRE_LEN strlen(DEVICESECRE) //設備秘鑰長度
#define S_TOPIC_NAME "/sys/a1XrG0NTzDE/D001/thing/service/property/set" //需要訂閱的主題
#define P_TOPIC_NAME "/sys/a1XrG0NTzDE/D001/thing/event/property/post" //需要發布的主題
extern unsigned char MQTT_RxDataBuf[R_NUM][BUFF_UNIT]; //外部變量聲明，數據的接收緩沖區,所有服務器發來的數據，存放在該緩沖區,緩沖區第一個字節存放數據長度
extern unsigned char *MQTT_RxDataInPtr; //外部變量聲明，指向緩沖區存放數據的位置
extern unsigned char *MQTT_RxDataOutPtr; //外部變量聲明，指向緩沖區讀取數據的位置
extern unsigned char *MQTT_RxDataEndPtr; //外部變量聲明，指向緩沖區結束的位置
extern unsigned char MQTT_TxDataBuf[T_NUM][BUFF_UNIT]; //外部變量聲明，數據的發送緩沖區,所有發往服務器的數據，存放在該緩沖區,緩沖區第一個字節存放數據長度
extern unsigned char *MQTT_TxDataInPtr; //外部變量聲明，指向緩沖區存放數據的位置
extern unsigned char *MQTT_TxDataOutPtr; //外部變量聲明，指向緩沖區讀取數據的位置
extern unsigned char *MQTT_TxDataEndPtr; //外部變量聲明，指向緩沖區結束的位置
extern unsigned char MQTT_CMDBuf[C_NUM][BUFF_UNIT]; //外部變量聲明，命令數據的接收緩沖區
extern unsigned char *MQTT_CMDInPtr; //外部變量聲明，指向緩沖區存放數據的位置
extern unsigned char *MQTT_CMDOutPtr; //外部變量聲明，指向緩沖區讀取數據的位置
extern unsigned char *MQTT_CMDEndPtr; //外部變量聲明，指向緩沖區結束的位置
extern char ClientID[128]; //外部變量聲明，存放客戶端ID的緩沖區
extern int ClientID_len; //外部變量聲明，存放客戶端ID的長度
extern char Username[128]; //外部變量聲明，存放用戶名的緩沖區
extern int Username_len; //外部變量聲明，存放用戶名的長度
extern char Passward[128]; //外部變量聲明，存放密碼的緩沖區
extern int Passward_len; //外部變量聲明，存放密碼的長度
extern char ServerIP[128]; //外部變量聲明，存放服務器IP或是域名
extern int ServerPort; //外部變量聲明，存放服務器的端口號
extern char Ping_flag; //外部變量聲明，ping報文狀態 0：正常狀態，等待計時時間到，發送Ping報文
//外部變量聲明，ping報文狀態 1：Ping報文已發送，當收到 服務器回復報文的后 將1置為0
extern char Connect_flag; //外部變量聲明，同服務器連接狀態 0：還沒有連接服務器 1：連接上服務器了
extern char ReConnect_flag; //外部變量聲明，重連服務器狀態 0：連接還存在 1：連接斷開，重連
extern char ConnectPack_flag; //外部變量聲明，CONNECT報文狀態 1：CONNECT報文成功
extern char SubcribePack_flag; //外部變量聲明，訂閱報文狀態 1：訂閱報文成功
void MQTT_Buff_Init(void);
void MQTT_Buff_ReInit(void);
void AliIoT_Parameter_Init(void);
void MQTT_ConectPack(void);
void MQTT_Subscribe(char *, int);
void MQTT_PingREQ(void);
void MQTT_PublishQs0(char *, char *, int);
void MQTT_DealPushdata_Qs0(unsigned char *);
void TxDataBuf_Deal(unsigned char *, int);
void CMDBuf_Deal(unsigned char *, int);
#endif
|
|
QQ好友和群
QQ空間
騰訊微博
騰訊朋友
收藏
淘帖
頂
踩
