使用MQTT.js可在JavaScript中实现物联网通信,支持Node.js与浏览器环境;通过npm install mqtt或CDN引入后,使用mqtt.connect()连接Broker;成功后调用subscribe()订阅主题,监听message事件接收数据;通过publish()发布消息,可设置QoS与retain;建议启用TLS加密、处理重连与心跳,确保连接稳定。

在JavaScript中实现物联网MQTT协议客户端,主要依赖于Paho-MQTT或MQTT.js这类成熟的库。这些库支持浏览器和Node.js环境,能轻松连接MQTT代理(broker),实现设备间的消息通信。
选择合适的MQTT客户端库
MQTT.js是目前最流行的JavaScript MQTT客户端,兼容Node.js与浏览器环境,功能完整且社区活跃。
安装方式(Node.js):
npm install mqtt
在浏览器中可通过CDN引入:
立即学习“Java免费学习笔记(深入)”;
连接MQTT Broker
使用MQTT.js连接公共或私有Broker,例如Eclipse Mosquitto、EMQX或HiveMQ提供的测试服务。
示例代码:
const client = mqtt.connect('mqtt://broker.hivemq.com:1883');
client.on('connect', () => {
console.log('已连接到MQTT Broker');
});
client.on('error', (err) => {
console.error('连接失败:', err);
});
若使用TLS加密,将协议改为mqtts://并配置证书选项。
订阅主题与接收消息
连接成功后可订阅一个或多个主题,监听数据变化。
示例:
client.subscribe('sensor/temperature', (err) => {
if (!err) {
console.log('已订阅 temperature 主题');
}
});
client.on('message', (topic, payload) => {
console.log(`收到消息:${topic} => ${payload.toString()}`);
});
常用于接收传感器数据、远程控制指令等场景。
发布消息到主题
向指定主题发送数据,实现设备上报或状态更新。
示例:
client.publish('sensor/humidity', '65%', { qos: 1 }, (err) => {
if (err) {
console.error('发布失败:', err);
} else {
console.log('湿度数据已发布');
}
});
可根据需要设置QoS等级(0、1、2)和保留标志(retain)。
基本上就这些。通过MQTT.js,JavaScript可以轻松接入物联网系统,无论是前端可视化监控,还是Node.js做边缘网关,都很实用。注意保持连接心跳、处理重连逻辑,确保通信稳定。










