使用MQTT.JS创建一个网页版的MQTT客户端

// 首先，确保已经通过npm安装了mqtt模块
// npm install mqtt --save
 
// 引入mqtt模块
const mqtt = require('mqtt');
 
// 创建MQTT客户端实例
const client = mqtt.connect('mqtt://broker.hivemq.com'); // 使用HiveMQ的公共MQTT代理
 
// 当客户端连接时，订阅一个主题
client.on('connect', function() {
  console.log('连接到MQTT代理成功！');
  client.subscribe('your/topic'); // 替换为你想订阅的主题
});
 
// 处理接收到的消息
client.on('message', function(topic, message) {
  // 转换消息为JSON，并在控制台输出
  try {
    const msg = JSON.parse(message.toString());
    console.log(`收到来自${topic}的消息:`, msg);
  } catch (e) {
    console.log(`收到来自${topic}的消息: ${message.toString()}`);
  }
});
 
// 发送消息到指定主题
function publishMessage(topic, message) {
  client.publish(topic, JSON.stringify(message));
}
 
// 使用函数发送一条测试消息
publishMessage('your/topic', { 'message': 'Hello MQTT!' }); // 替换为你想发送的主题和消息
 
// 确保在页面关闭或者脚本退出时，断开MQTT连接
process.on('SIGINT', function() {
  client.end(function() {
    console.log('MQTT客户端已经断开连接');
    process.exit();
  });
});

这段代码展示了如何在Node.js环境中使用mqtt.js库创建一个简单的MQTT客户端。它连接到一个MQTT代理（这里使用的是HiveMQ的公共代理），订阅了一个主题，并且可以接收和发送消息。同时，它还包含了一个简单的错误处理，在接收到消息时尝试将其解析为JSON，并在发送消息时将对象转换为字符串。最后，它还演示了如何优雅地断开连接。这个例子可以作为开发一个Web版MQTT客户端的起点。