ONE NET MQTT+HTTP多端控制

devtools/2025/2/5 21:33:45/

使用移动的ONENET实现数据上传与远程控制，数据上传使用MQTT协议（ESP8266），而数据查看和远程控制使用的HTTP（安卓端/QT），效果：

ONENET简单MQTT和HTTP使用

ESP8266通过MQTT上传和订阅数据我就不多赘述了，教程很多，我直接刷的MQTT固件，然后通过AT指令进行MQTT操作的

void esp_init(){SendCmd(ATE0,"OK",10);	//关闭回显HAL_Delay(50);SendCmd(AT,"OK",10);//发送AT指令HAL_Delay(50);SendCmd(CWJAP1,"IP",40);//连接WIFI，CWJAP1为连接的WiFi信息HAL_Delay(50);SendCmd(MQTTUSERCFG,"OK",10);//设置MQTT信息HAL_Delay(100);SendCmd(MQTTCONN,"OK",40);//连接MQTTHAL_Delay(100);SendCmd(MQTTSUB,"OK",40);//订阅MQTTHAL_Delay(100);
}
#define   AT          "AT\r\n"	
#define   ATE0        "ATE0\r\n"	
#define   CWMODE      "AT+CWMODE=1\r\n"
#define   RST         "AT+RST\r\n"
#define   CIFSR       "AT+CIFSR\r\n"#define   CWJAP       "AT+CWJAP=\"Caneve16spro\",\"123456789\"\r\n"//网络连接信息
#define   CWJAP1       "AT+CWJAP=\"CanEve17Pro\",\"12345678\"\r\n"#define		MQTTUSERCFG "AT+MQTTUSERCFG=0,1,\"FARM\",\"xxxxx\",\"version=2018-10-31&res=xxxxx\",0,0,\"\"\r\n" //这个就是MQTT的配置信息，根据自己的填
#define   MQTTCONN    "AT+MQTTCONN=0,\"mqtts.heclouds.com\",1883,0\r\n"//MQTT服务器
#define   MQTTSUB			"AT+MQTTSUB=0,\"$sys/xxxxx/FARM/thing/property/set\",1\r\n"//MQTT订阅#define   CIPSTART    "AT+CIPSTART=\"TCP\",\"192.168.31.112\",20233\r\n"
#define   CIPMODE     "AT+CIPMODE=1\r\n"
#define   CIPSEND     "AT+CIPSEND\r\n"
#define   CIPSTATUS   "AT+CIPSTATUS\r\n"
#define   CIPMODEOFF  "AT+CIPMODE=0\r\n"
#define   CIPCLOSE    "AT+CIPCLOSE\r\n"

设备接入的具体配置详见官网：OneNET - 中国移动物联网开放平台

https://i-blog.csdnimg.cn/direct/ab79305f05fa43f89fcf5e8b762df5c4.png" width="1611" />

上传数据

void pub_dat(){//MQTT发布更新数据memset(pub_dat_buf,0,sizeof pub_dat_buf);//清空发送数组memset(topic,0,sizeof topic);sprintf(pub_dat_buf,"{\"id\": \"123\",\"params\": {\"FAN\": {\"value\": %d},\"TEMP\": { \"value\": %.1f},\"LIGHT\": {\"value\": %d},\"LED\": {\"value\": %d},\"HUM\": {\"value\": %.0f},\"SOIL\": {\"value\": %.0f},\"PRE\": {\"value\": %.0f},\"PUMP\": {\"value\": %d}}}",mq_fan,mq_temp,mq_light,mq_led,humidity,soil_h,pressure,mq_pump);sprintf(topic,"AT+MQTTPUBRAW=0,\"$sys/xxxxx/FARM/thing/property/post\",%d,0,0\r\n",strlen(pub_dat_buf));SendCmd(topic,">",50);//发送需要发布的topic以及数据长度HAL_Delay(50);esp_send(pub_dat_buf);
}

Android端使用GET获取数据

