Node.js MQTT 初探

发布时间：2023-05-16

一、MQTT 简介

MQTT (Message Queuing Telemetry Transport，消息队列遥测传输协议) 是一种轻量级的物联网（IoT）通信协议。它使用 TCP/IP 协议栈构建，能够在不可靠的网络中实现可靠的消息传递。

二、Node.js MQTT 初探

Node.js MQTT 是一个轻量级的 MQTT 客户端库，使用 JavaScript 编写并可以在 Node.js 中运行。它具有高性能、可靠性、可扩展性等特点，可用于处理传感器的数据、物联网设备的状态变化等场景。 下面是一个简单的 Node.js MQTT 客户端代码示例：

const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
  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()
})

三、使用 Node.js MQTT 进行数据通信

下面是一个使用 Node.js MQTT 进行数据通信的场景示例： 场景： 在一个智能家居场景中，使用 Node.js MQTT 客户端与一个温度传感器进行通信。 步骤：

  1. 配置并启动 MQTT 代理服务器。
  2. 编写 Node.js MQTT 客户端代码，与温度传感器进行通信。
// MQTT 代理服务器地址
const MQTT_SERVER = 'mqtt://test.mosquitto.org'
// 温度传感器主题
const SENSOR_TOPIC = 'sensor/temperature'
// 创建 MQTT 客户端
const client = mqtt.connect(MQTT_SERVER)
// 监听连接事件
client.on('connect', () => {
  console.log(`Connected to MQTT server: ${MQTT_SERVER}`)
  // 订阅温度传感器主题
  client.subscribe(SENSOR_TOPIC, (err) => {
    if (err) {
      console.error(`Failed to subscribe to ${SENSOR_TOPIC}: ${err}`)
    } else {
      console.log(`Subscribed to ${SENSOR_TOPIC}`)
    }
  })
})
// 监听消息事件
client.on('message', (topic, message) => {
  if (topic === SENSOR_TOPIC) {
    const temperature = parseFloat(message.toString())
    console.log(`Temperature: ${temperature}`)
  }
})
  1. 部署温度传感器，并向 MQTT 代理服务器发布温度数据。
const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
  setInterval(() => {
    const temperature = Math.floor(Math.random() * 100) / 10
    client.publish('sensor/temperature', temperature.toString())
  }, 1000)
})

在步骤 3 中，我们使用 setInterval() 函数模拟温度传感器定时向 MQTT 代理服务器发布数据，数据的发布通过 client.publish() 方法实现。

四、使用 Node.js MQTT 进行状态订阅

下面是一个使用 Node.js MQTT 进行状态订阅的场景示例： 场景： 在一个智能家居场景中，使用 Node.js MQTT 客户端进行智能插座状态的订阅与控制。 步骤：

  1. 配置并启动 MQTT 代理服务器。
  2. 编写 Node.js MQTT 客户端代码，进行智能插座状态的订阅。
// MQTT 代理服务器地址
const MQTT_SERVER = 'mqtt://test.mosquitto.org'
// 智能插座状态主题
const SOCKET_STATE_TOPIC = 'socket/state'
// 创建 MQTT 客户端
const client = mqtt.connect(MQTT_SERVER)
// 监听连接事件
client.on('connect', () => {
  console.log(`Connected to MQTT server: ${MQTT_SERVER}`)
  // 订阅智能插座状态主题
  client.subscribe(SOCKET_STATE_TOPIC, (err) => {
    if (err) {
      console.error(`Failed to subscribe to ${SOCKET_STATE_TOPIC}: ${err}`)
    } else {
      console.log(`Subscribed to ${SOCKET_STATE_TOPIC}`)
    }
  })
})
// 监听消息事件
client.on('message', (topic, message) => {
  if (topic === SOCKET_STATE_TOPIC) {
    const state = message.toString()
    console.log(`Socket state: ${state}`)
  }
})
  1. 向 MQTT 代理服务器发布智能插座状态更新。
const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
  setInterval(() => {
    const state = Math.round(Math.random())
    client.publish('socket/state', state.toString())
  }, 1000)
})

在步骤 3 中，我们使用 setInterval() 函数模拟智能插座定时更新状态，更新状态通过 client.publish() 方法实现。

五、Node.js MQTT 应用案例

Node.js MQTT 可以应用于许多 IoT 场景中，比如智能家居、智能农业、智能城市等。下面是一个基于 Node.js MQTT 的智慧园区应用案例： 场景： 在一个园区中，使用 Node.js MQTT 客户端进行智能路灯的状态订阅与控制。 步骤：

  1. 配置并启动 MQTT 代理服务器。
  2. 编写 Node.js MQTT 客户端代码，进行智能路灯状态的订阅。
// MQTT 代理服务器地址
const MQTT_SERVER = 'mqtt://test.mosquitto.org'
// 智能路灯状态主题
const LAMP_STATE_TOPIC = 'lamp/state'
// 创建 MQTT 客户端
const client = mqtt.connect(MQTT_SERVER)
// 监听连接事件
client.on('connect', () => {
  console.log(`Connected to MQTT server: ${MQTT_SERVER}`)
  // 订阅智能路灯状态主题
  client.subscribe(LAMP_STATE_TOPIC, (err) => {
    if (err) {
      console.error(`Failed to subscribe to ${LAMP_STATE_TOPIC}: ${err}`)
    } else {
      console.log(`Subscribed to ${LAMP_STATE_TOPIC}`)
    }
  })
})
// 监听消息事件
client.on('message', (topic, message) => {
  if (topic === LAMP_STATE_TOPIC) {
    const state = message.toString()
    console.log(`Lamp state: ${state}`)
  }
})
  1. 架设智能路灯节点，向 MQTT 代理服务器发布智能路灯状态更新。
const mqtt = require('mqtt')
const client = mqtt.connect('mqtt://test.mosquitto.org')
client.on('connect', function () {
  setInterval(() => {
    const state = Math.round(Math.random())
    client.publish('lamp/state', state.toString())
  }, 1000)
})

在步骤 3 中，我们使用 setInterval() 函数模拟智能路灯定时更新状态，更新状态通过 client.publish() 方法实现。

六、总结

本文介绍了 Node.js MQTT 的基本概念及应用场景，并提供了相关代码示例。Node.js MQTT 具有轻量级、高性能、可靠性、可扩展性等特点，可用于处理传感器的数据、物联网设备的状态变化等场景。在实际应用中，我们可以通过 Node.js MQTT 来实现数据通信和状态订阅等功能，从而构建出更加智能和高效的 IoT 系统。

推荐文章