#include "stm32f10x.h" #include "mqtt.h" #include "string.h" #include "stdio.h" #include "usart1.h" #include "wifi.h"unsigned charMQTT_RxDataBuf[R_NUM][RBUFF_UNIT]; //数据的接收缓冲区,所有服务器发来的数据，存放在该缓冲区,缓冲区第一个字节存放数据长度 unsigned char *MQTT_RxDataInPtr; //指向接收缓冲区存放数据的位置 unsigned char *MQTT_RxDataOutPtr; //指向接收缓冲区读取数据的位置 unsigned char *MQTT_RxDataEndPtr; //指向接收缓冲区结束的位置unsigned charMQTT_TxDataBuf[T_NUM][TBUFF_UNIT]; //数据的发送缓冲区,所有发往服务器的数据，存放在该缓冲区,缓冲区第一个字节存放数据长度 unsigned char *MQTT_TxDataInPtr; //指向发送缓冲区存放数据的位置 unsigned char *MQTT_TxDataOutPtr; //指向发送缓冲区读取数据的位置 unsigned char *MQTT_TxDataEndPtr; //指向发送缓冲区结束的位置unsigned charMQTT_CMDBuf[C_NUM][CBUFF_UNIT]; //命令数据的接收缓冲区 unsigned char *MQTT_CMDInPtr; //指向命令缓冲区存放数据的位置 unsigned char *MQTT_CMDOutPtr; //指向命令缓冲区读取数据的位置 unsigned char *MQTT_CMDEndPtr; //指向命令缓冲区结束的位置char ClientID[128]; //存放客户端ID的缓冲区 intClientID_len; //存放客户端ID的长度char Username[128]; //存放用户名的缓冲区 intUsername_len; //存放用户名的长度char Passward[128]; //存放密码的缓冲区 intPassward_len; //存放密码的长度char ServerIP[128]; //存放服务器IP或是域名 intServerPort; //存放服务器的端口号intFixed_len; //固定报头长度 intVariable_len; //可变报头长度 intPayload_len; //有效负荷长度 unsigned chartemp_buff[TBUFF_UNIT]; //临时缓冲区，构建报文用char Ping_flag; //ping报文状态0：正常状态，等待计时时间到，发送Ping报文 //ping报文状态1：Ping报文已发送，当收到 服务器回复报文的后 将1置为0 char Connect_flag; //同服务器连接状态0：还没有连接服务器1：连接上服务器了 char ConnectPack_flag; //CONNECT报文状态1：CONNECT报文成功 char SubcribePack_flag; //订阅报文状态1：订阅报文成功/*----------------------------------------------------------*/ /*函数名：初始化接收,发送,命令数据的 缓冲区 以及各状态参数*/ /*参数：无*/ /*返回值：无*/ /*----------------------------------------------------------*/ void MQTT_Buff_Init(void) { MQTT_RxDataInPtr=MQTT_RxDataBuf[0]; //指向发送缓冲区存放数据的指针归位 MQTT_RxDataOutPtr=MQTT_RxDataInPtr; //指向发送缓冲区读取数据的指针归位 MQTT_RxDataEndPtr=MQTT_RxDataBuf[R_NUM-1]; //指向发送缓冲区结束的指针归位 MQTT_TxDataInPtr=MQTT_TxDataBuf[0]; //指向发送缓冲区存放数据的指针归位 MQTT_TxDataOutPtr=MQTT_TxDataInPtr; //指向发送缓冲区读取数据的指针归位 MQTT_TxDataEndPtr=MQTT_TxDataBuf[T_NUM-1]; //指向发送缓冲区结束的指针归位 MQTT_CMDInPtr=MQTT_CMDBuf[0]; //指向命令缓冲区存放数据的指针归位 MQTT_CMDOutPtr=MQTT_CMDInPtr; //指向命令缓冲区读取数据的指针归位 MQTT_CMDEndPtr=MQTT_CMDBuf[C_NUM-1]; //指向命令缓冲区结束的指针归位MQTT_ConectPack(); //发送缓冲区添加连接报文 MQTT_Subscribe(S_TOPIC_NAME,0); //发送缓冲区添加订阅topic，等级0 Ping_flag = ConnectPack_flag = SubcribePack_flag = 0; //各个参数清零 } /*----------------------------------------------------------*/ /*函数名：云初始化参数，得到客户端ID，用户名和密码*/ /*参数：无*/ /*返回值：无*/ /*----------------------------------------------------------*/ void IoT_Parameter_Init(void) { memset(ClientID,128,0); //客户端ID的缓冲区全部清零 sprintf(ClientID,"%s",DEVICEID); //构建客户端ID，并存入缓冲区 ClientID_len = strlen(ClientID); //计算客户端ID的长度 memset(Username,128,0); //用户名的缓冲区全部清零 sprintf(Username,"%s",PRODUCTID); //构建用户名，并存入缓冲区 Username_len = strlen(Username); //计算用户名的长度 memset(Passward,128,0); //用户名的缓冲区全部清零 sprintf(Passward,"%s",AUTHENTICATION); //构建密码，并存入缓冲区 Passward_len = strlen(Passward); //计算密码的长度 memset(ServerIP,0,128); sprintf(ServerIP,"%s","39.104.27.119"); //构建服务器域名 ServerPort = 1883; //服务器端口号1883 u1_printf("服 务 器：%s:%d\r\n",ServerIP,ServerPort); //串口输出调试信息 u1_printf("客户端ID：%s\r\n",ClientID); //串口输出调试信息 u1_printf("用 户 名：%s\r\n",Username); //串口输出调试信息 u1_printf("密码：%s\r\n",Passward); //串口输出调试信息 } /*----------------------------------------------------------*/ /*函数名：处理发送缓冲区*/ /*参数：data：数据*/ /*参数：size：数据长度*/ /*返回值：无*/ /*----------------------------------------------------------*/ void TxDataBuf_Deal(unsigned char *data, int size) { memcpy(&MQTT_TxDataInPtr[2],data,size); //拷贝数据到发送缓冲区 MQTT_TxDataInPtr[0] = size/256; //记录数据长度 MQTT_TxDataInPtr[1] = size%256; //记录数据长度 MQTT_TxDataInPtr+=TBUFF_UNIT; //指针下移 if(MQTT_TxDataInPtr==MQTT_TxDataEndPtr)//如果指针到缓冲区尾部了 MQTT_TxDataInPtr = MQTT_TxDataBuf[0]; //指针归位到缓冲区开头 } /*----------------------------------------------------------*/ /*函数名：处理命令缓冲区*/ /*参数：data：数据*/ /*参数：size：数据长度*/ /*返回值：无*/ /*----------------------------------------------------------*/ void CMDBuf_Deal(unsigned char *data, int size) { memcpy(&MQTT_CMDInPtr[2],data,size); //拷贝数据到命令缓冲区 MQTT_CMDInPtr[0] = size/256; //记录数据长度 MQTT_CMDInPtr[1] = size%256; //记录数据长度 MQTT_CMDInPtr[size+2] = '\0'; //加入字符串结束符 MQTT_CMDInPtr+=CBUFF_UNIT; //指针下移 if(MQTT_CMDInPtr==MQTT_CMDEndPtr)//如果指针到缓冲区尾部了 MQTT_CMDInPtr = MQTT_CMDBuf[0]; //指针归位到缓冲区开头 }

