STM32连接阿里云物联网平台

文章目录

  • 引言
  • 一、STM32连接阿里云物联网平台思路
  • 二、ESP8266烧录固件
  • 三、使用AT指令连接阿里云物联网平台
  • 四、STM32环形串口缓冲区驱动程序
  • 五、STM32连接阿里云驱动程序

引言

连续写了两篇关于阿里云连接的文章,都是使用Arduino ESP8266 & Arduino ESP32的方式:
1、Arduino ESP8266&ESP32使用AliyunIoTSDK.h连接阿里云物联网平台
2、使用ArduinoMqttClient库连接阿里云,并实现发送接收数据(ESP8266)

但是,使用Arduino的方式处理阿里云的数据在简单的电子小制作、毕业设计完全可以胜任,但是Arduino的核心库都是对底层进行二次封装,运行效率难免会低一些。ESP8266与ESP32作为主控的MCU,功能有限,在这种情况下,就会想到使用STM32搭载一个可以联网的芯片来做数据物联网的开发了。
我在企业开发项目中,接触过新能源汽车充电桩,核心是使用STM32F103VET6进行主控,它通过搭载一个4G模块来对云端数据进行处理。设备上线时,后台有上线的提示;管理员可用户都可以查看到充电桩的实时状态,如下图所示,管理员坐在办公室便可以查看到有两个慢充桩处于空闲状态,有一个充电桩已连接车辆,但是并没有开始充电,我们就可以猜测出用户可能刚刚到达,已将插枪连接车辆,正在进行扫码的操作。
请添加图片描述
平台更会报一些简单的故障,如急停故障,充电桩安装的环境多种多样,有时会有小朋友误触到急停故障导致充电桩报故障,不能充电,这时用户打电话给运维的客服,便可以在运维客服的提示下把急停按键复原,充电桩便可以正常使用。
通过物联网技术来对新能源汽车充电桩进行控制大大的减轻的运营的成本,在其他行业如加油站无人值守的自动洗车机、学校教学楼的自动贩卖机等等,都是物联网控制的一个范例,如今物联网控制技术更是影响着我们生活的方方面面。

文章使用基础型STM32F1作为主控芯片,搭载ESP8266模块,使用环形串口缓冲区算法连接阿里云平台,实现数据的订阅和发布。文章有一点点的深度,我尽量把每一个细节每一个步都骤掰开来,嚼碎去详细说明。
有很多例程在数据收发这一块都使用数组进行数据的接收,对付一些简单的物联网开发完全是没有问题的,而环形串口缓冲区算法是在大规模数据接收时使用的,在这么简单的物联网数据收发中使用难免会影响效率。
是的,在这么简单的物联网数据的收发我还使用环形串口缓冲区,影响一定的运行的效率是一定。但是,长期做开发的一定要留有有方便后期升级维护的一个思维,一些升级接口需要多预留一些,产品都不是一次做出来的,是一代一代逐渐完善,逐渐更新换代的。

一、STM32连接阿里云物联网平台思路

连接思路其实很简单,只要两步就好了:
1、烧录MQTT的固件
2、STM32使能串口通过AT指令连接阿里云物联网平台

我使用的是ESP8266作为联网设备,连接阿里云物联网平台,之前我使用Arduino的方式连接阿里云平台也是同样的原理,但是Arduino将一些底层的函数进行了封装,我们只需要学会使用Arduino提供的一些库便可以连接阿里云物联网平台进行数据交换。
而STM32则没有相关的库,我们需要烧录好MQTT的固件,通过电脑串口助手先连接成功阿里云物联网平台,测试好订阅和发布的功能后,连接我们STM32串口,进行简单的串口数据收发。

二、ESP8266烧录固件

连接物联网云平台之前先需要烧录相关固件,固件地址如下:
安信可固件汇总
我选择第4个固件,固件的下载地址附有官方的使用说明。
因为技术更新迭代的速度非常快,可能我的这一篇文章发布几个月或半年后固件便开始更新,但都是换汤不换药,掌握了连接的原理,我们也可以自行查看官方的文档来进行连接,此篇文章可以作为非常重要的参考使用。
在这里插入图片描述
下载完成后便可以烧录固件,烧录固件的软件可以通过官网下载,我这里也提供一个网盘下载连接:
链接:https://pan.baidu.com/s/1H96ZbeG_ogslrJUz2Y162w
提取码:wslw
软件打开后,安装提示很容易就可以将固件烧录进去,下图是我烧录成功的截图界面:
请添加图片描述

三、使用AT指令连接阿里云物联网平台

固件烧录成功之后,首先需要使用电脑的串口助手软件,通过简单的AT指令连接WiFi,连接阿里云,然后完成订阅和发布数据,确认好AT指令代码没有问题后,我们才把相关的AT指令封装起来,写进程序中,连接的AT指令只需要熟悉常用的几个即可。

指令功能
AT测试
AT+RST重启
AT+CWMODE=1设置为无线终端模式,可以连接WiFi
AT+CWJAP=“wifi”,“passwd”连接热点
AT+CWSTATE?查询WiFi连接讲解状态
AT+MQTTUSERCFG=0,1,“clientId”,“username”,“password”,0,0,“”设置MQTT连接参数
AT+MQTTCONN=0,“Broker Address”,1883,1连接阿里云
AT+MQTTCONN?查询MQTT连接状态
AT+MQTTSUB=0,“topic”,0订阅主题
AT+MQTTPUB=0,“topic”,“msg”发布主题

AT指令按照如下通过串口助手发送到ESP8266即可完成阿里云的连接
请添加图片描述
(1)判断ESP8266是否存在
使用指令:AT\r\n
串口回复:OK

备注:使用串口助手和STM32发送指令的时候,结尾加上\r\n,表示指令结束

(2)设置ESP8266为接入点模式
使用指令:AT+CWMODE=1\r\n
串口回复:OK

