web网页毗连MQTT，显示数据与下发控制命令

南七星之家 · 2024-8-14 13:03:37

web网页毗连MQTT，显示数据与下发控制命令

零、前言

在完成一些装备作品后，常常会因为没有一个上位机用来实时检测数据和下发命令而苦恼，在上一篇文章中提到了怎么白嫖阿里云服务器，并且在上面搭建了属于自己的web网站。那么如今就可以使用这个公网web来实现一个上位机，这样就可以在有网的地方随时对装备举行监控和下发控制指令。以下就是完成这样一个可以毗连MQTT服务器的web的制作过程。
一、body部门

html网页具有许多部门，此中最重要的是body部门，这部门决定了网站显示什么东西，stye部门就是对这部门举行美化。今天只完乐成能，不对样式举行美化，有需要自行学习。
1.显示部门

用于显示数据，常用的有标签、文本框、标题等。显示部门我写了一个大标题，另有几个用于显示一些数据的文本，例如温度、湿度、光照强度等，这部门代码如下：

<h1>物联网Web界面示例</h1>
<h2>示例参数</h2>
<p>温度：<span id="temperature">25°C</span></p>
<p>湿度：<span id="humidity">50%</span></p>
<p>光照强度：<span id="light">800 lux</span></p>

复制代码

温度、湿度、光照强度这三部门需要有自己唯一的id，以便于后续可以通过id来索引到，进而对显示内容举行修改。
2.按钮部门

除了有显示以外，还需要有控制，控制最常用的就是按钮的形式。举例了三个按钮，分别是控制灯光、打开装备、关闭装备

<h2>示例按钮</h2>
<button onclick="toggleLight()">控制灯光</button>
<button onclick="sendCommand('turnOn')">打开设备</button>
<button onclick="sendCommand('turnOff')">关闭设备</button>

复制代码

此中的onclick就是点击按钮后，会触发执行的函数。
二、script部门

在这部门中主要写的是处理逻辑相干的代码，包括MQTT毗连、数据监听、发送消息等等。
1.毗连MQTT

要在web中使用MQTT服务，需要引入MQTT相干的库，使用如下代码即可引入：

<script src="https://cdnjs.cloudflare.com/ajax/libs/mqtt/4.2.8/mqtt.min.js"></script>

复制代码

随后就可以使用MQTT的服务了，首先需要设置毗连参数，例如使用的MQTT的服务器所在、端口、主题等等。例如使用开源免费的emqx服务器为例，设置一下发布主题和订阅主题：

// MQTT 连接配置
const mqttBroker = 'ws://broker-cn.emqx.io:8083/mqtt';
const publish_Topic = 'iot/my_pub';
const subscribe_Topic = 'iot/my_sub';

复制代码

随后调用connect函数即可毗连MQTT服务器了：

// 创建 MQTT 客户端实例
const mqttClient = mqtt.connect(mqttBroker);

复制代码

这样就可以实验毗连到开源的emqx服务器上了，那到底有没有毗连上呢，还需要写点代码来验证，我们就让web毗连上后打印一下毗连乐成。代码如下：

// 连接事件处理
mqttClient.on('connect', function () {
console.log('连接成功');
// 订阅主题
mqttClient.subscribe(subscribe_Topic);
});

复制代码

这样网页乐成毗连上MQTT服务器后，就会在浏览器控制台打印毗连乐成，如图所示：

2.监听信息

在使用过程中，web界面需要不停监听订阅主题上有没有新的消息，如果有消息，就要及时根据新的消息更新web显示的内容。代码如下：

// 监听消息
mqttClient.on('message', function (topic, message) {
console.log("收到信息：" + message)
update_Status(message.toString());
});
//更新消息
function update_Status(msg) {
try {
const data = JSON.parse(msg); // 尝试解析收到的 JSON 格式消息
const temperature = data.temperature; // 假设 JSON 数据中有 temperature 字段
const humidity = data.humidity; // 假设 JSON 数据中有 humidity 字段
const light = data.light; // 假设 JSON 数据中有 light 字段
document.getElementById('temperature').textContent = temperature + '°C'; //更新temperature
document.getElementById('humidity').textContent = humidity + '%'; //更新humidity
document.getElementById('light').textContent = light + ' lux'; //更新light
} catch (error) {
console.error('解析 MQTT 消息时出错：', error);
}
}