#ifndef __MQTT_H #define __MQTT_H#defineR_NUM5//接收缓冲区个数 #defineRBUFF_UNIT300//接收缓冲区长度#defineT_NUM5//发送缓冲区个数 #defineTBUFF_UNIT300//发送缓冲区长度#defineC_NUM5//命令缓冲区个数 #defineCBUFF_UNIT300//命令缓冲区长度#defineMQTT_TxData(x)u2_TxData(x)//串口2负责数据发送#definePRODUCTID"Car001"//ID #definePRODUCTID_LENstrlen(PRODUCTID)//ID长度 #defineDEVICEID"OurIoT"//用户名 #defineDEVICEID_LENstrlen(DEVICEID)//用户名长度 #defineAUTHENTICATION"000000"//密码 #defineAUTHENTICATION_LENstrlen(AUTHENTICATION)//密码长度 #defineS_TOPIC_NAME"t/c"//需要订阅的主题 #defineP_TOPIC_NAME"t/v"//需要发布的主题extern unsigned charMQTT_RxDataBuf[R_NUM][RBUFF_UNIT]; //外部变量声明，数据的接收缓冲区,所有服务器发来的数据，存放在该缓冲区,缓冲区第一个字节存放数据长度 extern unsigned char *MQTT_RxDataInPtr; //外部变量声明，指向缓冲区存放数据的位置 extern unsigned char *MQTT_RxDataOutPtr; //外部变量声明，指向缓冲区读取数据的位置 extern unsigned char *MQTT_RxDataEndPtr; //外部变量声明，指向缓冲区结束的位置 extern unsigned charMQTT_TxDataBuf[T_NUM][TBUFF_UNIT]; //外部变量声明，数据的发送缓冲区,所有发往服务器的数据，存放在该缓冲区,缓冲区第一个字节存放数据长度 extern unsigned char *MQTT_TxDataInPtr; //外部变量声明，指向缓冲区存放数据的位置 extern unsigned char *MQTT_TxDataOutPtr; //外部变量声明，指向缓冲区读取数据的位置 extern unsigned char *MQTT_TxDataEndPtr; //外部变量声明，指向缓冲区结束的位置 extern unsigned charMQTT_CMDBuf[C_NUM][CBUFF_UNIT]; //外部变量声明，命令数据的接收缓冲区 extern unsigned char *MQTT_CMDInPtr; //外部变量声明，指向缓冲区存放数据的位置 extern unsigned char *MQTT_CMDOutPtr; //外部变量声明，指向缓冲区读取数据的位置 extern unsigned char *MQTT_CMDEndPtr; //外部变量声明，指向缓冲区结束的位置extern char ClientID[128]; //外部变量声明，存放客户端ID的缓冲区 extern intClientID_len; //外部变量声明，存放客户端ID的长度 extern char Username[128]; //外部变量声明，存放用户名的缓冲区 extern intUsername_len; //外部变量声明，存放用户名的长度 extern char Passward[128]; //外部变量声明，存放密码的缓冲区 extern intPassward_len; //外部变量声明，存放密码的长度 extern char ServerIP[128]; //外部变量声明，存放服务器IP或是域名 extern intServerPort; //外部变量声明，存放服务器的端口号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 IoT_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

