基于Arduino IDE 野火ESP8266模块 MQTT 的开发

一、库介绍

 Arduino常用的MQTT库主要有PubSubClient。
 PubSubClient库是一个广泛使用的MQTT客户端库，它基于MQTT 3.1.1版本，并且支持ESP8266和ESP32等Arduino兼容的硬件平台。PubSubClient库允许Arduino设备连接到MQTT服务器，发布和订阅MQTT主题，实现与其他设备或服务的通信。
 在使用PubSubClient库时，需要将其包含在Arduino项目中，并配置MQTT服务器的地址、端口、客户端ID等参数。然后可以使用库提供的函数来建立MQTT连接、发布消息到特定的主题，以及订阅并处理接收到的消息。
 除了PubSubClient库之外，还有其他一些MQTT库可供选择，但PubSubClient因其易用性和稳定性而广受欢迎。需要根据具体需求和项目环境选择适合的MQTT库。
安装完库，可查看官方的示例代码，查看方法如下：
在这里插入图片描述

官方示例代码如下：

/*Basic ESP8266 MQTT exampleThis sketch demonstrates the capabilities of the pubsub library in combinationwith the ESP8266 board/library.It connects to an MQTT server then:- publishes "hello world" to the topic "outTopic" every two seconds- subscribes to the topic "inTopic", printing out any messagesit receives. NB - it assumes the received payloads are strings not binary- If the first character of the topic "inTopic" is an 1, switch ON the ESP Led,else switch it offIt will reconnect to the server if the connection is lost using a blockingreconnect function. See the 'mqtt_reconnect_nonblocking' example for how toachieve the same result without blocking the main loop.To install the ESP8266 board, (using Arduino 1.6.4+):- Add the following 3rd party board manager under "File -> Preferences -> Additional Boards Manager URLs":http://arduino.esp8266.com/stable/package_esp8266com_index.json- Open the "Tools -> Board -> Board Manager" and click install for the ESP8266"- Select your ESP8266 in "Tools -> Board"
*/#include <ESP8266WiFi.h>
#include <PubSubClient.h>// Update these with values suitable for your network.const char* ssid = "........";
const char* password = "........";
const char* mqtt_server = "broker.mqtt-dashboard.com";WiFiClient espClient;
PubSubClient client(espClient);
unsigned long lastMsg = 0;
#define MSG_BUFFER_SIZE	(50)
char msg[MSG_BUFFER_SIZE];
int value = 0;void setup_wifi() {delay(10);// We start by connecting to a WiFi networkSerial.println();Serial.print("Connecting to ");Serial.println(ssid);WiFi.mode(WIFI_STA);WiFi.begin(ssid, password);while (WiFi.status() != WL_CONNECTED) {delay(500);Serial.print(".");}randomSeed(micros());Serial.println("");Serial.println("WiFi connected");Serial.println("IP address: ");Serial.println(WiFi.localIP());
}void callback(char* topic, byte* payload, unsigned int length) {Serial.print("Message arrived [");Serial.print(topic);Serial.print("] ");for (int i = 0; i < length; i++) {Serial.print((char)payload[i]);}Serial.println();// Switch on the LED if an 1 was received as first characterif ((char)payload[0] == '1') {digitalWrite(BUILTIN_LED, LOW);   // Turn the LED on (Note that LOW is the voltage level// but actually the LED is on; this is because// it is active low on the ESP-01)} else {digitalWrite(BUILTIN_LED, HIGH);  // Turn the LED off by making the voltage HIGH}}void reconnect() {// Loop until we're reconnectedwhile (!client.connected()) {Serial.print("Attempting MQTT connection...");// Create a random client IDString clientId = "ESP8266Client-";clientId += String(random(0xffff), HEX);// Attempt to connectif (client.connect(clientId.c_str())) {Serial.println("connected");// Once connected, publish an announcement...client.publish("outTopic", "hello world");// ... and resubscribeclient.subscribe("inTopic");} else {Serial.print("failed, rc=");Serial.print(client.state());Serial.println(" try again in 5 seconds");// Wait 5 seconds before retryingdelay(5000);}}
}void setup() {pinMode(BUILTIN_LED, OUTPUT);     // Initialize the BUILTIN_LED pin as an outputSerial.begin(115200);setup_wifi();client.setServer(mqtt_server, 1883);client.setCallback(callback);
}void loop() {if (!client.connected()) {reconnect();}client.loop();unsigned long now = millis();if (now - lastMsg > 2000) {lastMsg = now;++value;snprintf (msg, MSG_BUFFER_SIZE, "hello world #%ld", value);Serial.print("Publish message: ");Serial.println(msg);client.publish("outTopic", msg);}
}