复制代码

在监听函数中，一旦收到消息了，会将信息打印出来，然后会执行update_Status函数来更新web上的内容。这边接收到的信息的json格式的，所以要对json格式的数据举行解析。举例如下，原始界面如下：

使用MQTT.fx软件毗连上broker-cn.emqx.io后，往iot/my_sub主题发布一个json格式的信息，信息如下：

{"temperature":"23","humidity":"60","light":"500"}

复制代码

发送后，就可以看到web界面的数值发送了变化，变成如下：

同时在控制台也输出了对应的信息，如图所示：

3.发送信息

web除了有监听信息，接收信息的能力外，还应当具备发送消息的能力，通过按键点击后，就会执行对应的函数，在函数内向发布主题发送一些消息，代码实现如下：

// 发布 MQTT 消息
function sendCommand(command) {
mqttClient.publish(publish_Topic, command);
console.log('已发送 MQTT 消息：', command);
}

复制代码

实际结果可以在MQTT.fx中订阅iot/my_pub主题，来查看web发出的信息，当打开装备按键被按下后，就会向iot/my_pub主题发送turnOn的文本信息，如图所示：

同时在web的控制台也能看到对应的日志。

三、团体代码

团体代码中也是只做了简单的实现，没有对界面举行美化，仅供参考。团体的代码实现如下：

<!DOCTYPE html><html lang="en"><head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <title>物联网Web界面</title></head><body> <h1>物联网Web界面示例</h1>
<h2>示例参数</h2>
<p>温度：<span id="temperature">25°C</span></p>
<p>湿度：<span id="humidity">50%</span></p>
<p>光照强度：<span id="light">800 lux</span></p>
<h2>示例按钮</h2>
<button onclick="toggleLight()">控制灯光</button>
<button onclick="sendCommand('turnOn')">打开设备</button>
<button onclick="sendCommand('turnOff')">关闭设备</button>
<script src="https://cdnjs.cloudflare.com/ajax/libs/mqtt/4.2.8/mqtt.min.js"></script>
<script> // MQTT 毗连配置 const mqttBroker = 'ws://broker-cn.emqx.io:8083/mqtt'; const publish_Topic = 'iot/my_pub'; const subscribe_Topic = 'iot/my_sub'; // 创建 MQTT 客户端实例 const mqttClient = mqtt.connect(mqttBroker); // 毗连变乱处理 mqttClient.on('connect', function () { console.log('毗连乐成'); // 订阅主题 mqttClient.subscribe(subscribe_Topic); }); // 监听消息 mqttClient.on('message', function (topic, message) { console.log("收到信息：" + message) update_Status(message.toString()); }); //更新消息 function update_Status(msg) { try { const data = JSON.parse(msg); // 实验解析收到的 JSON 格式消息 const temperature = data.temperature; // 假设 JSON 数据中有 temperature 字段 const humidity = data.humidity; // 假设 JSON 数据中有 humidity 字段 const light = data.light; // 假设 JSON 数据中有 light 字段 document.getElementById('temperature').textContent = temperature + '°C'; //更新temperature document.getElementById('humidity').textContent = humidity + '%'; //更新humidity document.getElementById('light').textContent = light + ' lux'; //更新light } catch (error) { console.error('解析 MQTT 消息时出错：', error); } } // 发布 MQTT 消息 function sendCommand(command) { mqttClient.publish(publish_Topic, command); console.log('已发送 MQTT 消息：', command); } // 模拟函数，用于切换灯光状态 function toggleLight() { const lightElement = document.getElementById('light'); if (lightElement.textContent === '800 lux') { lightElement.textContent = '0 lux'; } else { lightElement.textContent = '800 lux'; } } </script></body></html>

复制代码

至此，教程结束，祝编程舒畅！73

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

		自动登录	找回密码
密码			立即注册

web网页毗连MQTT，显示数据与下发控制命令

本帖子中包含更多资源

0 个回复

快速回复

楼主热帖

标签云