public void Get() {new Thread(() -> {//接受温度OkHttpClient client = new OkHttpClient();Request request = new Request.Builder().url("https://iot-api.heclouds.com/thingmodel/query-device-property?product_id=xxxxx&device_name=FARM").addHeader("Authorization", "version=2018-10-31&res=products%2Fxxxxx%2Fdevices%2FFARM&et=1736269477&method=md5&sign=fVpjPaZLpv1%2Btl5zcIcC9A%3D%3D").addHeader("Accept",Accept).build();client.newCall(request).enqueue(new Callback() {@Overridepublic void onResponse(@NonNull Call call, @NonNull Response response) throws IOException {if(!response.isSuccessful()) {throw new IOException("Unexpected code" +response);}else {String responseBody = response.body().string();Log.e("farm",responseBody);//输出响应内容try {JSONArray jsonArray = new JSONArray(responseBody.substring(responseBody.indexOf("["),responseBody.lastIndexOf("]")+1));StringBuilder str= new StringBuilder("httpclient:\n");for (int i=0;i<jsonArray.length();i++){JSONObject jsonObject2 = (JSONObject)jsonArray.opt(i);String temp_id=jsonObject2.has("identifier")?jsonObject2.getString("identifier"):null;String temp_val=jsonObject2.has("value")? jsonObject2.getString("value"):null;str.append("第").append(i).append("个:").append(temp_id).append(": ").append(temp_val).append("\n");check(temp_id,temp_val);}Log.e("zms", str.toString());Calendar calendar = Calendar.getInstance();str= new StringBuilder(calendar.get(Calendar.MINUTE) + ":" + calendar.get(Calendar.SECOND) + str);check(String.valueOf(str));} catch (JSONException e) {
// TODO Auto-generated catch blockLog.e("zms", "err");e.printStackTrace();}}}@Overridepublic void onFailure(@NonNull Call call, @NonNull IOException e) {Log.e("farm","get fail");e.printStackTrace();}});}).start();}

Android端发送控制指令使用的POST

    //异步post请求public void Post() {RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"), "{" +"    \"product_id\": \"xxxxx\"," +"    \"device_name\": \"FARM\"," +"    \"params\": {" +"      \"LED\": 0" +"    }" +"  }");Request request = new Request.Builder().url("https://iot-api.heclouds.com/thingmodel/set-device-property").post(requestBody).header("Authorization", "version=2018-10-31&res=products%2Fxxxxx%2Fdevices%2FFARM&et=1772735919&method=md5&sign=QwtaZir04FXz1BeO%2B9FPpQ%3D%3D").build();OkHttpClient okHttpClient=new OkHttpClient();Call call=okHttpClient.newCall(request);call.enqueue(new Callback() {@Overridepublic void onFailure(Call call, IOException e) {Log.e("farm","post fail");//输出响应内容}@Overridepublic void onResponse(Call call, Response response) throws IOException {String str=response.body().string();//.........Log.e("farmPOST",str);//输出响应内容if(str.contains("success")){check("set ok");}}});}

https://i-blog.csdnimg.cn/direct/e13c8cfafabc4c2792beee986194b8ab.png" width="967" />

https://i-blog.csdnimg.cn/direct/4afd63bd6fb6487da60d962d3c42d3ea.png" width="539" />

QT端和Android操作差不多，也是通过get和post

void MainWindow::SendGetRequst()
{mNetworkManager = new QNetworkAccessManager(this);QNetworkRequest _quest;QString url = "https://iot-api.heclouds.com/thingmodel/query-device-property?product_id=xxxxx&device_name=FARM";_quest.setUrl((QUrl(url)));_quest.setRawHeader("Authorization","version=2018-10-31&res=products%2Fxxxxx%2Fdevices%2FFARM&et=1736269477&method=md5&sign=fVpjPaZLpv1%2Btl5zcIcC9A%3D%3D");_quest.setRawHeader("Accept","application/json, text/plain, */*");//自定义mReply = mNetworkManager->get(_quest);QByteArray _data = mReply->readAll();//读出数据//QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss.zzz").toUtf8().constData();qInfo()<<"1_data ==> "<<_data;//connect(mReply,&QNetworkReply::finished,this,&HttpOperate::ReplyFinshed);//方式一// auto lambdaFun = [=]{ReplyFinshed();};//lambda函数// connect(mReply,&QNetworkReply::finished,lambdaFun);//这里的信号的接受者可以省略不写connect(mReply,&QNetworkReply::finished,[=]{//这里的信号的接受者可以省略不写ReplyFinshed();});qInfo()<<"2_data ==> " << QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss.zzz").toUtf8().constData();}void MainWindow::SendPostRequst(uint8_t flag)//将控制命令发出去 0 led 1 pump 2 fan
{mNetworkManager = new QNetworkAccessManager(this);QNetworkRequest _quest;_quest.setUrl((QUrl("https://iot-api.heclouds.com/thingmodel/set-device-property")));_quest.setRawHeader("Authorization", "version=2018-10-31&res=products%2Fxxxxx%2Fdevices%2FFARM&et=1772735919&method=md5&sign=QwtaZir04FXz1BeO%2B9FPpQ%3D%3D");_quest.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/json"));QJsonDocument document;QJsonObject obj,obj1;obj.insert("product_id", "xxxxx");obj.insert("device_name", "FARM");switch (flag) {case 0:obj1.insert("LED",ui->comboBox->currentIndex());break;case 1:obj1.insert("PUMP",ui->checkBox_4->isChecked() ? 1:0);break;case 2:obj1.insert("FAN",ui->checkBox_2->isChecked() ? 1:0);break;default:return;break;}obj.insert("params", obj1);document.setObject(obj);QByteArray _postData = document.toJson(QJsonDocument::Compact);//以Json字符串的方式传参qDebug()<<_postData;_quest.setAttribute(QNetworkRequest::Http2AllowedAttribute, false);mReply = mNetworkManager->post(_quest,_postData);QByteArray _data = mReply->readAll();//读出数据qDebug()<<"1_data ==> "<<_data;//此s时数据为空connect(mReply,&QNetworkReply::finished,this,[=]{ReplyFinshed();});//方式三qDebug()<<"2_data ==> ";}


http://www.ppmy.cn/devtools/156379.html

相关文章

Vue整合Axios

Vue整合Axios

目标 将 axios 请求方法&#xff0c;封装到 request 模块 我们会使用 axios 来请求后端接口, 一般都会对 axios 进行一些配置 (比如: 配置基础地址,请求响应拦截器等等) 一般项目开发中, 都会对 axios 进行基本的二次封装, 单独封装到一个模块中, 便于使用 安装 Axios npm …
阅读更多...
智能汽车网络安全威胁报告

智能汽车网络安全威胁报告

近年来随着智能汽车技术的快速发展&#xff0c;针对智能汽车的攻击也逐渐从传统的针对单一车辆控制器的攻击转变为针对整车智能化服务的攻击&#xff0c;包括但不限于对远程控制应用程序的操控、云服务的渗透、智能座舱系统的破解以及对第三方应用和智能服务的攻击。随着WP.29 …
阅读更多...
【C++】线程池实现

【C++】线程池实现

目录 一、线程池简介线程池的核心组件实现步骤 二、C11实现线程池源码 三、线程池源码解析1. 成员变量2. 构造函数2.1 线程初始化2.2 工作线程逻辑 3. 任务提交(enqueue方法)3.1 方法签名3.2 任务封装3.3 任务入队 4. 析构函数4.1 停机控制 5. 关键技术点解析5.1 完美转发实现5…
阅读更多...
TensorFlow 示例摄氏度到华氏度的转换（二）

TensorFlow 示例摄氏度到华氏度的转换（二）

这是一个完整的神经网络实现&#xff0c;用于将摄氏度转换为华氏度。下面&#xff0c;我会逐步描述各个步骤&#xff0c;并提供完整代码。 1. 数据准备与预处理 在这部分&#xff0c;我们准备了摄氏度&#xff08;features&#xff09;与对应的华氏度&#xff08;labels&…
阅读更多...
LabVIEW无人机航线控制系统

LabVIEW无人机航线控制系统

介绍了一种无人机航线控制系统&#xff0c;该系统利用LabVIEW软件与MPU6050九轴传感器相结合&#xff0c;实现无人机飞行高度、速度、俯仰角和滚动角的实时监控。系统通过虚拟仪器技术&#xff0c;有效实现了数据的采集、处理及回放&#xff0c;极大提高了无人机航线的控制精度…
阅读更多...
Machine Learning Engineering Open Book 机器学习工程开放书

Machine Learning Engineering Open Book 机器学习工程开放书

文章目录 一、关于 Machine Learning Engineering Open Book二、书籍目录三、关键对照表四、快捷方式 一、关于 Machine Learning Engineering Open Book 这是一个开放的方法、工具和分步说明集合&#xff0c;有助于成功训练和微调大型语言模型和多模态模型及其推理。 这是一…
阅读更多...
Linux实操篇-文件目录类＞/＞＞/echo/head/tail/ln/history

Linux实操篇-文件目录类＞/＞＞/echo/head/tail/ln/history

目录 传送门前言一、>、 >>概念二、>、 >>实战1. **>&#xff08;输出重定向&#xff09;**2. **>>&#xff08;追加输出&#xff09;****区别总结&#xff1a;** 三、echo、head、tail概念四、echo、head、tail实战1. **echo****用法**&#xff1a…
阅读更多...
mysql重学（一）mysql语句执行流程

mysql重学（一）mysql语句执行流程

思考 一条查询语句如何执行&#xff1f;mysql语句中若列不存在&#xff0c;则在哪个阶段报错一条更新语句如何执行&#xff1f;redolog和binlog的区别&#xff1f;为什么要引入WAL什么是Changbuf&#xff1f;如何工作写缓冲一定好吗&#xff1f;什么情况会引发刷脏页删除语句会…
阅读更多...
最新文章

Copyright @ 2022~2023