欧美极品高清xxxxhd,国产日产欧美最新,无码AV国产东京热AV无码,国产精品人与动性XXX,国产传媒亚洲综合一区二区,四库影院永久国产精品,毛片免费免费高清视频,福利所导航夜趣136
標題:
STM32連接OneNET平臺 MQTT協議 源程序
[打印本頁]
作者:
暮雨亦成詩
時間:
2020-5-31 15:12
標題:
STM32連接OneNET平臺 MQTT協議 源程序
使用的是正點原子的mini板,設備是MQTT協議的。在代碼里改下產品ID啥的,還有無線網。
單片機源程序如下:
/*-----------------------------------------------------*/
/* 程序結構 */
/*-----------------------------------------------------*/
/*USER :包含程序的main函數,是整個程序的入口 */
/*HARDWARE :包含開發板各種功能外設的驅動程序 */
/*CORE :包含STM32的核心程序,官方提供, */
/*STLIB :官方提供的庫文件, */
/*-----------------------------------------------------*/
/* */
/* 程序main函數,入口函數源文件 */
/* */
/*-----------------------------------------------------*/
#include "stm32f10x.h" //包含需要的頭文件
#include "main.h" //包含需要的頭文件
#include "delay.h" //包含需要的頭文件
#include "usart1.h" //包含需要的頭文件
#include "usart2.h" //包含需要的頭文件
#include "timer1.h" //包含需要的頭文件
#include "timer2.h" //包含需要的頭文件
#include "timer3.h" //包含需要的頭文件
#include "timer4.h" //包含需要的頭文件
#include "timer5.h" //包含需要的頭文件
#include "wifi.h" //包含需要的頭文件
#include "led.h" //包含需要的頭文件
#include "mqtt.h" //包含需要的頭文件
#include "key.h" //包含需要的頭文件
#include "iic.h" //包含需要的頭文件
#include "dht11.h"
#include "bh1750.h"
#include "sr501.h"
char *CMD1 = "PC+CH1=C"; //通道1控制命令,狀態翻轉,停止->采集 采集->停止
char *CMD2 = "PC+CH2=C"; //通道2控制命令,狀態翻轉,停止->采集 采集->停止
char *CMD3 = "PC+SW1=C"; //開關1控制命令,狀態翻轉,開->關 關->開
char *CMD4 = "PC+SW2=C"; //開關2控制命令,狀態翻轉,開->關 關->開
char *CMD5 = "PC+STA=?"; //查詢2路開關狀態 和 采集狀態
char CH1_flag = 0; //通道1 溫度數據 是否處于采集狀態, 0:停止采集 1:采集中
char CH2_flag = 0; //通道2 濕度數據 是否處于采集狀態, 0:停止采集 1:采集中
int main(void)
{
Delay_Init(); //延時功能初始化
Usart1_Init(9600); //串口1功能初始化,波特率9600
Usart2_Init(115200); //串口2功能初始化,波特率115200
TIM4_Init(500,7200); //TIM4初始化,定時時間 500*7200*1000/72000000 = 50ms
LED_Init(); //LED初始化
KEY_Init(); //按鍵初始化
IIC_Init(); //初始化IIC接口
Init_BH1750();
SR501_Init();
WiFi_ResetIO_Init(); //初始化WiFi的復位IO
IoT_Parameter_Init(); //初始化云IoT平臺MQTT服務器的參數
while(1) //主循環
{
if(SR501)
{
}
/*--------------------------------------------------------------------*/
/* Connect_flag=1同服務器建立了連接,我們可以發布數據和接收推送了 */
/*--------------------------------------------------------------------*/
if(Connect_flag==1){
/*-------------------------------------------------------------*/
/* 處理發送緩沖區數據 */
/*-------------------------------------------------------------*/
if(MQTT_TxDataOutPtr != MQTT_TxDataInPtr){ //if成立的話,說明發送緩沖區有數據了
//3種情況可進入if
//第1種:0x10 連接報文
//第2種:0x82 訂閱報文,且ConnectPack_flag置位,表示連接報文成功
//第3種:SubcribePack_flag置位,說明連接和訂閱均成功,其他報文可發
if((MQTT_TxDataOutPtr[2]==0x10)||((MQTT_TxDataOutPtr[2]==0x82)&&(ConnectPack_flag==1))||(SubcribePack_flag==1)){
u1_printf("發送數據:0x%x\r\n",MQTT_TxDataOutPtr[2]); //串口提示信息
MQTT_TxData(MQTT_TxDataOutPtr); //發送數據
MQTT_TxDataOutPtr += TBUFF_UNIT; //指針下移
if(MQTT_TxDataOutPtr==MQTT_TxDataEndPtr) //如果指針到緩沖區尾部了
MQTT_TxDataOutPtr = MQTT_TxDataBuf[0]; //指針歸位到緩沖區開頭
}
}//處理發送緩沖區數據的else if分支結尾
/*-------------------------------------------------------------*/
/* 處理接收緩沖區數據 */
/*-------------------------------------------------------------*/
if(MQTT_RxDataOutPtr != MQTT_RxDataInPtr){ //if成立的話,說明接收緩沖區有數據了
u1_printf("接收到數據:");
/*-----------------------------------------------------*/
/* 處理CONNACK報文 */
/*-----------------------------------------------------*/
//if判斷,如果第一個字節是0x20,表示收到的是CONNACK報文
//接著我們要判斷第4個字節,看看CONNECT報文是否成功
if(MQTT_RxDataOutPtr[2]==0x20){
switch(MQTT_RxDataOutPtr[5]){
case 0x00 : u1_printf("CONNECT報文成功\r\n"); //串口輸出信息
ConnectPack_flag = 1; //CONNECT報文成功,訂閱報文可發
break; //跳出分支case 0x00
case 0x01 : u1_printf("連接已拒絕,不支持的協議版本,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case 0x01
case 0x02 : u1_printf("連接已拒絕,不合格的客戶端標識符,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case 0x02
case 0x03 : u1_printf("連接已拒絕,服務端不可用,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case 0x03
case 0x04 : u1_printf("連接已拒絕,無效的用戶名或密碼,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case 0x04
case 0x05 : u1_printf("連接已拒絕,未授權,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case 0x05
default : u1_printf("連接已拒絕,未知狀態,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支case default
}
}
//if判斷,第一個字節是0x90,表示收到的是SUBACK報文
//接著我們要判斷訂閱回復,看看是不是成功
else if(MQTT_RxDataOutPtr[2]==0x90){
switch(MQTT_RxDataOutPtr[6]){
case 0x00 :
case 0x01 : u1_printf("訂閱成功\r\n"); //串口輸出信息
SubcribePack_flag = 1; //SubcribePack_flag置1,表示訂閱報文成功,其他報文可發送
Ping_flag = 0; //Ping_flag清零
TIM3_ENABLE_30S(); //啟動30s的PING定時器
break; //跳出分支
default : u1_printf("訂閱失敗,準備重啟\r\n"); //串口輸出信息
Connect_flag = 0; //Connect_flag置零,重啟連接
break; //跳出分支
}
}
//if判斷,第一個字節是0xD0,表示收到的是PINGRESP報文
else if(MQTT_RxDataOutPtr[2]==0xD0){
u1_printf("PING報文回復\r\n"); //串口輸出信息
if(Ping_flag==1){ //如果Ping_flag=1,表示第一次發送
Ping_flag = 0; //要清除Ping_flag標志
}else if(Ping_flag>1){ //如果Ping_flag>1,表示是多次發送了,而且是2s間隔的快速發送
Ping_flag = 0; //要清除Ping_flag標志
TIM3_ENABLE_30S(); //PING定時器重回30s的時間
}
}
//if判斷,如果第一個字節是0x30,表示收到的是服務器發來的推送數據
//我們要提取控制命令
else if((MQTT_RxDataOutPtr[2]==0x30)){
u1_printf("服務器等級0推送\r\n"); //串口輸出信息
MQTT_DealPushdata_Qs0(MQTT_RxDataOutPtr); //處理等級0推送數據
}
MQTT_RxDataOutPtr +=RBUFF_UNIT; //指針下移
if(MQTT_RxDataOutPtr==MQTT_RxDataEndPtr) //如果指針到緩沖區尾部了
MQTT_RxDataOutPtr = MQTT_RxDataBuf[0]; //指針歸位到緩沖區開頭
}//處理接收緩沖區數據的else if分支結尾
/*-------------------------------------------------------------*/
/* 處理命令緩沖區數據 */
/*-------------------------------------------------------------*/
if(MQTT_CMDOutPtr != MQTT_CMDInPtr){ //if成立的話,說明命令緩沖區有數據了
MQTT_CMDOutPtr[MQTT_CMDOutPtr[0]+1] = '\0'; //加入字符串結束符
u1_printf("命令:%s\r\n",&MQTT_CMDOutPtr[2]); //串口輸出信息
if(!memcmp(&MQTT_CMDOutPtr[2],CMD1,strlen(CMD1))){ //判斷指令,如果是CMD1
if(CH1_flag==0){ //如果,CH1_flag等于0,表示當前處于停止采集狀態,我們開始采集
CH1_flag = 1; //CH1_flag置1,表示處于采集狀態了
TIM5_ENABLE_10S(); //定時器1,,10s間隔采集溫度
}else{ //反之,DCH1_flag等于1,表示當前處于采集狀態,我們停止
CH1_flag = 0; //CH1_flag置1,表示處于停止狀態了
TIM_Cmd(TIM5,DISABLE); //關TIM2
}
CH_SW_State(); //判斷2路通道,2路開關狀態,并發布給服務器
}else if(!memcmp(&MQTT_CMDOutPtr[2],CMD2,strlen(CMD2))){ //判斷指令,如果是CMD2
if(CH2_flag==0){ //如果,CH2_flag等于0,表示當前處于停止采集狀態,我們開始采集
CH2_flag = 1; //CH2_flag置1,表示處于采集狀態了
TIM2_ENABLE_10S(); //定時器2,,10s間隔采集溫度
}else{ //反之,DCH2_flag等于1,表示當前處于采集狀態,我們停止
CH2_flag = 0; //CH2_flag置0,表示處于停止狀態了
TIM_Cmd(TIM2,DISABLE); //關TIM2
}
CH_SW_State(); //判斷2路通道,2路開關狀態,并發布給服務器
}else if(!memcmp(&MQTT_CMDOutPtr[2],CMD3,strlen(CMD3))){ //判斷指令,如果是CMD3
LED1_OUT(!LED1_IN_STA); //開關1狀態翻轉 如果點亮就熄滅,反之如果熄滅就點亮 //我們只有兩路,第3路通道,不做處理,僅返回狀態
CH_SW_State(); //判斷2路通道,2路開關狀態,并發布給服務器
}else if(!memcmp(&MQTT_CMDOutPtr[2],CMD4,strlen(CMD4))){ //判斷指令,如果是CMD4
LED2_OUT(!LED2_IN_STA); //開關2狀態翻轉 如果點亮就熄滅,反之如果熄滅就點亮 //我們只有兩路,第4路通道,不做處理,僅返回狀態
CH_SW_State(); //判斷2路通道,2路開關狀態,并發布給服務器
}else if(!memcmp(&MQTT_CMDOutPtr[2],CMD5,strlen(CMD5))){ //判斷指令,如果是CMD5
CH_SW_State(); //判斷2路通道,2路開關狀態,并發布給服務器
}else u1_printf("未知指令\r\n"); //串口輸出信息
MQTT_CMDOutPtr += CBUFF_UNIT; //指針下移
if(MQTT_CMDOutPtr==MQTT_CMDEndPtr) //如果指針到緩沖區尾部了
MQTT_CMDOutPtr = MQTT_CMDBuf[0]; //指針歸位到緩沖區開頭
}//處理命令緩沖區數據的else if分支結尾
}//Connect_flag=1的if分支的結尾
/*--------------------------------------------------------------------*/
/* Connect_flag=0同服務器斷開了連接,我們要重啟連接服務器 */
/*--------------------------------------------------------------------*/
else{
u1_printf("需要連接服務器\r\n"); //串口輸出信息
TIM_Cmd(TIM4,DISABLE); //關閉TIM4
TIM_Cmd(TIM3,DISABLE); //關閉TIM3
WiFi_RxCounter=0; //WiFi接收數據量變量清零
memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE); //清空WiFi接收緩沖區
if(WiFi_Connect_IoTServer()==0){ //如果WiFi連接云服務器函數返回0,表示正確,進入if
u1_printf("建立TCP連接成功\r\n"); //串口輸出信息
Connect_flag = 1; //Connect_flag置1,表示連接成功
WiFi_RxCounter=0; //WiFi接收數據量變量清零
memset(WiFi_RX_BUF,0,WiFi_RXBUFF_SIZE); //清空WiFi接收緩沖區
MQTT_Buff_Init(); //初始化發送緩沖區
}
}
}
}
/*-------------------------------------------------*/
/*函數名:判斷2路通道,2路開關狀態,并發布給服務器 */
/*參 數:無 */
/*返回值:無 */
/*-------------------------------------------------*/
void CH_SW_State(void)
{
char temp[10]; //定義一個臨時緩沖區
memset(temp,0,10); //清空臨時緩沖區
sprintf(temp,"+STA:"); //構建回復數據
if(LED1_IN_STA) temp[5] = '0'; //如果LED1是高電平,說明是熄滅狀態,開關1狀態位置0
else temp[5] = '1'; //反之,說明是點亮狀態,開關1狀態位置1
if(LED2_IN_STA) temp[6] = '0'; //如果LED2是高電平,說明是熄滅狀態,開關2狀態位置0
else temp[6] = '1'; //反之,說明是點亮狀態,開關2狀態位置1
if(CH1_flag==0) temp[7] = '0'; //如果,CH1_flag等于0,表示當前通道1處于停止采集狀態,狀態位置0
else temp[7] = '1'; //反之,CH1_flag等于1,表示當前通道1處于采集狀態,狀態位置1
if(CH2_flag==0) temp[8] = '0'; //如果,CH2_flag等于0,表示當前通道2處于停止采集狀態,狀態位置0
else temp[8] = '1'; //反之,CH2_flag等于1,表示當前通道2處于采集狀態,狀態位置1
MQTT_PublishQs0(P_TOPIC_NAME,temp,9); //添加數據,發布給服務器
}
復制代碼
所有程序51hei提供下載:
Test.7z
(221.15 KB, 下載次數: 81)
2020-5-31 15:37 上傳
點擊文件名下載附件
下載積分: 黑幣 -5
作者:
swustlx86
時間:
2020-6-1 02:04
好資料,51黑有你更精彩!!!
作者:
wenhuaxiao
時間:
2020-6-1 09:35
WIFI用的是那個芯片呢
歡迎光臨 (http://m.raoushi.com/bbs/)
Powered by Discuz! X3.1