(3)查询WiFi是否连接成功
使用指令:AT+CWSTATE?
串口回复:

+CWSTATE:2"CMCC-H3qz"	//备注:CMCC-H3qz是我的WiFi名OK

(4)如果没有连接WiF,则连接WiFi
使用指令:AT+CWJAP=“CMCC-H3qz”,“7xf47uxf”\r\n
备注:CMCC-H3qz是我的WiFi名,7xf47uxf是我的WiFi密码

串口回复:

AT+CWJAP="CMCC-H3qz""7xf47uxf"
WIFI DISCONNECT
WIFI CONNECTED
WIFI GOT IPOK

(5)设置MQTT参数
使用指令:
AT+MQTTUSERCFG=0,1,“clientId”,“username”,“password”,0,0,“”\r\n
示例:
AT+MQTTUSERCFG=0,1,"k0efkfcSwlt.Device_Demo|securemode=2\,signmethod=hmacsha256\,timestamp=1705149361131|","Device_Demo&k0efkfcSwlt","ea343ac1d6a4eec7b057bcab39a2ffdf88abc8b810ec0dc7ca3de91a56292ff9",0,0,""\r\n
备注:
1、指令中,遇到“,”字符时,使用“\”隔开,避免报错。
2、clientId,username,password这些数据从阿里云物联网平台获取
在这里插入图片描述
串口回复:

AT+MQTTUSERCFG=01"k0efkfcSwlt.Device_Demo|securemode=2\signmethod=hmacsha256\timestamp=1705149361131|""Device_Demo&k0efkfcSwlt""ea343ac1d6a4eec7b057bcab39a2ffdf88abc8b810ec0dc7ca3de91a56292ff9"00""OK

(6)连接阿里云
使用指令:AT+MQTTCONN=0,“Broker Address”,1883,1\r\n
示例:
AT+MQTTCONN=0,"k0efkfcSwlt.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883,1\r\n
备注:
Broker Address为MQTT域名,阿里云物联网平台开发者文档有详细的解释,我在以前的文章也对这方面进行了详细的说明,大家可以尝试一下使用MQTT.fx连接阿里云平台就能明白MQTT域名的作用了。
附上这部分云文档的地址:
使用MQTT.fx接入物联网平台
在这里插入图片描述
串口回复:

AT+MQTTCONN=0"k0efkfcSwlt.iot-as-mqtt.cn-shanghai.aliyuncs.com"18831
+MQTTCONNECTED:01"k0efkfcSwlt.iot-as-mqtt.cn-shanghai.aliyuncs.com""1883"""1OK

这时,我们登陆阿里云物联网平台,可以看到设备已成功连接阿里云物联网平台。
在这里插入图片描述
(7)发布数据
使用指令:AT+MQTTPUB=0,“topic”,“msg”\r\n
示例:
AT+MQTTPUB=0,"/sys/k0efkfcSwlt/Device_Demo/thing/event/property/post","{\"params\": {\"temperature\": 10.5}\,\"version\": \"1.0\"}",0,0\r\n
备注:
1、topic从阿里云平台获取
在这里插入图片描述
2、msg有一定的格式,在阿里云平台的开发者文档里也有详细的说明,附上文档连接:
阿里云物联网平台设备上报属性
示例中上报的属性为:温度10.5。
3、使用这个指令遇到" “ ”的时候,学会使用专业字符“\”。

串口回复:

AT+MQTTPUB=0"/sys/k0efkfcSwlt/Device_Demo/thing/event/property/post""{\"params\": {\"temperature\": 10.5}\\"version\": \"1.0\"}"00OK

我们查看阿里云物联网平台物模型数据,可以看到阿里云已成功接收数据。
在这里插入图片描述

(8)订阅数据
使用指令:AT+MQTTSUB=0,“topic”,0\r\n
示例:AT+MQTTSUB=0,"/sys/k0efkfcSwlt/Device_Demo/thing/service/property/set",0
备注:topic从阿里云物联网平台获取
在这里插入图片描述
串口回复:

AT+MQTTSUB=0"/sys/k0efkfcSwlt/Device_Demo/thing/service/property/set"0OK

这时,我们通过在线调试测试订阅数据是否成功。
在这里插入图片描述
我们在阿里云平台自定义了一盏LED灯,通过在线调试的方式,发送开启和关闭的命令,如果订阅没有问题的话,可以看到如下串口回复:

+MQTTSUBRECV:0"/sys/k0efkfcSwlt/Device_Demo/thing/service/property/set"100{"method":"thing.service.property.set""id":"2001671834""params":{"LEDSwitch":0}"version":"1.0.0"}
+MQTTSUBRECV:0"/sys/k0efkfcSwlt/Device_Demo/thing/service/property/set"100{"method":"thing.service.property.set""id":"2046606498""params":{"LEDSwitch":1}"version":"1.0.0"}

可以看到json数据里LEDSwitch的变换,这时,我们就可以在单片机上,处理这条指令来实现LED的亮灭,实现阿里云物联网平台控制led。

如果顺利到这一步,那么恭喜你,现在距离成功仅剩一半的距离了,接下来只需将AT指令封装到STM32的代码中,进行简单的STM32串口操作,就可以实现使用STM32连接阿里云的操作了。

四、STM32环形串口缓冲区驱动程序

环形串口缓冲区的原理可以查看这篇文章:环形串口缓冲区

明白了环形串口缓冲区的原理,在STM32开发中,先写好串口的驱动程序,然后再编写环形串口缓冲区程序,下面是驱动程序,我都有注释,学过STM32的都能看得懂。

usart.c

