基于STM32的OTA远程升级-凡亿课堂

OTA又叫空中下载技术，是通过移动通信的空中接口实现对移动终端设备数据进行远程管理的技术，还能提供移动化的新业务下载功能。

要实现OTA功能，至少需要两块设备，分别是服务器与客户端。服务器只有一个，客户端可有多个。服务器通过串口与PC机连接，需要下载的镜像文件存放于PC机，命令执行器给服务器发命令及镜像文件。

首先命令执行器控制服务器广播当前可用的镜像文件信息，客户端收到信息后进行对比，若有与自身相匹配的镜像，则向服务器请求数据。服务器收到请求后向命令执行器索取固定大小的块，再点对点传送给客户端。镜像传输完毕后，客户端进行校验，完成后发送终止信号。

一. 升级方式的对比

OTA升级与平时用到的SD卡升级、串口升级等等大体原理上是一样的，都是对MCU的Flash进行操作而已。

收到升级指令——>MCU复位或者跳转到Boot程序区——>擦除对应的Flash区域——>获取APP数据——>写入FLASH数据——>校验——>跳转到APP应用程序区

OTA与其他本地升级的区别就是：获取数据的方式不同。比如串口升级，就是通过上位机传输到MCU串口上的数据；SD卡升级，就是通过读取SD卡，把程序通过SPI传输到MCU上；而OTA升级，就是通过带无线传输的模块，把程序传输到MCU上。例如：蓝牙、Wifi、GSM等等。不过大部分的无线模块，通过串口把数据传输到MCU上的，只是服务端不再是PC端了，而是网络服务器。

二. 硬件选择

MCU我这里选用的是STM32F030F4P6的芯片，16K的Flash，应该是ST产品中Flash空间比较小的一种，为的就是体现一下小容量的单片机也可以进行OTA升级。

无线模块我使用的是ESP-8266，WIfi传输方式，应该也是比较大众化的一款模组。（TTL串口连接MCU）

OTA相关的硬件没有了，剩下的无所谓，都是其他功能的，最好有个LED灯，可以明显的看出是否升级成功。

三. 网络服务器的选择

网络服务器多种多样，常用的有阿里云、百度云、腾讯云、移动云等等，有条件的，还可以使用自己的服务器。总之需要实现：网络服务器可以与我们的无线模块进行大数据通信。

我这里选用的是OneNet移动云（OTA服务之前是免费，现在是前100个设备免费，之后每增加一个设备1元钱永久），我感觉OneNet相对于阿里云较为简单，没有阿里云那么繁琐，不过阿里云还是比OneNet更专业一点（个人见解），其他的没有用过，大家都可以去试试。

四. 网络服务器的传输方式

我这里使用的是OneNet的服务器，它的OTA服务是通过Http协议进行传输的，有对应的API，我们可以通过OneNet释放的API去访问OTA服务。

五. OTA升级流程

OneNet的OTA升级流程主要为6步：

1. 上报版本号---客户端（MCU）上报当前的一个版本号
2. 检测升级任务---检查服务器是否有待升级的版本
3. 检测Token有效性---检查Token密钥，可省略
4. 下载固件---应用程序传输
5. 上报升级状态---上报服务端升级是否成功，不成功有对应的响应码

六. OneNet服务端配置

1.首先注册OneNet的账号，进入开发者中心，在导航栏选择全部产品->远程升级OTA板块。

2.进入远程升级OTA界面，选择需要升级的模块；然后点击右上角的添加升级包按钮。FOTA升级：对设备中的模组进行升级。SOTA升级：对设备中的应用程序进行升级，我这里选用的是SOTA，因为我要对MCU的应用程序升级。

3.在添加升级包对话框中，输入固件信息，上传固件包文件。产品选你要升级的设备，全部设备也可以；厂商名称选其他，主要是与之后发的对应上即可；模组型号同理；目标版本是你要更新到的版本号，比如你现在是V01，你这里添加的固件是V02的，这个版本号就要填V02；然后上传升级包，只支持Bin和压缩包格式的。