二、代码设计

代码设计思路：
1.包含库：在Arduino项目中，包含必要的库文件，特别是MQTT库（如pubsubclient）。
2.WiFi设置：设置ESP8266连接到指定的WiFi网络所需的SSID和密码。
3.MQTT服务器设置：配置MQTT服务器的地址、端口以及任何必要的认证信息（如用户名和密码）。
4.回调函数：设置MQTT连接、发布和订阅的回调函数，以便处理与MQTT服务器的通信。
5.初始化和连接：在setup()函数中初始化MQTT客户端，并尝试连接到MQTT服务器。
6.消息处理：在loop()函数中处理MQTT消息，例如发布消息到特定的主题或响应订阅的主题消息。

测试代码如下：

#include <ESP8266WiFi.h>  
#include <PubSubClient.h>  // WiFi设置  
const char* ssid = "yourSSID";  
const char* password = "yourPASSWORD";  // MQTT服务器设置  
const char* mqtt_server = "yourMQTTServer";  
const int mqtt_port = 1883;  
const char* mqtt_client_id = "ESP8266Client";  
const char* mqtt_topic = "your/topic";  //
unsigned long lastMsg = 0;WiFiClient espClient;  
PubSubClient client(espClient);  void setup_wifi() {  delay(10);  // 连接到WiFi网络  Serial.print("Connecting to ");  Serial.println(ssid);  WiFi.begin(ssid, password);  while (WiFi.status() != WL_CONNECTED) {  delay(500);  Serial.print(".");  }  Serial.println("");  Serial.println("WiFi connected");  Serial.print("IP address: ");  Serial.println(WiFi.localIP());  
}  void reconnect() {  // Loop until we're reconnected  while (!client.connected()) {  Serial.print("Attempting MQTT connection...");  // 连接到MQTT服务器  if (client.connect(mqtt_client_id)) {  Serial.println("connected");  // 一旦连接，订阅主题  client.subscribe(mqtt_topic);  } else {  delay(5000);  }  }  
}  void callback(char* topic, byte* payload, unsigned int length) {  // 处理接收到的消息  Serial.print("Message arrived [");  Serial.print(topic);  Serial.print("] ");  for (int i = 0; i < length; i++) {  Serial.print((char)payload[i]);  }  Serial.println();  
}  void setup() {  Serial.begin(115200);  setup_wifi();  client.setServer(mqtt_server, mqtt_port);  client.setCallback(callback);  
}  void loop() {  if (!client.connected()) {  reconnect();  }  client.loop();  // 每隔一段时间发布一条消息到MQTT主题  long now = millis();  if (now - lastMsg > 2000) {  lastMsg = now;  char msg[50];  snprintf(msg, 50, "hello world at %ld", now);  client.publish(mqtt_topic, msg);  }  
}

 请确保上述代码中的yourSSID、yourPASSWORD、yourMQTTServer、your/topic替换为实际的SSID、密码、MQTT服务器地址和主题。
 这个示例代码首先设置了WiFi连接，然后连接到MQTT服务器。一旦连接成功，它将订阅一个MQTT主题。在loop()函数中，它周期性地发布消息到该主题，并处理从该主题接收到的任何消息。
 此外，MQTT服务器的地址、端口和凭据（如果需要的话）应根据实际的MQTT服务器配置进行调整。如MQTT服务器需要用户名和密码，PubSubClient库也提供了设置这些的方法。
 上传成功后，打开串口监视器来查看ESP8266与MQTT服务器的通信日志。

三、测试结果

MQTT的参数配置如下：

// MQTT服务器设置  
const char* mqtt_server = "broker.mqtt-dashboard.com";  
const int mqtt_port = 1883;  
const char* mqtt_client_id = "ESP8266Client0326";  
const char* mqtt_topic = "test/topic";

esp8266模块运行串口打印如下：
在这里插入图片描述更换其它服务器进行测试，如下：
在这里插入图片描述

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

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

相关文章

electron+VUE Browserwindow与webview通信

electron+VUE Browserwindow与webview通信

仅做记录 前言&#xff1a; electronVUEVITE框架&#xff0c;用的是VUE3.0 主进程定义&#xff1a;用于接收webview发送的消息 ipcMain.on(MyWebviewMessage, (event, message) > {logger.info(收到webmsg message)//转发给渲染进程}) porelaod/webPreload.js定义 cons…
阅读更多...
C语言编译与链接