/********************************************************************************* @file    usart.c* @author  小途* @version V1.0* @date    2022-2-21* @brief   STM32F1的串口初始化设置******************************************************************************* @attention* 串口2配置环形串口缓冲区********************************************************************************/#include "usart.h"#define UART_RX_MAX 255		//数组最大值//环形缓冲区结构体
typedef struct
{uint8_t head_count;					//头计数uint8_t tail_count;					//尾计数uint8_t buf[UART_RX_MAX];		//缓冲区数组
}UART_S;UART_S uart;//定义串口缓冲区结构体变量//串口环形缓冲区初始化
void uart_Buffer_Init(void)
{int i;uart.head_count = 0;uart.tail_count = 0;for(i=0; i<UART_RX_MAX; i++){uart.buf[i] = 0x00;}
}//往缓冲器里放数据
void uart_buf_put(uint8_t ch)
{uart.buf[uart.head_count++] = ch;if(uart.head_count == UART_RX_MAX){uart.head_count = 0;}
}//判断缓冲区是否有数据
int fifo_is_empty(void)
{if(uart.head_count != uart.tail_count)//判断如果头不等于尾{return 0;//有数据}else return 1;//无数据
}//从缓冲区取数据
int uart_buf_get(uint8_t *ch)
{if(fifo_is_empty() == 0)//如果有数据{*ch = uart.buf[uart.tail_count++];//取数据if(uart.tail_count == UART_RX_MAX){uart.tail_count = 0;}	return 1;//返回成功}else return 0;//返回失败
}//读数据,将数据通过串口发送出去
void debug_read(void)
{uint8_t ch;/*如果有数据就一直取,直到取完为至*/while(!fifo_is_empty()){if(uart_buf_get(&ch)){putchar(ch);}}
}/*** @brief  配置嵌套向量中断控制器NVIC* @param  无* @retval 无*/
void NVIC_Configuration(void)
{NVIC_InitTypeDef NVIC_InitStructure;/* 嵌套向量中断控制器组选择 */NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);/* 配置USART为中断源 */NVIC_InitStructure.NVIC_IRQChannel = DEBUG_USART_IRQ;/* 抢断优先级*/NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1;/* 子优先级 */NVIC_InitStructure.NVIC_IRQChannelSubPriority = 2;/* 使能中断 */NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;/* 初始化配置NVIC */NVIC_Init(&NVIC_InitStructure);
}//对串口2配置嵌套向量中断控制器NVIC
void NVIC_USART2_Configuration(void)
{NVIC_InitTypeDef NVIC_InitStructure;/* 嵌套向量中断控制器组选择 */NVIC_PriorityGroupConfig(NVIC_PriorityGroup_2);/* 配置USART为中断源 */NVIC_InitStructure.NVIC_IRQChannel = DEBUG_USART2_IRQ;/* 抢断优先级*/NVIC_InitStructure.NVIC_IRQChannelPreemptionPriority = 1;/* 子优先级 */NVIC_InitStructure.NVIC_IRQChannelSubPriority = 1;/* 使能中断 */NVIC_InitStructure.NVIC_IRQChannelCmd = ENABLE;/* 初始化配置NVIC */NVIC_Init(&NVIC_InitStructure);
}/*** @brief  USART GPIO 配置,工作参数配置* @param  无* @retval 无*/
void USART_Config(void)
{GPIO_InitTypeDef GPIO_InitStructure;USART_InitTypeDef USART_InitStructure;// 打开串口GPIO的时钟DEBUG_USART_GPIO_APBxClkCmd(DEBUG_USART_GPIO_CLK, ENABLE);// 打开串口外设的时钟DEBUG_USART_APBxClkCmd(DEBUG_USART_CLK, ENABLE);// 将USART Tx的GPIO配置为推挽复用模式GPIO_InitStructure.GPIO_Pin = DEBUG_USART_TX_GPIO_PIN;GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;GPIO_Init(DEBUG_USART_TX_GPIO_PORT, &GPIO_InitStructure);// 将USART Rx的GPIO配置为浮空输入模式GPIO_InitStructure.GPIO_Pin = DEBUG_USART_RX_GPIO_PIN;GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;GPIO_Init(DEBUG_USART_RX_GPIO_PORT, &GPIO_InitStructure);// 配置串口的工作参数// 配置波特率USART_InitStructure.USART_BaudRate = DEBUG_USART_BAUDRATE;// 配置 针数据字长USART_InitStructure.USART_WordLength = USART_WordLength_8b;// 配置停止位USART_InitStructure.USART_StopBits = USART_StopBits_1;// 配置校验位USART_InitStructure.USART_Parity = USART_Parity_No ;// 配置硬件流控制USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;// 配置工作模式,收发一起USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx;// 完成串口的初始化配置USART_Init(DEBUG_USARTx, &USART_InitStructure);// 串口中断优先级配置//NVIC_Configuration();// 使能串口接收中断//USART_ITConfig(DEBUG_USARTx, USART_IT_RXNE, ENABLE);	// 使能串口USART_Cmd(DEBUG_USARTx, ENABLE);	    
}/*** @brief  USART2 GPIO 配置,工作参数配置,配置环形串口缓冲区* @param  无* @retval 无*/
void USART2_Config(void)
{//在串口2配置环形串口缓冲区//初始化环形串口缓冲区uart_Buffer_Init();GPIO_InitTypeDef GPIO_InitStructure;USART_InitTypeDef USART_InitStructure;// 打开串口GPIO的时钟DEBUG_USART2_GPIO_APBxClkCmd(DEBUG_USART2_GPIO_CLK, ENABLE);// 打开串口外设的时钟DEBUG_USART2_APBxClkCmd(DEBUG_USART2_CLK, ENABLE);// 将USART Tx的GPIO配置为推挽复用模式GPIO_InitStructure.GPIO_Pin = DEBUG_USART2_TX_GPIO_PIN;GPIO_InitStructure.GPIO_Mode = GPIO_Mode_AF_PP;GPIO_InitStructure.GPIO_Speed = GPIO_Speed_50MHz;GPIO_Init(DEBUG_USART2_TX_GPIO_PORT, &GPIO_InitStructure);// 将USART Rx的GPIO配置为浮空输入模式GPIO_InitStructure.GPIO_Pin = DEBUG_USART2_RX_GPIO_PIN;GPIO_InitStructure.GPIO_Mode = GPIO_Mode_IN_FLOATING;GPIO_Init(DEBUG_USART2_RX_GPIO_PORT, &GPIO_InitStructure);// 配置串口的工作参数// 配置波特率USART_InitStructure.USART_BaudRate = DEBUG_USART2_BAUDRATE;// 配置 针数据字长USART_InitStructure.USART_WordLength = USART_WordLength_8b;// 配置停止位USART_InitStructure.USART_StopBits = USART_StopBits_1;// 配置校验位USART_InitStructure.USART_Parity = USART_Parity_No ;// 配置硬件流控制USART_InitStructure.USART_HardwareFlowControl = USART_HardwareFlowControl_None;// 配置工作模式,收发一起USART_InitStructure.USART_Mode = USART_Mode_Rx | USART_Mode_Tx;// 完成串口的初始化配置USART_Init(DEBUG_USART2, &USART_InitStructure);	//串口2中断优先级配置NVIC_USART2_Configuration();//使能串口2接收中断USART_ITConfig(DEBUG_USART2, USART_IT_RXNE, ENABLE);// 使能串口//USART_Cmd(DEBUG_USART2, ENABLE);	    
}/*****************  发送一个字符 **********************/
void Usart_SendByte( USART_TypeDef * pUSARTx, uint8_t ch)
{/* 发送一个字节数据到USART */USART_SendData(pUSARTx,ch);/* 等待发送数据寄存器为空 */while (USART_GetFlagStatus(pUSARTx, USART_FLAG_TXE) == RESET);	
}/*****************  发送字符串 **********************/
void Usart_SendString( USART_TypeDef * pUSARTx, char *str)
{unsigned int k=0;do {Usart_SendByte( pUSARTx, *(str + k) );k++;} while(*(str + k)!='\0');/* 等待发送完成 */while(USART_GetFlagStatus(pUSARTx,USART_FLAG_TC)==RESET);
}//发送整形数据字符串(发送长字符串)
void Usart_SendIntString( USART_TypeDef * pUSARTx, int *str)
{int k=0;do {Usart_SendByte( pUSARTx, *(str + k) );k++;} while(*(str + k)!='\0');/* 等待发送完成 */while(USART_GetFlagStatus(pUSARTx,USART_FLAG_TC)==RESET);
}//重定向c库函数printf到串口,重定向后可使用printf函数,默认使用串口1
int fputc(int ch, FILE *f)
{/* 发送一个字节数据到串口 */USART_SendData(DEBUG_USART1, (uint8_t) ch);/* 等待发送完毕 */while (USART_GetFlagStatus(DEBUG_USART1, USART_FLAG_TXE) == RESET);		return (ch);
}//重定向c库函数scanf到串口,重写向后可使用scanf、getchar等函数,默认使用串口1
int fgetc(FILE *f)
{/* 等待串口输入数据 */while (USART_GetFlagStatus(DEBUG_USART1, USART_FLAG_RXNE) == RESET);return (int)USART_ReceiveData(DEBUG_USART1);
}