4.点击验证升级按钮，选择验证类型（完整包或者差分包），选择进行测试升级的设备，进行验证。一般跳过验证就行，我这里选的是整包，差分包原理一样。

5.单击升级设备列表，进入升级队列模块，在右上角单击添加升级设备按钮，新增设备升级任务。在添加待升级设备对话框中输入对应参数值。初始版本：就是升级前的版本，也是上次升级的版本；升级范围就是你需要给哪些设备升级；升级时机：就是立即升级或是定时在什么时段升级；重试策略：不重试就是如果升级失败就完事了，重试那就失败了还能重试；信号强度和剩余电量只是一个信息的接口，有需要的可以读取来用。

6.上述完成后，会出现“待升级”的设备，服务器这边就算配置完了，后续要我们M客户端进行操作了。

七.客户端(MCU)API访问服务端进行OTA升级

无线模组用的是ESP8266，由于OneNet的OTA服务用的是HTTP协议，但是ESP8266没有HTTP协议，所以我使用TCP协议，封装成HTTP的报文格式。

1.ESP8266初始化；连接Wifi，AP_SSID，AP_PASS是WiFi的账号和密码；SERVER_IP和SERVER_PORT是OneNet的Ip和端口号。

#define SERVER_IP "183.230.40.50"#define SERVER_PORT 80uint8_t pro = 0;uint8_t ESP8266_Init(void){ switch(pro) {

case 0 : //printf("+++");

Uart2_Send("+++");

Delay_S(2);

if(ESP8266_SoftReset(50) == 0)

pro = 1;

break;

case 1 :

if(ESP8266_AT_Send("ATE0\r\n",10) == 0)

pro = 2;

break;

case 2 :

if(ESP8266_AT_Send("AT+CWMODE=1\r\n",50) == 0) //设置8266为STA模式

pro = 3;

break;

case 3 :

if(ESP8266_ConnectionAP(AP_SSID,AP_PASS,200) == 0) //8266连接AP

pro = 4;

break;

case 4 :

if(ESP8266_AT_Send("AT+CIPMODE=1\r\n",50) == 0) //8266开启透传模式

pro = 5;

break;

case 5 :

if(ESP8266_Connect_Server(SERVER_IP,SERVER_PORT,50) == 0) //8266连接TCP服务器

{

pro = 0; //USART1_Clear(); //清除串口数据 return 1;

}

break;

}

return 0;}

2.上报版本号；dev_id是设备ID，authorization是鉴权参数，ver要上报的版本号，timeout发送超时时间。

//上报版本号

uint8_t Report_Version(char *dev_id,char *authorization,char *ver,uint16_t timeout){

uint16_t time=0; char send_buf[296];

USART1_Clear(); //清除串口数据

snprintf(send_buf, sizeof(send_buf), "POST /ota/device/version?dev_id=%s HTTP/1.1\r\n" "Authorization:%s\r\n"

"Host:ota.heclouds.com\r\n" "

Content-Type:application/json\r\n"

"Content-Length:%d\r\n\r\n"

"{\"s_version\":\"%s\"}", dev_id, authorization, strlen(ver) + 16, ver);

Uart2_Send(send_buf);

while(time

{ )<>

if(strstr( (const char *)usart_info.buf , (const char *)"\"errno\":0")) )<>

break; )<>

Delay_Ms(100); )<>

time++; } )<>

if(time>=timeout) )<>

return 1; )<>

else )<>

return 0; })<>

3.检查升级任务；dev_id是设备ID，authorization是鉴权参数，cur_version是当前的版本号，timeout发送超时时间

)<>

//检查升级任务uint8_t Detect_Task(char *dev_id,char *cur_version,char *authorization,uint16_t timeout){ )<>

uint16_t time=0; char send_buf[280]; )<>

USART1_Clear(); //清除串口数据 )<>