C语言编译与链接

前言 我们想一个问题&#xff0c;我们写的C语言代码都是文本信息&#xff0c;电脑能直接执行c语言代码吗&#xff1f;肯定不能啊&#xff0c;计算机能执行的是二进制指令&#xff0c;所以将C语言转化为二进制指令需要一段过程&#xff0c;这篇博客讲一下编译与链接&#xff0c;…
阅读更多...
Day26 手撕各种集合底层源码（一）

Day26 手撕各种集合底层源码（一）

Day26 手撕各种集合底层源码&#xff08;一&#xff09; 一、手撕ArrayList底层源码 1、概念&#xff1a; ArrayList的底层实现是基于数组的动态扩容结构。 2、思路&#xff1a; 1.研究继承关系 2.研究属性 3.理解创建集合的过程 – 构造方法的底层原理 4.研究添加元素的过程…
阅读更多...
vue实现把Ox格式颜色值转换成rgb渐变颜色值（开箱即用）

vue实现把Ox格式颜色值转换成rgb渐变颜色值（开箱即用）

图示&#xff1a; 核心代码&#xff1a; //将0x格式的颜色转换为Hex格式&#xff0c;并计算插值返回rgb颜色 Vue.prototype.$convertToHex function (colorCode1, colorCode2, amount) {// 确保输入是字符串&#xff0c;并检查是否以0x开头let newCode1 let newCode2 if (t…
阅读更多...
关系型数据库mysql（5）存储引擎

关系型数据库mysql（5）存储引擎

目录 一.存储引擎的概念 二. MyISAM 和 InnoDB 2.1MyISAM介绍 2.2MyISAM支持的存储格式 2.2.1静态表&#xff08;固定长度表&#xff09; 2.2.2动态表 2.2.3压缩表 2.3场景举例 2.4.InnoDB 2.4.1场景举例 2.4.2企业选择存储引擎依据 三.查看存储引擎 3.1查看当前数…
阅读更多...
C++中的STL简介与string类

C++中的STL简介与string类

目录 STL简介 STL的版本 STL的六大组件 string类 标准库中的string类 string类的常用接口 string类对象对容量的操作 size()函数与length()函数 capacity()函数 capacity的扩容方式 reserve()函数 resize()函数 string类对象的操作 push_back()函数 append()函数 operator()函数…
阅读更多...
【01-20】计算机网络基础知识（非常详细）从零基础入门到精通，看完这一篇就够了

【01-20】计算机网络基础知识（非常详细）从零基础入门到精通，看完这一篇就够了

【01-20】计算机网络基础知识&#xff08;非常详细&#xff09;从零基础入门到精通&#xff0c;看完这一篇就够了 以下是本文参考的资料 欢迎大家查收原版 本版本仅作个人笔记使用1、OSI 的七层模型分别是&#xff1f;各自的功能是什么&#xff1f;2、说一下一次完整的HTTP请求…
阅读更多...
记录何凯明在MIT的第一堂课：神经网络发展史

记录何凯明在MIT的第一堂课：神经网络发展史

https://www.youtube.com/watch?vZ5qJ9IxSuKo 目录 表征学习 主要特点&#xff1a; 方法和技术&#xff1a; LeNet 全连接层​ 主要特点&#xff1a; 主要特点&#xff1a; 网络结构&#xff1a; AlexNet 主要特点&#xff1a; 网络结构&#xff1a; Sigmoid Re…
阅读更多...
经典永不过时 Wordpress模板主题

经典永不过时 Wordpress模板主题

经得住时间考验的模板&#xff0c;才是经典模板&#xff0c;带得来客户的网站&#xff0c;才叫NB网站。 https://www.jianzhanpress.com/?p2484
阅读更多...
第十五届蓝桥杯第三期模拟赛第十题 ← 上楼梯

第十五届蓝桥杯第三期模拟赛第十题 ← 上楼梯

【问题描述】 小蓝要上一个楼梯&#xff0c;楼梯共有 n 级台阶&#xff08;即小蓝总共要走 n 级&#xff09;。小蓝每一步可以走 a 级、b 级或 c 级台阶。 请问小蓝总共有多少种方案能正好走到楼梯顶端&#xff1f;【输入格式】 输入的第一行包含一个整数 n 。 第二行包含三个整…
阅读更多...
vulfocus环境搭建（kali搭建）

vulfocus环境搭建（kali搭建）