usart.h

#ifndef __USART_H
#define __USART_H#include "stm32f10x.h"
#include <stdio.h>/** 串口宏定义,不同的串口挂载的总线不一样,移植时需要修改这几个宏*/// 串口1-USART1
#define  DEBUG_USARTx                   USART1
#define  DEBUG_USART_CLK                RCC_APB2Periph_USART1
#define  DEBUG_USART_APBxClkCmd         RCC_APB2PeriphClockCmd
#define  DEBUG_USART_BAUDRATE           115200// USART GPIO 引脚宏定义
#define  DEBUG_USART_GPIO_CLK           (RCC_APB2Periph_GPIOA)
#define  DEBUG_USART_GPIO_APBxClkCmd    RCC_APB2PeriphClockCmd#define  DEBUG_USART_TX_GPIO_PORT       GPIOA   
#define  DEBUG_USART_TX_GPIO_PIN        GPIO_Pin_9
#define  DEBUG_USART_RX_GPIO_PORT       GPIOA
#define  DEBUG_USART_RX_GPIO_PIN        GPIO_Pin_10#define  DEBUG_USART_IRQ                USART1_IRQn
#define  DEBUG_USART_IRQHandler         USART1_IRQHandler//------------------------------------------------------------------------// 串口1-USART1
#define  DEBUG_USART1                    USART1
#define  DEBUG_USART1_CLK                RCC_APB2Periph_USART1
#define  DEBUG_USART1_APBxClkCmd         RCC_APB2PeriphClockCmd
#define  DEBUG_USART1_BAUDRATE           115200// USART GPIO 引脚宏定义
#define  DEBUG_USART1_GPIO_CLK           (RCC_APB2Periph_GPIOA)
#define  DEBUG_USART1_GPIO_APBxClkCmd    RCC_APB2PeriphClockCmd#define  DEBUG_USART1_TX_GPIO_PORT       GPIOA   
#define  DEBUG_USART1_TX_GPIO_PIN        GPIO_Pin_9
#define  DEBUG_USART1_RX_GPIO_PORT       GPIOA
#define  DEBUG_USART1_RX_GPIO_PIN        GPIO_Pin_10#define  DEBUG_USART1_IRQ                USART1_IRQn
#define  DEBUG_USART1_IRQHandler         USART1_IRQHandler//------------------------------------------------------------------------// 串口2-USART2
#define  DEBUG_USART2                   	USART2
#define  DEBUG_USART2_CLK                	RCC_APB1Periph_USART2
#define  DEBUG_USART2_APBxClkCmd         	RCC_APB1PeriphClockCmd
#define  DEBUG_USART2_BAUDRATE           	115200// USART GPIO 引脚宏定义
#define  DEBUG_USART2_GPIO_CLK           	(RCC_APB2Periph_GPIOA)
#define  DEBUG_USART2_GPIO_APBxClkCmd    	RCC_APB2PeriphClockCmd#define  DEBUG_USART2_TX_GPIO_PORT        GPIOA   
#define  DEBUG_USART2_TX_GPIO_PIN         GPIO_Pin_2
#define  DEBUG_USART2_RX_GPIO_PORT       	GPIOA
#define  DEBUG_USART2_RX_GPIO_PIN        	GPIO_Pin_3#define  DEBUG_USART2_IRQ                	USART2_IRQn
#define  DEBUG_USART2_IRQHandler         	USART2_IRQHandler//使能串口2
#define USART2_ON													USART_Cmd(DEBUG_USART2, ENABLE);
//失能串口2
#define USART2_OFF												USART_Cmd(DEBUG_USART2, DISABLE);//环形串口缓冲区相关功能函数
void uart_buf_put(uint8_t ch);
void debug_read(void);
int fifo_is_empty(void);
int uart_buf_get(uint8_t *ch);//STM32串口相关功能函数
void USART_Config(void);
void USART2_Config(void);
void Usart_SendByte( USART_TypeDef * pUSARTx, uint8_t ch);
void Usart_SendString( USART_TypeDef * pUSARTx, char *str);
void Usart_SendIntString( USART_TypeDef * pUSARTx, int *str);#endif

