初出茅庐的小李博客之使用立创开发板(ESP32)连接到EMQX Platform【MQTT TLS/SSL 端口连接】

介绍

手上有一块立创开发板，本着不吃灰的原则把它用起来，今天就来用它来连接上自己部署的MQTT服务器进行数据通信。

硬件：立创开发板
开发环境：Arduino IDE Win11
MQTT 平台：EMQX Platform

在这里插入图片描述

立创开发板介绍：

初出茅庐的小李博客之立创开发板初体验【Arduino IDE开发环境】：
地址：https://blog.csdn.net/weixin_43176183/article/details/139101412?spm=1001.2014.3001.5501

MQTT.fx客户端接入EMQX Platform

初出茅庐的小李博客之MQTT.fx客户端接入EMQX Platform
地址：https://blog.csdn.net/weixin_43176183/article/details/139190727?spm=1001.2014.3001.5501

参考文档：
https://docs.emqx.com/zh/cloud/latest/connect_to_deployments/esp32.html

过程记录：

安装MQTT依赖库

在 Arduino IDE 中完成以下安装。
先安装 ESP32 开发板。
点击工具 -> 开发板 -> 开发板管理。搜索 ESP32，点击安装 我已经安装过。
安装 PubSub client 库。
点击项目 -> 加载库 -> 管理库…。搜索 PubSubClient，安装 PubSubClient by Nick O’Leary。
通过 TCP 端口连接
在这里插入图片描述

写代码

  • 引入对应的库

#include "WiFi.h"
#include <PubSubClient.h>
#include <WiFiClientSecure.h>
  • 定义用户自定义参数

// WiFi Credentials
const char *ssid     = "AQST";             // Replace with your WiFi name
const char *password = "12345678";         // Replace with your WiFi password// MQTT Broker Settings
const char *mqtt_broker   = "xxxxxx.ala.cn-hangzhou.emqxsl.cn";//这里定义自己的连接地址
const char *mqtt_topic    = "emqx/esp32";
const char *mqtt_username = "AQ";
const char *mqtt_password = "123456";
const int   mqtt_port     = 8883;
  • 编写连接代码【准确的来说叫改写】