snprintf(send_buf, sizeof(send_buf), "GET /ota/south/check?" "dev_id=%s&manuf=100&model=10001&type=2&version=%s&cdn=false HTTP/1.1\r\n" "Authorization:%s\r\n" )<>

"Host:ota.heclouds.com\r\n\r\n", )<>

dev_id, cur_version,authorization); )<>

Uart2_Send(send_buf); )<>

while(time )<>)<>

{ if(strstr( (const char *)usart_info.buf , (const char *)"\"errno\":0")) )<>)<>

break; )<>)<>

Delay_Ms(100); )<>)<>

time++; } )<>)<>

if(time>=timeout) )<>)<>

return 1; )<>)<>

else )<>)<>

return 0; }

)<>)<>

3.下载资源(我省略了"检查token有效"步骤)；ctoken是上一步“检查升级任务”返回的Token，这个每次请求都不一样，所以注意要记录；size：平台返回的固件大小(字节)；bytes_range：分片大小(字节)

/**************************************************************

函数名称：OTA_Download_Range**

函数功能：分片下载固件**

入口参数：token：平台返回的Token*

size：平台返回的固件大小(字节)*

bytes_range：分片大小(字节)**

返回参数：0-成功其他-失败** 说明：

*************************************************************

/uint8_t Download_Task(char *ctoken,unsigned int size, const unsigned short bytes_range,uint16_t timeout){ MD5_CTX md5_ctx; //MD5相关变量

unsigned char md5_t[16];

char md5_t1[16];

char md5_result[40];

uint16_t time=0;

char *data_ptr = NULL;

char send_buf[256];

unsigned char flash_buf[OTA_BUFFER_SIZE]; //flash读写缓存

unsigned int bytes = 0;

MD5_Init(&md5_ctx);

Flash_cashu(); while(bytes < size)

{

time = 0;

memset(send_buf, 0, sizeof(send_buf));

USART1_Clear(); //清除串口数据

snprintf(send_buf, sizeof(send_buf), "GET /ota/south/download/"

"%s HTTP/1.1\r\n"

"Range:bytes=%d-%d\r\n"

"Host:ota.heclouds.com\r\n\r\n",

ctoken, bytes, bytes + bytes_range - 1);

Uart2_Send(send_buf); //----------------------------------------------------等待数据---------------------------------------------------------------------

while(time < 30) {

if(usart_info.buf[0] != 0)

break;

Delay_Ms(100);

time++;

}

if(time <=>29)

)<>)<>

/************************************************************** )<>)<>

函数名称：OTA_Download_Range** )<>)<>

函数功能：分片下载固件** )<>)<>

入口参数：token：平台返回的Token* )<>)<>

size：平台返回的固件大小(字节)* )<>)<>

bytes_range：分片大小(字节)** 返回参数：0-成功其他-失败** )<>)<>

说明：*************************************************************)<>)<>

/uint8_t Download_Task(char *ctoken,unsigned int size, const unsigned short bytes_range,uint16_t timeout){ MD5_CTX md5_ctx; //MD5相关变量 )<>)<>

unsigned char md5_t[16]; )<>)<>

char md5_t1[16]; )<>)<>

char md5_result[40]; )<>)<>

uint16_t time=0; )<>)<>

char *data_ptr = NULL; )<>)<>

char send_buf[256]; )<>)<>

unsigned char flash_buf[OTA_BUFFER_SIZE]; //flash读写缓存 )<>)<>

u)<>)<>nsigned int bytes = 0; )<>

MD5_Init(&md5_ctx); )<>

Flash_cashu(); )<>

while(bytes < size) { )<>

time = 0; )<>

memset(send_buf, 0, sizeof(send_buf)); )<>

USART1_Clear(); //清除串口数据 )<>

snprintf(send_buf, sizeof(send_buf), "GET /ota/south/download/" )<>

"%s HTTP/1.1\r\n" )<>

"Range:bytes=%d-%d\r\n" )<>

"Host:ota.heclouds.com\r\n\r\n", )<>

ctoken, bytes, bytes + bytes_range - 1); )<>

Uart2_Send(send_buf); //----------------------------------------------------等待数据--------------------------------------------------------------------- )<>

while(time < 30) )<>

{ if(usart_info.buf[0] != 0) break; )<>

Delay_Ms(100); )<>

time++; } )<>

if(time <=>29))<> {

Delay_Ms(500); //----------------------------------------------------跳过HTTP报文头、找到固件数据--------------------------------------------------

data_ptr = strstr( (const char *)usart_info.buf, "Range");

data_ptr = strstr(data_ptr, "\r\n");

data_ptr += 4; //----------------------------------------------------将固件数据写入缓存和闪存-----------------------------------------------------

if(data_ptr != NULL) {

if((size - bytes) >= OTA_BUFFER_SIZE) { memcpy(flash_buf + (bytes % OTA_BUFFER_SIZE), data_ptr, bytes_range); STMFLASH_Write_NoCheck(FLASH_APP1_ADDR + bytes,(uint16_t *)flash_buf,OTA_BUFFER_SIZE / 2); bytes = bytes + OTA_BUFFER_SIZE; MD5_Update(&md5_ctx, (unsigned char *)data_ptr, bytes_range);

}

else{

memcpy(flash_buf + (bytes % OTA_BUFFER_SIZE), data_ptr, size - bytes); STMFLASH_Write_NoCheck(FLASH_APP1_ADDR + bytes , (uint16_t *)flash_buf , (size % OTA_BUFFER_SIZE) / 2);

MD5_Update(&md5_ctx, (unsigned char *)data_ptr, size - bytes); bytes = size; } } } } //----------------------------------------------------MD校验比对------------------------------------------------------------------

memset(md5_result, 0, sizeof(md5_result));

MD5_Final(&md5_ctx, md5_t);

for(int i = 0; i < 16; i++) {

if(md5_t[i] <=>0x0f)

sprintf(md5_t1, "0%x", md5_t[i]);

else

sprintf(md5_t1, "%x", md5_t[i]);

strcat(md5_result, md5_t1);

}

if(strcmp(md5_result, ota_info.md5) == 0)

return 0;

else

return 1; }

4.上报升级状态；这一步由于时间问题，我也省略了，总之程序已经下载到MCU上了，只是没有通知服务器而已，大家最好还是加上这一步。

5.main函数循环；

char rrr; char dev_id[] = {"640600857"}; char Authorization[] = {"version=2018-10-31&res=products%2F378414&et=1735660800&method=sha1&sign=9EgY%2Bk4r%2BlvCooIGf1ghtQFC0%2Bc%3D"};
char Version[] = {"V10"};

while(1) { switch(pro) { case 1 : //上报版本 if(Report_Version(dev_id,Authorization,Version,10) == 0) pro++; break; case 2 : //检查任务 if(Detect_Task(dev_id,Version,Authorization,50) == 0) pro++; break; case 3 : //接收token、size、md5信息 rrr = json_get_value((char *)usart_info.buf,"token",ota_info.token); rrr = json_get_value((char *)usart_info.buf,"size",ota_info.csize); rrr = json_get_value((char *)usart_info.buf,"md5",ota_info.md5); ota_info.size = atoi(ota_info.csize); pro++; break; case 4 : //进行下载 res = Download_Task(ota_info.token,ota_info.size,OTA_BUFFER_SIZE,10); if(res == 0) //校验成功 { pro++; } else if(res == 1) //校验失败 { pro = 1; } break; case 5 : //Flash写入升级完成的标志位 USART1_Clear(); STMFLASH_Unlock(); STMFLASH_WriteHalfWord(FLASH_APP1_ADDR - 0x64, 0xFF02);//写入数据 STMFLASH_Lock(); pro++; break; case 6 : //复位或者跳转到APP Sys_Soft_Reset(); //iap_load_app(FLASH_APP1_ADDR); break; } }

下图是我升级的历史

八.注意事项