Vulfocus 是一个漏洞集成平台&#xff0c;将漏洞环境 docker 镜像&#xff0c;放入即可使用&#xff0c;开箱即用。 安装docker环境 个人不建议随意更换apt源&#xff0c;我换了几次遇到很多问题。 apt-get update apt-get upgrade&#xff08;时间很久&#xff09; apt-get i…
阅读更多...
基于springboot的人事管理系统

基于springboot的人事管理系统

人事管理系统 摘 要 人事管理系统理工作是一种繁琐的&#xff0c;务求准确迅速的信息检索工作。随着计算机信息技术的飞速发展&#xff0c;人类进入信息时代&#xff0c;社会的竞争越来越激烈&#xff0c;人事就越显示出其不可或缺性&#xff0c;成为学校一个非常重要的模块。…
阅读更多...
防止恶意软件和网络攻击的简单贴士

防止恶意软件和网络攻击的简单贴士

如今&#xff0c;缺少互联网的生活是难以想象的。然而&#xff0c;互联网的匿名性导致了网络攻击和恶意软件很猖獗。恶意软件会损坏我们的设备、窃取个人数据&#xff0c;并导致金钱损失。因此&#xff0c;保护计算机免受这些威胁显得至关重要。 一、确保操作系统和软件是最新版…
阅读更多...
企业数据资产管理的战略价值与实施策略

企业数据资产管理的战略价值与实施策略

一、引言 数据资产不仅记录了企业的历史运营情况&#xff0c;更能够揭示市场的未来趋势&#xff0c;为企业的决策提供有力支持。因此&#xff0c;如何有效地管理和利用数据资产&#xff0c;已经成为企业竞争力的重要体现。本文将探讨企业数据资产管理的战略价值与实施策略&…
阅读更多...
URL编码：原理、应用与安全性

URL编码：原理、应用与安全性

title: URL编码&#xff1a;原理、应用与安全性 date: 2024/3/29 18:32:42 updated: 2024/3/29 18:32:42 tags: URL编码百分号编码特殊字符处理网络安全应用场景标准演变未来发展 在网络世界中&#xff0c;URL&#xff08;统一资源定位符&#xff09;是我们访问网页、发送请求…
阅读更多...
设计模式之单例模式精讲

设计模式之单例模式精讲

UML图&#xff1a; 静态私有变量&#xff08;即常量&#xff09;保存单例对象&#xff0c;防止使用过程中重新赋值&#xff0c;破坏单例。私有化构造方法&#xff0c;防止外部创建新的对象&#xff0c;破坏单例。静态公共getInstance方法&#xff0c;作为唯一获取单例对象的入口…
阅读更多...
速通汇编（二）汇编mov、addsub指令

速通汇编（二）汇编mov、addsub指令

一&#xff0c;mov指令 mov指令的全称是move&#xff0c;从字面上去理解&#xff0c;作用是移动&#xff08;比较确切的说是复制&#xff09;数据&#xff0c;mov指令可以有以下几种形式 无论哪种形式&#xff0c;都是把右边的值移动到左边 mov 寄存器&#xff0c;数据&#…
阅读更多...
AI 创新领跑者，KIP Protocol 如何理解 Decentralized AI

AI 创新领跑者，KIP Protocol 如何理解 Decentralized AI

随着 OpenAI 的 Sora 推动 AI 赛道的热度攀升&#xff0c;AI 领域再次成为科技和投资界的焦点。KIP Protocol 是面向 AI 模型制作者、App 开发者和数据所有者构建的去中心化 Web3 协议层&#xff0c;使数据可在 Web3 中安全地进行交易和货币化。KIP Protocol 由 Animoca Ventur…
阅读更多...
Jenkins实现CICD

Jenkins实现CICD

Jenkins实现CICD JenkinsCI简介环境安装新建任务源码管理构建配置发送邮件配置自动化项目定时构建 JenkinsCD简介配置ssh保证其可以免登录接下来配置github的webhook正式实现自动化打包master主分支的代码将前端三剑客代码文件发送到网站服务器对应的tomcat Jenkins面试题 Jenk…
阅读更多...
个人简历主页搭建系列-04：网站初搭建

个人简历主页搭建系列-04：网站初搭建

准备工作差不多了&#xff0c;该开始搭建网站了&#xff01; 这次我们先把网站搭建部署起来&#xff0c;关于后续主题内容等更换留到后续。 创建源码文件夹 首先通过 hexo 创建本地源码文件夹。因为最终部署的 github 仓库格式为 websiteName.github.io&#xff08;websiteN…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023