JavaScript物联网_MQTT协议通信实现-js教程-PHP中文网

JavaScript物联网_MQTT协议通信实现

幻影之瞳

发布： 2025-11-24 22:35:02

原创

861人浏览过

MQTT协议是物联网设备通信的轻量高效方案，基于发布/订阅模式，支持低带宽、不稳定网络环境。其特点包括解耦的消息模型、三种QoS等级、遗嘱消息机制及小头部开销。在JavaScript中，通过MQTT.js库可实现Node.js或浏览器端与Broker的连接，使用mqtt.connect()建立连接，subscribe()订阅主题，publish()发布消息。浏览器中需通过WebSocket连接Broker（如端口9001），并处理跨域问题。实际应用中需配置心跳、重连策略及合理QoS等级以保障通信稳定。

javascript物联网_mqtt协议通信实现

在JavaScript中实现物联网设备间的通信，MQTT协议是一个轻量、高效的选择，特别适合低带宽、不稳定网络环境下的设备互联。它基于发布/订阅模式，能够实现一对多的消息分发，广泛应用于智能家居、远程监控等场景。

MQTT协议简介

MQTT（Message Queuing Telemetry Transport）是一种基于TCP/IP的轻量级消息传输协议，由IBM开发，专为受限设备和低带宽网络设计。其核心特点包括：

使用发布/订阅模型，解耦消息发送者与接收者
支持三种服务质量等级（QoS 0, 1, 2），适应不同可靠性需求
提供“遗嘱消息”机制，可感知设备离线状态
头部开销小，最小报文仅2字节

JavaScript中使用MQTT.js连接Broker

在Node.js或浏览器环境中，MQTT.js 是最常用的客户端库。通过npm安装后即可创建客户端实例连接到MQTT代理（Broker）。

安装命令：

立即学习“Java免费学习笔记（深入）”；

npm install mqtt

登录后复制

连接示例代码：

const mqtt = require('mqtt');
<p>// 连接本地Mosquitto Broker
const client = mqtt.connect('mqtt://localhost:1883');</p><p>client.on('connect', () => {
console.log('已连接到MQTT Broker');
});</p><p>client.on('error', (err) => {
console.error('连接失败:', err);
});

登录后复制

发布与订阅消息

设备间通信依赖于主题（Topic）进行消息路由。一个设备可以订阅特定主题来接收消息，也可以向某个主题发布数据。

无涯·问知

无涯·问知，是一款基于星环大模型底座，结合个人知识库、企业知识库、法律法规、财经等多种知识源的企业级垂直领域问答产品

142

查看详情

订阅主题：

client.subscribe('sensor/temperature', (err) => {
  if (!err) {
    console.log('已订阅温度传感器数据');
  }
});
<p>client.on('message', (topic, payload) => {
console.log(<code>收到消息来自 ${topic}: ${payload.toString()}</code>);
});

登录后复制

发布消息：

setInterval(() => {
  const temp = Math.random() * 30; // 模拟温度值
  client.publish('sensor/temperature', temp.toFixed(2), {
    qos: 1,
    retain: false
  });
}, 5000);

登录后复制

在Web前端中使用MQTT over WebSocket

若需在浏览器中接入MQTT服务，Broker必须支持WebSocket连接。例如Mosquitto可通过配置启用端口9001的WebSocket监听。

前端连接方式：

const client = mqtt.connect('ws://your-mqtt-broker:9001');
<p>client.on('connect', () => {
client.subscribe('device/status');
});</p><p>client.on('message', (topic, payload) => {
document.getElementById('status').innerText = payload.toString();
});

登录后复制

注意确保服务器配置正确，并处理跨域问题。

基本上就这些。只要搭建好MQTT Broker（如Mosquitto、EMQX），前后端都能通过简洁的API实现稳定通信。不复杂但容易忽略的是QoS设置和连接保活机制，实际部署时建议开启心跳和重连策略。

以上就是JavaScript物联网_MQTT协议通信实现的详细内容，更多请关注php中文网其它相关文章！