STM32连接阿里云物联网平台

2024-01-27 07:28
文章标签 阿里 平台 连接 stm32 联网 云物

本文主要是介绍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);}}}}}}
}

这篇关于STM32连接阿里云物联网平台的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/649480。

相关文章

流媒体平台/视频监控/安防视频汇聚EasyCVR播放暂停后视频画面黑屏是什么原因？

流媒体平台/视频监控/安防视频汇聚EasyCVR播放暂停后视频画面黑屏是什么原因？

视频智能分析/视频监控/安防监控综合管理系统EasyCVR视频汇聚融合平台，是TSINGSEE青犀视频垂直深耕音视频流媒体技术、AI智能技术领域的杰出成果。该平台以其强大的视频处理、汇聚与融合能力，在构建全栈视频监控系统中展现出了独特的优势。视频监控管理系统EasyCVR平台内置了强大的视频解码、转码、压缩等技术，能够处理多种视频流格式，并以多种格式（RTMP、RTSP、HTTP-FLV、WebS
阅读更多...
W外链微信推广短连接怎么做？

W外链微信推广短连接怎么做？

制作微信推广链接的难点分析 一、内容创作难度 制作微信推广链接时，首先需要创作有吸引力的内容。这不仅要求内容本身有趣、有价值，还要能够激起人们的分享欲望。对于许多企业和个人来说，尤其是那些缺乏创意和写作能力的人来说，这是制作微信推广链接的一大难点。 二、精准定位难度 微信用户群体庞大，不同用户的需求和兴趣各异。因此，制作推广链接时需要精准定位目标受众，以便更有效地吸引他们点击并分享链接
阅读更多...
综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动，这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升：减少抖动，提高图像的清晰度和细节表现力，使得监控画面更加真实可信。 - 细节增强：在低光条件下，抖
阅读更多...
JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
阿里开源语音识别SenseVoiceWindows环境部署

阿里开源语音识别SenseVoiceWindows环境部署

SenseVoice介绍 SenseVoice 专注于高精度多语言语音识别、情感辨识和音频事件检测多语言识别： 采用超过 40 万小时数据训练，支持超过 50 种语言，识别效果上优于 Whisper 模型。富文本识别：具备优秀的情感识别，能够在测试数据上达到和超过目前最佳情感识别模型的效果。支持声音事件检测能力，支持音乐、掌声、笑声、哭声、咳嗽、喷嚏等多种常见人机交互事件进行检测。高效推
阅读更多...
如何解决线上平台抽佣高 线下门店客流少的痛点！

如何解决线上平台抽佣高 线下门店客流少的痛点！

目前，许多传统零售店铺正遭遇客源下降的难题。尽管广告推广能带来一定的客流，但其费用昂贵。鉴于此，众多零售商纷纷选择加入像美团、饿了么和抖音这样的大型在线平台，但这些平台的高佣金率导致了利润的大幅缩水。在这样的市场环境下，商家之间的合作网络逐渐成为一种有效的解决方案，通过资源和客户基础的共享，实现共同的利益增长。 以最近在上海兴起的一个跨行业合作平台为例，该平台融合了环保消费积分系统，在短
阅读更多...
Android平台播放RTSP流的几种方案探究（VLC VS ExoPlayer VS SmartPlayer）

Android平台播放RTSP流的几种方案探究（VLC VS ExoPlayer VS SmartPlayer）

技术背景 好多开发者需要遴选Android平台RTSP直播播放器的时候，不知道如何选的好，本文针对常用的方案，做个大概的说明： 1. 使用VLC for Android VLC Media Player（VLC多媒体播放器），最初命名为VideoLAN客户端，是VideoLAN品牌产品，是VideoLAN计划的多媒体播放器。它支持众多音频与视频解码器及文件格式，并支持DVD影音光盘，VCD影
阅读更多...
【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

【区块链 + 人才服务】区块链集成开发平台 | FISCO BCOS应用案例

随着区块链技术的快速发展，越来越多的企业开始将其应用于实际业务中。然而，区块链技术的专业性使得其集成开发成为一项挑战。针对此，广东中创智慧科技有限公司基于国产开源联盟链 FISCO BCOS 推出了区块链集成开发平台。该平台基于区块链技术，提供一套全面的区块链开发工具和开发环境，支持开发者快速开发和部署区块链应用。此外，该平台还可以提供一套全面的区块链开发教程和文档，帮助开发者快速上手区块链开发。
阅读更多...
K8S（Kubernetes）开源的容器编排平台安装步骤详解

K8S（Kubernetes）开源的容器编排平台安装步骤详解

K8S（Kubernetes）是一个开源的容器编排平台，用于自动化部署、扩展和管理容器化应用程序。以下是K8S容器编排平台的安装步骤、使用方式及特点的概述： 安装步骤： 安装Docker：K8S需要基于Docker来运行容器化应用程序。首先要在所有节点上安装Docker引擎。 安装Kubernetes Master：在集群中选择一台主机作为Master节点，安装K8S的控制平面组件，如AP
阅读更多...
【STM32】SPI通信-软件与硬件读写SPI

【STM32】SPI通信-软件与硬件读写SPI

SPI通信-软件与硬件读写SPI 软件SPI一、SPI通信协议1、SPI通信2、硬件电路3、移位示意图4、SPI时序基本单元(1)开始通信和结束通信(2)模式0---用的最多(3)模式1(4)模式2(5)模式3 5、SPI时序(1)写使能(2)指定地址写(3)指定地址读 二、W25Q64模块介绍１、W25Q64简介２、硬件电路３、W25Q64框图４、Flash操作注意事项软件SPI读写W2
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2