赞
踩
假如有这需求,你写好了代码,现在ESP32设备正在运行着,但是设备程序需要升级,目前设备接着WIFI,那么就可以使用远程OTA升级的方法。
需要的环境:Arduino编程环境+巴法云平台+ESP32
Arduino编程环境要求安装好ESP32的开发板库,具体操作方法见ESP32环境安装
选创客云,代码端口才是8340
登录平台并进行主题设置。主题作用类似于QQ群号,指令要发送到ESP32模块上,需要和平台共同在一个QQ群里,后面其他设备订阅了这个主题,相当于大家都在一个QQ群里,发送的消息大家都可以收到。
代码如下(示例):
#include <WiFi.h>
#include <HTTPUpdate.h>
#define server_ip "bemfa.com" //巴法云服务器地址默认即可
#define server_port "8344" //服务器端口,tcp创客云端口8344
//********************需要修改的部分*******************//
#define wifi_name "PDCN" //WIFI名称,区分大小写,不要写错
#define wifi_password "11111111" //WIFI密码
String UID = "9e05a1a53b2cb25a1b50db94d43aa6ce"; //用户私钥,可在控制台获取,修改为自己的UID
String TOPIC = "lmq"; //主题名字,可在控制台新建
//const int LED_Pin = 2; //单片机LED引脚值,D2是NodeMcu引脚命名方式,其他esp8266型号将D2改为自己的引脚
String upUrl = "http://bin.bemfa.com/b/3BcN2Q1NGY4NWFmNDI5NzZlZTNjMjY5M2U2OTJhNmJiNTk=light002.bin";//固件链接,在巴法云控制台复制、粘贴到这里即可
//**************************************************//
//最大字节数
#define MAX_PACKETSIZE 512
//设置心跳值30s
#define KEEPALIVEATIME 30*1000
//tcp客户端相关初始化,默认即可
WiFiClient TCPclient;
String TcpClient_Buff = "";//初始化字符串,用于接收服务器发来的数据
unsigned int TcpClient_BuffIndex = 0;
unsigned long TcpClient_preTick = 0;
unsigned long preHeartTick = 0;//心跳
unsigned long preTCPStartTick = 0;//连接
bool preTCPConnected = false;
//相关函数初始化
//连接WIFI
void doWiFiTick();
void startSTA();
//TCP初始化连接
void doTCPClientTick();
void startTCPClient();
void sendtoTCPServer(String p);
//led控制函数,具体函数内容见下方
//void turnOnLed();
//void turnOffLed();
/*
发送数据到TCP服务器
*/
void sendtoTCPServer(String p) {
if (!TCPclient.connected())
{
Serial.println("Client is not readly");
return;
}
TCPclient.print(p);
}
/*
初始化和服务器建立连接 :style="value.online?'订阅设备在线':'无订阅设备'" color:#9A9A9A;
*/
void startTCPClient() {
if (TCPclient.connect(server_ip, atoi(server_port))) {
Serial.print("\nConnected to server:");
Serial.printf("%s:%d\r\n", server_ip, atoi(server_port));
String tcpTemp = ""; //初始化字符串
tcpTemp = "cmd=1&uid=" + UID + "&topic=" + TOPIC + "\r\n"; //构建订阅指令
sendtoTCPServer(tcpTemp); //发送订阅指令
tcpTemp = ""; //清空
/*
//如果需要订阅多个主题,可再次发送订阅指令
tcpTemp = "cmd=1&uid="+UID+"&topic="+主题2+"\r\n"; //构建订阅指令
sendtoTCPServer(tcpTemp); //发送订阅指令
tcpTemp="";//清空
*/
preTCPConnected = true;
preHeartTick = millis();
TCPclient.setNoDelay(true);
}
else {
Serial.print("Failed connected to server:");
Serial.println(server_ip);
TCPclient.stop();
preTCPConnected = false;
}
preTCPStartTick = millis();
}
/*
检查数据,发送心跳
*/
void doTCPClientTick() {
//检查是否断开,断开后重连
if (WiFi.status() != WL_CONNECTED) return;
if (!TCPclient.connected()) {//断开重连
if (preTCPConnected == true) {
preTCPConnected = false;
preTCPStartTick = millis();
Serial.println();
Serial.println("TCP Client disconnected.");
TCPclient.stop();
}
else if (millis() - preTCPStartTick > 1 * 1000) //重新连接
startTCPClient();
}
else
{
if (TCPclient.available()) {//收数据
char c = TCPclient.read();
TcpClient_Buff += c;
TcpClient_BuffIndex++;
TcpClient_preTick = millis();
if (TcpClient_BuffIndex >= MAX_PACKETSIZE - 1) {
TcpClient_BuffIndex = MAX_PACKETSIZE - 2;
TcpClient_preTick = TcpClient_preTick - 200;
}
preHeartTick = millis();
}
if (millis() - preHeartTick >= KEEPALIVEATIME) { //保持心跳
preHeartTick = millis();
Serial.println("--Keep alive:");
sendtoTCPServer("ping\r\n"); //发送心跳,指令需\r\n结尾,详见接入文档介绍
}
}
if ((TcpClient_Buff.length() >= 1) && (millis() - TcpClient_preTick >= 200))
{
TCPclient.flush();
Serial.print("Rev string: ");
TcpClient_Buff.trim(); //去掉首位空格
Serial.println(TcpClient_Buff); //打印接收到的消息
String getTopic = "";
String getMsg = "";
if (TcpClient_Buff.length() > 15) { //注意TcpClient_Buff只是个字符串,在上面开头做了初始化 String TcpClient_Buff = "";
//此时会收到推送的指令,指令大概为 cmd=2&uid=xxx&topic=light002&msg=off
int topicIndex = TcpClient_Buff.indexOf("&topic=") + 7; //c语言字符串查找,查找&topic=位置,并移动7位,不懂的可百度c语言字符串查找
int msgIndex = TcpClient_Buff.indexOf("&msg=");//c语言字符串查找,查找&msg=位置
getTopic = TcpClient_Buff.substring(topicIndex, msgIndex); //c语言字符串截取,截取到topic,不懂的可百度c语言字符串截取
getMsg = TcpClient_Buff.substring(msgIndex + 5); //c语言字符串截取,截取到消息
Serial.print("topic:------");
Serial.println(getTopic); //打印截取到的主题值
Serial.print("msg:--------");
Serial.println(getMsg); //打印截取到的消息值
}
if (getMsg == "on") { //如果收到指令on==打开灯
// turnOnLed();
Serial.print("on:------");
} else if (getMsg == "off") { //如果收到指令off==关闭灯
// turnOffLed();
Serial.print("off:------");
} else if (getMsg == "update") { //如果收到指令update
updateBin();//执行升级函数
}
TcpClient_Buff = "";
TcpClient_BuffIndex = 0;
}
}
/*
初始化wifi连接
*/
void startSTA() {
WiFi.disconnect();
WiFi.mode(WIFI_STA);
WiFi.begin(wifi_name, wifi_password);
}
/**************************************************************************
WIFI
***************************************************************************/
/*
WiFiTick
检查是否需要初始化WiFi
检查WiFi是否连接上,若连接成功启动TCP Client
控制指示灯
*/
void doWiFiTick() {
static bool startSTAFlag = false;
static bool taskStarted = false;
static uint32_t lastWiFiCheckTick = 0;
if (!startSTAFlag) {
startSTAFlag = true;
startSTA();
}
//未连接1s重连
if ( WiFi.status() != WL_CONNECTED ) {
if (millis() - lastWiFiCheckTick > 1000) {
lastWiFiCheckTick = millis();
}
}
//连接成功建立
else {
if (taskStarted == false) {
taskStarted = true;
Serial.print("\r\nGet IP Address: ");
Serial.println(WiFi.localIP());
startTCPClient();
}
}
}
//打开灯泡
//void turnOnLed() {
// Serial.println("Turn ON");
// digitalWrite(LED_Pin, LOW);
//}
关闭灯泡
//void turnOffLed() {
// Serial.println("Turn OFF");
// digitalWrite(LED_Pin, HIGH);
//}
/**
固件升级函数
在需要升级的地方,加上这个函数即可,例如setup中加的updateBin();
原理:通过http请求获取远程固件,实现升级
*/
void updateBin() {
Serial.println("start update");
WiFiClient UpdateClient;
t_httpUpdate_return ret = httpUpdate.update(UpdateClient, upUrl);
switch (ret) {
case HTTP_UPDATE_FAILED: //当升级失败
Serial.println("[update] Update failed.");
break;
case HTTP_UPDATE_NO_UPDATES: //当无升级
Serial.println("[update] Update no Update.");
break;
case HTTP_UPDATE_OK: //当升级成功
Serial.println("[update] Update ok.");
break;
}
}
// 初始化,相当于main 函数
void setup() {
Serial.begin(115200);
// pinMode(LED_Pin, OUTPUT);
// digitalWrite(LED_Pin, HIGH);
Serial.println("Beginning...");
}
//循环
void loop() {
doWiFiTick();
doTCPClientTick();
}
代码来源于官方资料,把开关关灯指令暂时给屏蔽了。
编译没问题提示:
然后需要导出bin固件,在Arduino软件中选择 项目===导出已编译的二进制文件
此时,在你的项目文件夹下产生bin文件。
核对下端口和代码的端口对不对。应该是TCP创客云,不是设备云。复制bin固件地址,替换到原来的String upUrl
这个位置:
String upUrl = "http://bin.bemfa.com/b/1BcOWUwNWExYTUzYjJjYjI1YTFiNTBkYjk0ZDQzYWE2Y2U=lmq.bin";
然后在重新编译一次程序,再上传一次bin文件到平台,再烧录到ESP32中,这是必要的。bin文件地址不会变化。
在网页输入update即可进行远程更新。
如果需要开启自己的任务函数,在void loop()循环中加入即可。另外,升级结束需要按下重启按键才可以执行新代码。
详细使用方法建议看巴法云官网资料。
巴法云,简单来说就是提供一个更方便功能更强的免费MQTT服务器给使用。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。