推荐阅读

• 

  防水涂料使用时有哪些技巧 防水涂料应该怎么操作
• 

  杨桃可以直接啃着吃吗
• 

  耳朵进水怎么去处理 洗澡,游泳后耳朵进水怎么办
• 

  mysql视图索引生效吗 mysql视图会有索引吗
• 

  阁楼摄影师 阁楼摄影招聘
• 

  犯爆炸刑事量刑标准有哪些 爆炸判什么刑
• 

  那些年的开源项目，你跑起来了吗（）
• 

  贾惜春的判词是什么意思 判词是什么意思
• 

  ipv4路由表分析,如何分析路由表
• 

  集合啦动物森友会可以玩多久
• 

  龙头电影影评 龙头电影剧情简介
• 

  破解版 百度云，手机百度网盘破解版可用免费的
• 

  保健鞋垫算什么， 保健内裤了解一下？ 保健内裤有什么用
• 

  王源高考分数王源高考分数是
• 

  就组词及解释
• 

  驾驶证档案编号怎么查? 驾驶证档案编号怎么查询公安交警官网
• 

  噬血代码steam预购多少钱
• 

  多肉植物多久浇一次水 多肉植物怎么浇水
• 

  儿媳妇与媳妇有什么区别？
• 

  mysql压缩包怎么卸载 解压版mysql怎么删除

• 跌跌撞撞奔向你|跌跌撞撞奔向你 第四章（你补英语，我补物理）
• 做一件事情的基本原理是什么（）
• 基于微信小程序带后端ssm接口小区物业管理平台设计
• 螃蟹和这些食物同吃，轻则腹泻、重则中毒！要小心哦~
• 做个俗物有什么不好
• 有句话忍很久了，女生要求买房怎么就物质了（）
• 球松
• 六一礼物
• 《有味》（做一个人间的烟火神仙）
• 鹿鸣高级营养老师徐老师分享应该注意的6种食物