mqtt.js使用示例

好的，下面是一个使用mqtt.js的简单示例：

首先，安装mqtt.js:

npm install mqtt --save

然后，编写代码：

const mqtt = require('mqtt')
const client  = mqtt.connect('mqtt://test.mosquitto.org')

client.on('connect', function () {
  console.log('connected')
  client.subscribe('presence', function (err) {
    if (!err) {
      client.publish('presence', 'Hello mqtt')
    }
  })
})

client.on('message', function (topic, message) {
  // message is Buffer
  console.log(message.toString())
  client.end()
})

这个例子连接到mqtt://test.mosquitto.org，并订阅了名为“presence”的主题。一旦连接成功，就会发布一条消息到该主题，然后等待回调函数。如果订阅成功，就会收到该主题的任何消息，并打印出来。

注意：这只是一个简单的示例，实际使用时需要根据实际情况进行修改。

相关问题

uniapp mqtt.js 使用demo

uniapp 是一个跨平台开发框架，可以使用 mqtt.js 库来连接和操作 MQTT 服务器。下面是一个简单的 Uniapp 中使用 mqtt.js 的示例：

1. 在 uniapp 项目中安装 mqtt.js：

npm install mqtt --save

2. 在需要使用 mqtt.js 的页面中引入 mqtt.js：

import mqtt from 'mqtt'

3. 在页面中使用 mqtt.js 进行连接和操作 MQTT 服务器：

// 创建 MQTT 客户端
const client = mqtt.connect('mqtt://mqtt.example.com', {
  clientId: 'your-client-id',
  username: 'your-username',
  password: 'your-password'
})

// 连接成功回调函数
client.on('connect', function () {
  console.log('Connected to MQTT server')
  
  // 订阅主题
  client.subscribe('your-topic', function (err) {
    if (err) {
      console.log('Failed to subscribe to topic:', err)
    }
  })
})

// 收到消息回调函数
client.on('message', function (topic, message) {
  console.log('Received message:', message.toString())
})

// 发布消息
client.publish('your-topic', 'Hello, MQTT!')

// 关闭 MQTT 连接
client.end()

这是一个简单的 uniapp 中使用 mqtt.js 的示例，你可以根据自己的需求进行进一步的定制和扩展。

node mqtt.js

以下是一个使用MQTT.js库在Node.js中实现MQTT订阅功能的示例代码：

const mqtt = require("mqtt");

const client = mqtt.connect("mqtt://127.0.0.1:1883");

client.on("connect", function() {
  console.log("服务器连接成功");
  client.subscribe("temperature", { qos: 1 });
});

client.on("message", function(topic, message) {
  console.log("当前topic：", topic);
  console.log("当前温度：", message.toString());
});

这段代码首先使用`require`语句引入了MQTT.js库。然后，通过`mqtt.connect`方法连接到MQTT服务器。在连接成功后，使用`client.subscribe`方法订阅了名为"temperature"的主题，并指定了QoS等级为1。最后，通过`client.on`方法监听"message"事件，当接收到消息时，会打印出当前主题和消息内容。

请注意，你需要将代码中的MQTT服务器地址和端口修改为你实际使用的地址和端口。