/连接Wifi热点函数
void ConnectToWiFi(void) 
{WiFi.begin(ssid, password);Serial.print("Connecting to WiFi");while (WiFi.status() != WL_CONNECTED){delay(500);Serial.print(".");}Serial.println("\nConnected to WiFi");
}
//连接MQTT代理函数
void ConnectToMQTT(void) 
{while (!mqtt_client.connected()){String client_id = "esp32-client-" + String(WiFi.macAddress());Serial.printf("Connecting to MQTT Broker as %s...\n", client_id.c_str());if(mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {Serial.println("Connected to MQTT broker");mqtt_client.subscribe(mqtt_topic);mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 by Arduino IED ^^");  // Publish message upon connection}else {Serial.print("Failed to connect to MQTT broker, rc=");Serial.print(mqtt_client.state());Serial.println(" Retrying in 5 seconds.");delay(5000);}}
}
//MQTT 回调函数
void MqttCallback(char *topic, byte *payload, unsigned int length)
{Serial.print("Message received on topic: ");Serial.println(topic);Serial.print("Message: ");for (unsigned int i = 0; i < length; i++) {Serial.print((char) payload[i]);//打印有效载荷的信息}Serial.println("\n-----------------------");
}
  • 函数调用

void setup(void)
{Serial.begin(115200);                         //设置串口参数ConnectToWiFi();                              //连接Wifi热点// Set Root CA certificateespClient.setCACert(ca_cert);                 //设置CA证书mqtt_client.setServer(mqtt_broker, mqtt_port);//指定代理 指定端口mqtt_client.setKeepAlive(60);                 //保活时间mqtt_client.setCallback(MqttCallback);        //回调函数ConnectToMQTT();                              //连接MQTT 代理}void loop(void) 
{if (!mqtt_client.connected()) {ConnectToMQTT();}mqtt_client.loop();
}

特别提示：这里的地址要写自己的地址 CA证书也要用自己的证书 否则连不上

官方原话：
添加服务端证书。如果您在使用公共 MQTT Broker、Serverless 部署或基础版部署的 TLS/SSL 端口连接，在此下载 CA 证书。 如您使用专业版 / BYOC 部署的 TLS/SSL 端口连接，请使用自己的服务端证书。

  • 开启MQTT服务器
    在这里插入图片描述

  • 编译烧录代码

在这里插入图片描述

用MQTT.fx连接到MQTT服务器跟ESP32开发板进行通信

发布消息：

在这里插入图片描述

ESP32收到订阅消息

在这里插入图片描述
这里可以看到开发板收到了消息 但是客户端提示收到的消息不是标准json
在这里插入图片描述
改进一下发送的数据格式

{"mag": "This is Json Data"
}

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

总结：

利用Arduino IED 进行MQTT通信 确实很方便，很容易就能实现两个设备的交互、但是使用库的缺点也很明显 有很多api不太懂它的意思，还需要进一步研究。

完整代码


#include "WiFi.h"
#include <PubSubClient.h>
#include <WiFiClientSecure.h>// WiFi Credentials
const char *ssid     = "AQST";             // Replace with your WiFi name
const char *password = "12345678";         // Replace with your WiFi password// MQTT Broker Settings
const char *mqtt_broker   = "xxxxxxx.ala.cn-hangzhou.emqxsl.cn";//这里要改成自己的地址！！！！
const char *mqtt_topic    = "emqx/esp32";
const char *mqtt_username = "AQ";
const char *mqtt_password = "123456";
const int   mqtt_port     = 8883;WiFiClientSecure espClient;
PubSubClient mqtt_client(espClient);void ConnectToWiFi(void);//函数声明
void ConnectToMQTT(void);//函数声明
void MqttCallback(char *mqtt_topic, byte *payload, unsigned int length);//函数声明const char *ca_cert = R"EOF(
-----BEGIN CERTIFICATE-----
MIIDrzCCApegAwIBAgIQCDvgVpBCRrGhdWrJWZHHSjANBgkqhkiG9w0BAQUFADBh
MQswCQYDVQQGEwJVUzEVMBMGA1UEChMMRGlnaUNlcnQgSW5jMRkwFwYDVQQLExB3
d3cuZGlnaWNlcnQuY29tMSAwHgYDVQQDExdEaWdpQ2VydCBHbG9iYWwgUm9vdCBD
QTAeFw0wNjExMTAwMDAwMDBaFw0zMTExMTAwMDAwMDBaMGExCzAJBgNVBAYTAlVT
MRUwEwYDVQQKEwxEaWdpQ2VydCBJbmMxGTAXBgNVBAsTEHd3dy5kaWdpY2VydC5j
b20xIDAeBgNVBAMTF0RpZ2lDZXJ0IEdsb2JhbCBSb290IENBMIIBIjANBgkqhkiG
9w0BAQEFAAOCAQ8AMIIBCgKCAQEA4jvhEXLeqKTTo1eqUKKPC3eQyaKl7hLOllsB
CSDMAZOnTjC3U/dDxGkAV53ijSLdhwZAAIEJzs4bg7/fzTtxRuLWZscFs3YnFo97
nh6Vfe63SKMI2tavegw5BmV/Sl0fvBf4q77uKNd0f3p4mVmFaG5cIzJLv07A6Fpt
43C/dxC//AH2hdmoRBBYMql1GNXRor5H4idq9Joz+EkIYIvUX7Q6hL+hqkpMfT7P
T19sdl6gSzeRntwi5m3OFBqOasv+zbMUZBfHWymeMr/y7vrTC0LUq7dBMtoM1O/4
gdW7jVg/tRvoSSiicNoxBN33shbyTApOB6jtSj1etX+jkMOvJwIDAQABo2MwYTAO
BgNVHQ8BAf8EBAMCAYYwDwYDVR0TAQH/BAUwAwEB/zAdBgNVHQ4EFgQUA95QNVbR
TLtm8KPiGxvDl7I90VUwHwYDVR0jBBgwFoAUA95QNVbRTLtm8KPiGxvDl7I90VUw
DQYJKoZIhvcNAQEFBQADggEBAMucN6pIExIK+t1EnE9SsPTfrgT1eXkIoyQY/Esr
hMAtudXH/vTBH1jLuG2cenTnmCmrEbXjcKChzUyImZOMkXDiqw8cvpOp/2PV5Adg
06O/nVsJ8dWO41P0jmP6P6fbtGbfYmbW0W5BjfIttep3Sp+dWOIrWcBAI+0tKIJF
PnlUkiaY4IBIqDfv8NZ5YBberOgOzW6sRBc4L0na4UU+Krk2U886UAb3LujEV0ls
YSEY1QSteDwsOoBrp+uvFRTp2InBuThs4pFsiv9kuXclVzDAGySj4dzp30d8tbQk
CAUw7C29C79Fv1C5qfPrmAESrciIxpg0X40KPMbp1ZWVbd4=
-----END CERTIFICATE-----
)EOF";void setup(void)
{Serial.begin(115200);                         //设置串口参数ConnectToWiFi();                              //连接Wifi热点// Set Root CA certificateespClient.setCACert(ca_cert);                 //设置CA证书mqtt_client.setServer(mqtt_broker, mqtt_port);//指定代理 指定端口mqtt_client.setKeepAlive(60);                 //保活时间mqtt_client.setCallback(MqttCallback);        //回调函数ConnectToMQTT();                              //连接MQTT 代理}//连接Wifi热点函数
void ConnectToWiFi(void) 
{WiFi.begin(ssid, password);Serial.print("Connecting to WiFi");while (WiFi.status() != WL_CONNECTED){delay(500);Serial.print(".");}Serial.println("\nConnected to WiFi");
}
//连接MQTT代理函数
void ConnectToMQTT(void) 
{while (!mqtt_client.connected()){String client_id = "esp32-client-" + String(WiFi.macAddress());Serial.printf("Connecting to MQTT Broker as %s...\n", client_id.c_str());if(mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password)) {Serial.println("Connected to MQTT broker");mqtt_client.subscribe(mqtt_topic);mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 by Arduino IED ^^");  // Publish message upon connection}else {Serial.print("Failed to connect to MQTT broker, rc=");Serial.print(mqtt_client.state());Serial.println(" Retrying in 5 seconds.");delay(5000);}}
}
//MQTT 回调函数
void MqttCallback(char *topic, byte *payload, unsigned int length)
{Serial.print("Message received on topic: ");Serial.println(topic);Serial.print("Message: ");for (unsigned int i = 0; i < length; i++) {Serial.print((char) payload[i]);//打印有效载荷的信息}Serial.println("\n-----------------------");
}void loop(void) 
{if (!mqtt_client.connected()) {ConnectToMQTT();}mqtt_client.loop();
}// WiFiClient espClient;
// PubSubClient mqtt_client(espClient);// void setup(void) 
// {
//   Serial.begin(115200);
//   ConnectToWiFi(); //连接指定热点
//   //mqtt_client.setServer(mqtt_broker, mqtt_port);
//   espClient.setCACert(ca_cert);
//   mqtt_client.setKeepAlive(60);
//   mqtt_client.setCallback(MqttCallback); // Corrected callback function name
//   ConnectToMQTT();
// }// void loop(void) 
// {
//   if (!mqtt_client.connected()) 
//   {
//     ConnectToMQTT();
//   }
//   mqtt_client.loop();
// }//用户自定义函数
// void ConnectToWiFi(void) 
// {
//     WiFi.begin(ssid, password);
//     Serial.print("Connecting to WiFi");
//     while (WiFi.status() != WL_CONNECTED) 
//     {
//         delay(500);
//         Serial.print(".");
//     }
//     Serial.println("\nConnected to WiFi");
// }
// //用户自定义函数
// void ConnectToMQTT(void) 
// {
//   while (!mqtt_client.connected()) 
//   {
//     String client_id = "esp32-client-" + String(WiFi.macAddress());//     Serial.printf("Connecting to MQTT Broker as %s.....\n", client_id.c_str());//     if (mqtt_client.connect(client_id.c_str(), mqtt_username, mqtt_password))
//     {
//       Serial.println("Connected to MQTT broker");
//       mqtt_client.subscribe(mqtt_topic);
//       mqtt_client.publish(mqtt_topic, "Hi EMQX I'm ESP32 ^^"); // Publish message upon successful connection
//     }
//     else 
//     {
//       Serial.print("Failed, rc=");
//       Serial.print(mqtt_client.state());
//       Serial.println(" try again in 5 seconds");
//       delay(5000);
//     }
//   }
// }//用户自定义回调函数
// void MqttCallback(char *mqtt_topic, byte *payload, unsigned int length)
// {
//   Serial.print("Message received on mqtt_topic: ");
//   Serial.println(mqtt_topic);
//   Serial.print("Message: ");
//   for (unsigned int i = 0; i < length; i++) 
//   {
//     Serial.print((char) payload[i]);
//   }
//   Serial.println("\n-----------------------");
// }

视频：

https://www.bilibili.com/video/BV1gJ4m1A7bg/?pop_share=1

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

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

相关文章

论文总结：Grasp-Anything: Large-scale Grasp Dataset from Foundation Models

论文总结：Grasp-Anything: Large-scale Grasp Dataset from Foundation Models

目录 一、论文摘要 二、Grasp-Anything数据集 A. 场景生成 B. 抓取姿势标注 ​编辑 C. Grasp-Anything统计 D. Grasp-Anything对社区的帮助 三、实验 A. 零样本抓取检测 B. 机器人评估 C. 野外抓取检测 D. 讨论 四、总结 论文&#xff1a;https://arxiv.org/pdf/2…
阅读更多...
Kafka系列之高频面试题

Kafka系列之高频面试题

基础 简介 特点&#xff1a; 高吞吐、低延迟&#xff1a;kafka每秒可以处理几十万条消息&#xff0c;延迟最低只有几毫秒&#xff0c;每个Topic可以分多个Partition&#xff0c;Consumer Group对Partition进行Consumer操作可扩展性&#xff1a;Kafka集群支持热扩展持久性、可…
阅读更多...
STM32启动过程分析

STM32启动过程分析

Keil堆栈设置注意事项 一、启动模式 复位方式&#xff1a;上电复位、硬件复位、软件复位 从地址0x0000 0000处取出堆栈指针MSP的初始值&#xff0c;该值就是栈顶地址。从地址0x0000 0004处取出程序计数器指针PC的初始值&#xff0c;该值指向复位后执行的第一条指令。 说白了就…
阅读更多...
基于模板匹配的信用卡数字识别

基于模板匹配的信用卡数字识别

文章目录 一、项目介绍二、模板匹配的原理三、模板匹配的步骤模板图片处理信用卡图片处理进行模板匹配 一、项目介绍 模板识别&#xff08;Template Matching&#xff09;是一种基于图像匹配的技术&#xff0c;用于在较大图像中识别和定位小图像&#xff08;模板&#xff09;。…
阅读更多...
YOLO目标检测：框架技术原理和代码实现

YOLO目标检测：框架技术原理和代码实现

Dream推荐 适读人群 &#xff1a;本书适合对YOLO目标检测感兴趣、了解深度学习相关概念的算法工程师、软件工程师等人员阅读。 全面&#xff1a;涵盖6个常用目标检测框架&#xff08;YOLOv1、YOLOv2、YOLOv3、YOLOv4、YOLOX、YOLOv7&#xff09;的发展状况、技术原理和代码实…
阅读更多...
【Spring EL＜一＞✈️ 】SL 表达式的应用

【Spring EL＜一＞✈️ 】SL 表达式的应用

目录 &#x1f378;前言 &#x1f37b;一、Spring EL 1.1 定义 1.2 常见使用方式 &#x1f37a;二、项目案例 2.1 实现一个简单的案例 2.2 创建注解 2.3 切面类实现 2.4 创建测试接口 2.5 测试 &#x1f379;三、章末 &#x1f378;前言 小伙伴们大家好&#xff0c;前段时间…
阅读更多...
32. 【Java教程】集合

32. 【Java教程】集合

在前面的小节中&#xff0c;我们学习了数组&#xff0c;本小节学习的集合同样用于存放一组数据&#xff0c;我们将学习什么是集合、集合的应用场景 &#xff0c;在应用场景部分我们将对比 Java 数组与集合的区别&#xff0c;还将系统介绍 Java 集合的架构&#xff0c;也将结合实…
阅读更多...
【观察】数字化生存时代已来临，能源转型如何实现“再升级”？

【观察】数字化生存时代已来临，能源转型如何实现“再升级”？

20多年前&#xff0c;尼古拉斯尼葛洛庞帝在《数字化生存》一书中预言&#xff1a;“数字化生存是现代社会中以新技术为基础的新的生存方式。” 随着数字经济的蓬勃发展&#xff0c;尼葛洛庞帝的预言逐渐被验证。今天&#xff0c;新技术带来的数字化和智能化正全方位影响着经济…
阅读更多...
【赠书第27期】向AI提问的艺术：提示工程入门与应用

【赠书第27期】向AI提问的艺术：提示工程入门与应用

文章目录 前言 1 问题的构建 1.1 明确性与具体性 1.2 结构化与层次性 1.3 相关性与针对性 2 提问的技巧 2.1 简洁明了 2.2 避免歧义 2.3 使用自然语言 3 与AI的互动策略 3.1 耐心与理解 3.2 逐步引导 3.3 反馈与调整 4 总结与展望 5 推荐图书 6 粉丝福利 前言 …
阅读更多...
定时器与PWM的LED控制

定时器与PWM的LED控制

目录 一、基础概念定时器定时器类型定时器特性 PWM定义占空比原理 二、实验1.LED周期性亮灭定时器TIM2配置GPIO引脚设置工程相关参数配置Keil编写程序 2.LED呼吸灯(PWM)呼吸灯原理Keil编写程序Keil虚拟示波器&#xff0c;观察 PWM输出波形设置点击setup&#xff0c;并设置观察引…
阅读更多...
Sapphire开发日志（三）

Sapphire开发日志（三）

任务描述 本周实现并封装了模型的运行&#xff0c;需要在前端安装依赖的库&#xff0c;编写对应的处理函数。同时需要能够展示出抠图效果。 依赖与环境配置 尝试在前端接入并运行onnx。 在前端运行onnx依赖于onnxruntime-web这个包&#xff0c;这个包可以在浏览器进行模型推…
阅读更多...
antV+vue3 单选框选中加入逻辑运算，再次点击取消选中，不计入逻辑运算

antV+vue3 单选框选中加入逻辑运算，再次点击取消选中，不计入逻辑运算

文章目录 antVvue3 单选框选中加入逻辑运算&#xff0c;再次点击取消选中&#xff0c;不计入逻辑运算需求增加点击事件逻辑处理效果 antVvue3 单选框选中加入逻辑运算&#xff0c;再次点击取消选中&#xff0c;不计入逻辑运算 需求 在做项目时&#xff0c;多次遇到单选框需要再…
阅读更多...
【2024新版】银系统源码/超市收银系统/智慧新零售/ERP进销存管理/线上商城/商户助手

【2024新版】银系统源码/超市收银系统/智慧新零售/ERP进销存管理/线上商城/商户助手

>>>系统简述&#xff1a;本系统适用于超吃便利店&#xff0c;美妆母婴行业&#xff0c;服装鞋帽行业&#xff0c;食品零售行业&#xff0c;3C数码电子行业&#xff0c;食品生鲜等一切零售行业&#xff0c;产品功能角色介绍如下 合伙人&#xff1a;无限发展代理商和商…
阅读更多...
Pod 控制器

Pod 控制器

前言 Pod 是 Kubernetes 集群中能够被创建和管理的最小部署单元。所以需要有工具去操作和管理它们的生命周期,这里就需要用到控制器了。 Pod 控制器由 master 的 kube-controller-manager 组件提供&#xff0c;常见的此类控制器有 Replication Controller、ReplicaSet、Deploym…
阅读更多...
React-生成随机数和日期格式化

React-生成随机数和日期格式化

生成随机数 uuid文档&#xff1a;https://github.com/uuidjs/uuid npm install uuid import {v4 as uuidV4} from uuid 使用&#xff1a; uuidV4() 日期格式化 dayjs文档&#xff1a;安装 | Day.js中文网 npm install dayjs import dayjs from dayjs
阅读更多...
算法-扫描线

算法-扫描线

目录 什么是扫描线算法&#xff1f; 扫描线简单应用 更多的扫描线 什么是扫描线算法&#xff1f; 在计算几何中&#xff0c;扫描线算法&#xff08;scan line algorithm&#xff09;一般用来解决几何图形的面积交并&#xff0c;周长交并问题&#xff0c;扫描线算法的核心思想…
阅读更多...
SAPUI5基础知识3 - 引导过程（Bootstrap）

SAPUI5基础知识3 - 引导过程（Bootstrap）

1. 背景 在上一篇博客中&#xff0c;我们已经建立出了第一个SAPUI5项目&#xff0c;接下来&#xff0c;我们将为这个项目添加引导过程。 在动手练习之前&#xff0c;让我们先解释一下什么引导过程。 1.1 什么是引导过程&#xff1f; 在计算机科学中&#xff0c;引导过程也称…
阅读更多...
5、css3 自动动画渐变背景

5、css3 自动动画渐变背景

效果例图&#xff1a;&#xff08;因gif图片太大&#xff0c;而csdn只能上传小于5m图片&#xff0c;所以无法上传&#xff09; 1、首先上传html代码&#xff1a; <!DOCTYPE html> <html lang"zh"> <head><meta charset"UTF-8">&l…
阅读更多...
【鸟哥】Linux笔记-硬件搭配

【鸟哥】Linux笔记-硬件搭配

在Linux这个系统当中&#xff0c;几乎所有的硬件设备文件都在/dev这个目录内。打印机与软盘呢&#xff1f;分别是/dev/lp0, /dev/fd0。 几个常见的设备与其在Linux当中的文件名&#xff1a; 如果你的机器使用的是跟网际网络供应商 &#xff08;ISP&#xff09; 申请使用的云端…
阅读更多...
二叉树的构建和遍历（oj题）

二叉树的构建和遍历（oj题）

一、题目链接 https://www.nowcoder.com/practice/4b91205483694f449f94c179883c1fef?tpId60&&tqId29483&rp1&ru/activity/oj&qru/ta/tsing-kaoyan/question-ranking 二、题目思路 利用先序遍历的方法&#xff0c;构建二叉树。为了保证在递归中&#xf…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023