stm32f10x_it.c

//串口2中断服务函数
//将串口2接收到的数据回传到串口1
void USART2_IRQHandler(void)
{uint8_t ucTemp;if(USART_GetITStatus(DEBUG_USART2,USART_IT_RXNE)!=RESET){		ucTemp = USART_ReceiveData(DEBUG_USART2);uart_buf_put(ucTemp);//往环形串口缓冲区存数据}	 
}

五、STM32连接阿里云驱动程序

STM32连接阿里云程序逻辑与串口助手的一致,之前使用串口助手与我的电脑进行数据交换,现在将STM32当成一个小型的“电脑”,使用STM32来对ESP8266的数据进行处理,达到物联网控制的目的。
我使用的是STM32霸道的开发板做的测试例程, 使用杜邦线连接ESP8266模块,以下的厂程序供大家参考,如有问题望指摘。
esp8266.c

/********************************************************************************* @file    esp8266.c* @author  fire* @version V1.0* @date    2024-1-16* @brief   esp8266连接阿里云物联网平台******************************************************************************
**/#include "./ESP8266/esp8266.h"//测试esp8266是否存在
//向串口2发送“AT”,esp8266收到后会回复一个“Ok”
//STM32会将串口2收到的数据转发到串口1,用于监视串口2状态
//函数需要提前初始化串口1,串口2,串口2中断接收
//成功读取到esp8266返回1,否则返回0
char esp8266_text(void)
{uint8_t ch;uint8_t str[20], i=0;char* pch;//发送测试命令Usart_SendString(DEBUG_USART2, "AT\r\n");//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1
//	Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");
//	Usart_SendString(DEBUG_USART1, (char *)str);
//	Usart_SendString(DEBUG_USART1, "\r\n");pch = strstr((char *)str, "OK");if(pch != NULL){Usart_SendString(DEBUG_USART1, "esp8266真实存在\r\n");return 1;}elsereturn 0;
}//esp8266重启
void esp8266_restart(void)
{uint8_t ch;uint8_t str[255], i=0;//发送命令Usart_SendString(DEBUG_USART2, "AT+RST\r\n");//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");Usart_SendString(DEBUG_USART1, (char *)str);Usart_SendString(DEBUG_USART1, "\r\n");
}//将esp8266设置为接入点模式
//设置成功返回1,失败返回0
char esp8266_setStation(void)
{uint8_t ch;uint8_t str[20], i=0;	char* pch;//发送命令Usart_SendString(DEBUG_USART2, "AT+CWMODE=1\r\n");//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1
//	Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");
//	Usart_SendString(DEBUG_USART1, (char *)str);
//	Usart_SendString(DEBUG_USART1, "\r\n");pch = strstr((char *)str, "OK");if(pch != NULL)return 1;elsereturn 0;
}//查询WiFi连接信息
//如果成功连接WiFi返回1,否则返回0
char esp8266_inquireWiFi_Data(void)
{uint8_t ch;uint8_t str[255], i=0;char* pch;//发送命令Usart_SendString(DEBUG_USART2, "AT+CWSTATE?\r\n");//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1
//	Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");
//	Usart_SendString(DEBUG_USART1, (char *)str);
//	Usart_SendString(DEBUG_USART1, "\r\n");pch = strchr((char *)str, '2');if(pch != NULL)return 1;elsereturn 0;
}//连接WiFi
void esp8266_connectWiFi(void)
{uint8_t ch, i=0;char str[255];//将要发送的数据拼接起来char wifi_data[255] = "AT+CWJAP=\"";strcat(wifi_data, WiFi_Name);strcat(wifi_data, "\",\"");strcat(wifi_data, WiFi_Password);strcat(wifi_data, "\"\r\n");//发送命令Usart_SendString(DEBUG_USART2, wifi_data);//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");Usart_SendString(DEBUG_USART1, str);Usart_SendString(DEBUG_USART1, "\r\n");
}//设置MQTT连接参数
//设置成功返回1,否则返回0
char esp8266_setMQTTData(void)
{uint8_t ch;uint8_t str[255], i=0;char* pch;//发送命令Usart_SendString(DEBUG_USART2, "AT+MQTTUSERCFG=0,1,\"");Usart_SendString(DEBUG_USART2, Aliyun_ClientId);Usart_SendString(DEBUG_USART2, "\",\"");Usart_SendString(DEBUG_USART2, Aliyun_Username);Usart_SendString(DEBUG_USART2, "\",\"");Usart_SendString(DEBUG_USART2, Aliyun_Password);Usart_SendString(DEBUG_USART2, "\",0,0,\"\"\r\n");//延时一段时间等待接收Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//	Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");
//	Usart_SendString(DEBUG_USART1, (char *)str);
//	Usart_SendString(DEBUG_USART1, "\r\n");pch = strstr((char *)str, "OK");if(pch != NULL)return 1;elsereturn 0;
}//连接阿里云
//连接成功回复1,失败回复0
char connect_Aliyun(void)
{uint8_t ch;uint8_t str[255], i=0;char* pch;//检查esp8266是否存在if(esp8266_text() != 1){printf("连接错误,代码1:请检测esp8266与芯片连接线路!\r\n");return 0;}//设置esp8266为接入点模式if(esp8266_setStation() != 1){printf("连接错误,代码2:esp8266 接入点模式设置失败,请检查!\r\n");return 0;}else{printf("接入点模式设置成功!\r\n");}//连接WiFi网络//连接之前先检查WiFi网络是否连接//如果以连接则跳过此步骤if(esp8266_inquireWiFi_Data() != 1){//连接WiFiesp8266_connectWiFi();printf("正在连接WiFi");//5(s)*15=60(s)=1(min)//等待一段时间,待WiFi连接成功i=15;while(1){Delay_ms(5000);printf(".");//如果WiFi成功退出循环if(esp8266_inquireWiFi_Data() == 1){printf("WiFi连接成功!\r\n");break;}//超时连接退出程序i--;if(i == 0){printf("\r\n错误代码3:WiFi连接超时,已退出!\r\n");return 0;}}}else{printf("WiFi连接成功!\r\n");}//设置MQTT连接参数if(esp8266_setMQTTData() != 1){printf("连接错误,代码4:esp8266 接入点模式设置失败,请检查!\r\n");return 0;}else{printf("MQTT连接参数设置成功!\r\n");}//-------------------------------------------------------------------------------------------for(i=0; i<255; i++){str[i] = '\0';}i=0;//下面开始连接阿里云//发送命令Usart_SendString(DEBUG_USART2, "AT+MQTTCONN=0,\"");Usart_SendString(DEBUG_USART2, BrokerAddress);Usart_SendString(DEBUG_USART2, "\",1883,1\r\n");Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}//	Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");
//	Usart_SendString(DEBUG_USART1, (char *)str);
//	Usart_SendString(DEBUG_USART1, "\r\n");//	for(i=0; i<255; i++)
//	{
//		str[i] = '\0';
//	}
//	
//	i=0;//查询阿里云连接状态Usart_SendString(DEBUG_USART2, "AT+MQTTCONN?");Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}Usart_SendString(DEBUG_USART1, "阿里云的连接状态为:\r\n");Usart_SendString(DEBUG_USART1, (char *)str);Usart_SendString(DEBUG_USART1, "\r\n");pch = strstr((char *)str, BrokerAddress);if(pch != NULL){printf("阿里云物联网平台连接成功!\r\n");return 1;}else{printf("错误代码6:阿里云物联网平台连接失败,请检查!\r\n");return 0;}
}//向阿里云上传温度数据
void AliyunSetData(float temperature)
{uint8_t ch;uint8_t str[255], i=0;//发送数据Usart_SendString(DEBUG_USART2, "AT+MQTTPUB=0,\"");Usart_SendString(DEBUG_USART2, IssueTOPIC);Usart_SendString(DEBUG_USART2, "\",\"{\\\"params\\\": {\\\"temperature\\\":");//将浮点型数据转换成字符串并发送出去char str2[10];sprintf(str2,"%f", temperature);Usart_SendString(DEBUG_USART2, str2);Usart_SendString(DEBUG_USART2, "}\\,\\\"version\\\": \\\"1.0\\\"}\",0,0\r\n");Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str[i] = ch;i++;}}Usart_SendString(DEBUG_USART1, "收到ESP8266传来的数据:\r\n");Usart_SendString(DEBUG_USART1, (char *)str);Usart_SendString(DEBUG_USART1, "\r\n");
}//阿里云订阅数据
void AliyunSubscriptionData(void)
{	uint8_t ch;uint8_t str3[255], i=0;Usart_SendString(DEBUG_USART2, "AT+MQTTSUB=0,\"");Usart_SendString(DEBUG_USART2, SubscriptionTOPIC);Usart_SendString(DEBUG_USART2, "\",0\r\n");Delay_ms(50);//向串口环形缓冲区取数据while(!fifo_is_empty()){if(uart_buf_get(&ch)){str3[i] = ch;i++;}}Usart_SendString(DEBUG_USART1, "\r\n");Usart_SendString(DEBUG_USART1, "esp8266设置订阅数据回复:\r\n");Usart_SendString(DEBUG_USART1, (char *)str3);Usart_SendString(DEBUG_USART1, "\r\n");
}

esp8266.h

#ifndef __ESP8266_H
#define	__ESP8266_H#include "stm32f10x.h"
#include "usart.h"
#include "delay.h"
#include <string.h>#define WiFi_Name 				"CMCC-H3qz"
#define WiFi_Password			"7xf47uxf"
#define Aliyun_ClientId		"k0efkfcSwlt.Device_Demo|securemode=2\\,signmethod=hmacsha256\\,timestamp=1705149361131|"
#define Aliyun_Username		"Device_Demo&k0efkfcSwlt"
#define Aliyun_Password		"ea343ac1d6a4eec7b057bcab39a2ffdf88abc8b810ec0dc7ca3de91a56292ff9"
#define BrokerAddress			"k0efkfcSwlt.iot-as-mqtt.cn-shanghai.aliyuncs.com"//发布数据topic
#define IssueTOPIC				"/sys/k0efkfcSwlt/Device_Demo/thing/event/property/post"
//订阅数据topic
#define SubscriptionTOPIC	"/sys/k0efkfcSwlt/Device_Demo/thing/service/property/set"char esp8266_text(void);
void esp8266_restart(void);
char esp8266_setStation(void);
char esp8266_inquireWiFi_Data(void);
void esp8266_connectWiFi(void);
char esp8266_setMQTTData(void);
char connect_Aliyun(void);
void AliyunSetData(float temperature);
void AliyunSubscriptionData(void);#endif

main.c

void RCC_Configuration(void)
{   //Install system time  is 72MHZSystemInit();
}int main(void)
{	uint8_t ch, bufferFlag=0;char str[255], i=0;char *property = 0;char led_switch;RCC_Configuration();	//系统时钟初始化Delay_Timer_Init();		//延时函数定时器初始化USART_Config();				//串口1初始化USART2_Config();			//串口2初始化//向串口1 发送一段数据,测试串口1初始化成功printf("这是一个STM32挂载ESP8266连接阿里云的例程!\r\n");//初始化PB5为输出gpio_OutputConfig(RCC_APB2Periph_GPIOB, GPIO_Pin_5, GPIOB);//并将LED灯熄灭(将引脚拉高)GPIO_SetBits(GPIOB, GPIO_Pin_5);//如下同理...gpio_OutputConfig(RCC_APB2Periph_GPIOB, GPIO_Pin_0, GPIOB);GPIO_SetBits(GPIOB, GPIO_Pin_0);//初始化PA0为按键功能(SW1)Key_GPIO_Config(RCC_APB2Periph_GPIOA, GPIO_Pin_0, GPIOA);//初始化PC13为按键功能(SW2)Key_GPIO_Config(RCC_APB2Periph_GPIOC, GPIO_Pin_13, GPIOC);while(1){//sw1按键按下功能if(Key_Scan(GPIOA, GPIO_Pin_0) == 1){//使能串口2USART2_ON;//连接阿里云if(connect_Aliyun() == 1){if(GPIO_ReadOutputDataBit(GPIOB,GPIO_Pin_5) == 1){GPIO_ResetBits(GPIOB, GPIO_Pin_5);		//红灯亮起AliyunSubscriptionData();							//订阅数据}	else{GPIO_SetBits(GPIOB, GPIO_Pin_5);			//灯熄灭USART2_ON;														//使能串口2}}}//sw2按键按下功能//判断esp8266是否存在if(Key_Scan(GPIOC, GPIO_Pin_13) == 1){USART2_ON;esp8266_text();}//检测到红灯亮起时,发布和订阅数据if(GPIO_ReadOutputDataBit(GPIOB,GPIO_Pin_5) == 0){//每隔5秒发布数据Delay_ms(1000);AliyunSetData(1.2);//接收阿里云发送过来的数据for(int j=0; j<5; j++){//每隔1秒查看串口环形缓冲区是否有数据Delay_ms(1000);for(i=0; i<127; i++){str[i] = '\0';}i=0;//向串口环形缓冲区取数据while(!fifo_is_empty()){bufferFlag = 1;if(uart_buf_get(&ch)){str[i] = ch;i++;}}if(bufferFlag == 1){bufferFlag = 0;//STM32将连接在串口2上ESP8266发送过来的数据转发到串口1Usart_SendString(DEBUG_USART1, "收到阿里云服务器发送过来的数据:\r\n");Usart_SendString(DEBUG_USART1, str);Usart_SendString(DEBUG_USART1, "\r\n");//以下是通过阿里云控制一盏led灯例程property = strstr(str, "LEDSwitch");if(property != NULL){led_switch = *(property + 11);//Usart_SendByte(DEBUG_USART1, led_switch);led_switch = led_switch - 48;if(led_switch == 0){GPIO_SetBits(GPIOB, GPIO_Pin_0);}else if(led_switch == 1){GPIO_ResetBits(GPIOB, GPIO_Pin_0);}}}}}}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/248426.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

关于如何将Win幻兽帕鲁服务端存档转化为单人本地存档的一种方法(无损转移)

本文转自博主的个人博客&#xff1a;https://blog.zhumengmeng.work,欢迎大家前往查看。 原文链接&#xff1a;点我访问 **起因&#xff1a;**最近大火的开放世界缝合体游戏幻兽帕鲁的大火也是引起了博主的注意&#xff0c;然后博主和周边小伙伴纷纷入手&#xff0c;博主也是利…

安装好IntelliJ IDEA点击无反应,如何解决配置文件不一致导致的启动问题

在我们的开发生涯中&#xff0c;遇到IDE工具出现问题是在所难免的。最令人头疼的莫过于&#xff0c;你的IDEA(IntelliJ IDEA)无法启动&#xff0c;而且没有任何错误提示。这篇文章将详细讲解如何解决IntelliJ IDEA 2023.3.3版本启动失败的问题&#xff0c;这个问题可能也适用于…

LeetCode.2808. 使循环数组所有元素相等的最少秒数

题目 题目链接 分析 我们最终形成的数组一定是当前数组nums 中的一个数字。 所以我们的想法就是枚举数组 nums 中的所有数字&#xff0c;取最小值。 题目告诉我们每一秒都可以向左右扩散一位&#xff0c;那么多个相同的 x 同时扩散&#xff0c;扩散完整个数组耗时就取决于两…

使用.NET6 Avalonia开发跨平台三维应用

本文介绍在Vistual Studio 2022中使用Avalonia和集成AnyCAD Rapid AvaloniaUI三维控件的过程。 0 初始化环境 安装Avalonia.Templates dotnet new install Avalonia.Templates若之前安装过可忽略此步骤。 1 创建项目 选择创建AvaloniaUI项目 选一下.NET6版本和Avalonia版…

文件上传之大文件分块上传进度控制处理

在分块上传内容结束以后的事件监听&#xff0c;我们会实现 unlinkSync 删除临时文件操作&#xff0c;那么试想一下&#xff0c;在这个事件监听中&#xff0c;我们是否可以通过totalChunks以及currentChunk获取当前上传的进度情况呢&#xff1f; 后端 upload上传接口&#xff…

学习嵌入式的第十二天-------二维数组函数的调用和指针的运算

二维数组函数调用 输入设备-------cpu------输出设备 | V 存储器 总线&#xff1a; 总线宽度&#xff1a;32位或64位 &#xff08;1.数据总线2.控制总线3.地址总线&#xff09; 练习&#xff1a; 定义一个二维整型数组&#xff0c;实现一个函数…

KAFKA高可用架构涉及常用功能整理

KAFKA高可用架构涉及常用功能整理 1. kafka的高可用系统架构和相关组件2. kafka的核心参数2.1 常规配置2.2 特殊优化配置 3. kafka常用命令3.1 常用基础命令3.1.1 创建topic3.1.2 获取集群的topic列表3.1.3 获取集群的topic详情3.1.4 删除集群的topic3.1.5 获取集群的消费组列表…

尝试搭建域

使用window 7 作为dmz 主机 server_2008 作为 预控 前提两台主机都在同一个LAN 下&#xff08;设置一个LAN 区域&#xff09;&#xff0c;同样防火墙关闭状态 首先搞定server 2008 中的域 1. 在计算机属性中选择更改设置中将主机名修改一下&#xff1a; 2. 在server 2008 中…

代码随想录 Leetcode222.完全二叉树的节点个数

题目&#xff1a; 代码&#xff08;首刷自解 2024年1月30日&#xff09;&#xff1a; class Solution { public:int countNodes(TreeNode* root) {int res 0;if (root nullptr) return res;queue<TreeNode*> deque;TreeNode* cur root;deque.push(cur);int size 0;w…

编译opencv4.6问题汇总,第三方软件包见我发的资源

win10系统 python3.8.2&#xff0c;cmake-3.15.5-win64-x64&#xff0c;opencv4.6 编译方式见&#xff1a;OpenCV的编译 - 知乎 本文主要总结问题。赠人玫瑰手留余香。 问题1 Problem with installing OpenCV using Visual Studio and CMake (error code: MSB3073) 解决方法…

Java 字符串 07 练习-手机号屏蔽、身份证号信息查看,游戏骂人敏感词替换

注意点&#xff1a;只有返回值才是被截取的小串&#xff0c;所以需要有一个变量去承接它&#xff1b; 自己写的代码&#xff1a; import java.util.Scanner; public class practice {public static void main(String[] args) {Scanner input new Scanner(System.in);String …

Walrus 实用教程|Walrus + Gitlab,打通CI/CD 自动化交付!

Walrus file 是 Walrus 0.5 版本推出的新功能&#xff0c;用户可以通过一个非常简洁的 YAML 描述应用或基础设施资源的部署配置&#xff0c;然后通过 Walrus CLI 执行 walrus apply或在 Walrus UI 上进行import&#xff0c;将 Walrus file 提交给 Walrus server&#xff0c;由 …

【Python笔记-设计模式】单例模式

一、说明 单例是一种创建型设计模式&#xff0c;能够保证一个类只有一个实例&#xff0c; 并提供一个访问该实例的全局节点。 (一) 解决问题 维护共享资源&#xff08;数据库或文件&#xff09;的访问权限&#xff0c;避免多个实例覆盖同一变量&#xff0c;引发程序崩溃。 …

多线程c++

目录 1.join和detach区别 2.lock_guard和unique_lock 3.原子操作 4.条件变量condition_variable 5.future 和 promise 1.join和detach区别 ①不使用join和detach #include <iostream> #include <thread> #include <windows.h>using namespace std;v…

docker由浅入深

一、什么是docker docker 顾名思义就是轮船的意思&#xff0c;轮船我们知道是通过集装箱运载货物的东西&#xff0c;那么docker其实也是类似的东西&#xff0c;只是装载的是虚拟的运行程序罢了。其中集装箱在docker里面被称为container&#xff08;后面以容器称之&#xff09;…

彻底解决 MAC Android Studio gradle async 时出现 “connect timed out“ 问题

最近在编译一个比较老的项目&#xff0c;git clone 之后使用 async 之后出现一下现象&#xff1a; 首先确定是我网络本身是没有问题的&#xff0c;尝试几次重新 async 之后还是出现问题&#xff0c;网上找了一些方法解决了本问题&#xff0c;以此来记录一下问题是如何解决的。 …

Python(19)Excel表格操作Ⅰ

目录 导包 读取EXCEL文件 1、获取worksheet名称 2、设定当前工作表 3、输出目标单元格数据 4、工作表.rows&#xff08;行&#xff09; 5、工作表.columns&#xff08;列&#xff09; 小结 导包 要想使用 python 操作 Excel 文件&#xff0c;应当导入 openpyxl 包。在…

上位机图像处理和嵌入式模块部署(视频处理vs图像处理)

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 从目前发展的情况来看&#xff0c;视频处理会慢慢变成一种主流趋势。这里面的原因很多&#xff0c;比如说现在嵌入式soc的算力越来越强、获取图像的…

【环境配置】安装了pytorch但是报错torch.cuda.is_availabel()=Flase

解决思路&#xff1a;import torch正常&#xff0c;说明torch包安装正常&#xff0c;但是不能和gpu正常互动&#xff0c;猜测还是pytroch和cuda的配合问题 1.查看torch包所需的cuda版本 我的torch是2.0.1&#xff0c;在现在是比较新的包&#xff0c;需要12以上的cuda支持&…

鸿蒙首批原生应用!无感验证已完美适配鸿蒙系统

顶象无感验证已成功适配鸿蒙系统&#xff0c;成为首批鸿蒙原生应用&#xff0c;助力鸿蒙生态的快速发展。 作为全场景分布式操作系统&#xff0c;鸿蒙系统旨在打破不同设备之间的界限&#xff0c;实现极速发现、极速连接、硬件互助、资源共享。迄今生态设备数已突破8亿台&…