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