在 Raspberry Pi 上使用 Node.js 开发物联网应用程序

引言

大家好，欢迎来到今天的讲座！今天我们要聊的是如何在 Raspberry Pi 上使用 Node.js 开发物联网（IoT）应用程序。如果你对 IoT 有一点了解，你就会知道它是一个非常有趣且充满潜力的领域。从智能家居到工业自动化，IoT 应用无处不在。而 Raspberry Pi 作为一款小巧、低成本的单板计算机，无疑是开发 IoT 应用的理想平台之一。

为什么选择 Node.js？首先，Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行时，它允许你在服务器端编写 JavaScript 代码。Node.js 的非阻塞 I/O 模型使得它非常适合处理高并发的网络请求，这对于 IoT 应用来说非常重要。其次，Node.js 拥有丰富的生态系统和大量的第三方库，可以大大简化开发过程。最后，JavaScript 是一种非常流行的编程语言，学习成本低，社区活跃，资源丰富。

在接下来的时间里，我们将一步步探讨如何在 Raspberry Pi 上搭建 Node.js 环境，连接各种传感器和执行器，并通过 MQTT 协议实现设备之间的通信。我们还会介绍一些常见的 IoT 平台和服务，帮助你更好地管理和扩展你的 IoT 应用。准备好了吗？让我们开始吧！

1. 准备工作

1.1 硬件准备

在开始之前，我们需要准备一些硬件设备。以下是你可能需要的东西：

Raspberry Pi：推荐使用 Raspberry Pi 4 或更新版本，因为它有更好的性能和更多的内存。
电源适配器：确保你的电源适配器能够提供足够的电流，特别是当你连接多个外设时。
MicroSD 卡：用于安装操作系统。建议使用至少 16GB 的高速卡。
USB 键盘和鼠标：用于初始设置。如果你打算通过 SSH 远程操作，可以省略这一步。
HDMI 显示器：同样用于初始设置。如果你打算通过 SSH 远程操作，也可以省略。
网络连接：Wi-Fi 或以太网连接，用于更新系统和安装软件包。
传感器和执行器：例如温湿度传感器、LED 灯、继电器模块等。这些设备将帮助你构建实际的 IoT 应用。

1.2 软件准备

1.2.1 安装操作系统

Raspberry Pi 支持多种操作系统，但最常用的还是 Raspbian（现更名为 Raspberry Pi OS）。你可以从官方网站下载最新的镜像文件，并使用 Etcher 或 Balena Etcher 将其写入 MicroSD 卡。插入 MicroSD 卡后，启动 Raspberry Pi 并按照提示完成初始设置。

1.2.2 更新系统

为了让我们的系统保持最新，建议在首次启动后立即更新软件包。打开终端并输入以下命令：

sudo apt update
sudo apt upgrade -y

这可能会花费一些时间，具体取决于你的网络速度和可用的更新数量。耐心等待，完成后重启系统：

sudo reboot

1.2.3 安装 Node.js

接下来，我们需要在 Raspberry Pi 上安装 Node.js。Raspberry Pi OS 默认不包含 Node.js，因此我们需要手动安装。我们可以使用 NodeSource 提供的安装脚本来简化这个过程。以下是安装步骤：

打开终端，运行以下命令来安装 Node.js 16.x 版本：

curl -fsSL https://deb.nodesource.com/setup_16.x | sudo -E bash -

安装 Node.js 和 npm（Node.js 包管理器）：
```
sudo apt install -y nodejs
```
验证安装是否成功：
```
node -v
npm -v
```
你应该会看到类似如下的输出：
```
v16.13.0
7.24.0
```

1.2.4 安装其他依赖

为了方便开发，我们还需要安装一些常用的工具和库。以下是推荐的安装列表：

Git：用于版本控制和获取开源项目。
Nodemon：用于自动重启 Node.js 应用程序，方便调试。
Mosquitto：一个轻量级的 MQTT 消息代理，用于设备之间的通信。

安装这些工具的命令如下：

sudo apt install -y git
npm install -g nodemon
sudo apt install -y mosquitto mosquitto-clients

1.3 配置网络

如果你打算通过 SSH 远程操作 Raspberry Pi，或者希望它能够与外部设备通信，那么配置网络是非常重要的。你可以通过 Wi-Fi 或以太网连接到互联网。对于 Wi-Fi，你可以使用 raspi-config 工具来配置无线网络：

sudo raspi-config

选择 Network Options -> Wi-Fi，然后按照提示输入你的 SSID 和密码。配置完成后，重启系统以使更改生效。

如果你更喜欢使用静态 IP 地址，可以通过编辑 /etc/dhcpcd.conf 文件来配置。例如，假设你想为 Raspberry Pi 分配 IP 地址 192.168.1.100，可以在文件末尾添加以下内容：

interface wlan0
static ip_address=192.168.1.100/24
static routers=192.168.1.1
static domain_name_servers=8.8.8.8 8.8.4.4

保存并退出后，重启网络服务：

sudo systemctl restart dhcpcd

2. 传感器和执行器的连接

2.1 GPIO 引脚介绍

Raspberry Pi 的 GPIO（General Purpose Input/Output）引脚是连接外部设备的主要接口。通过这些引脚，你可以读取传感器的数据或将信号发送给执行器。Raspberry Pi 4 具有 40 个 GPIO 引脚，其中一些是电源引脚，一些是接地引脚，还有一些是可编程的数字或模拟引脚。

为了方便理解，这里有一个简单的 GPIO 引脚布局表：

引脚编号	功能	引脚编号	功能
1	3.3V	2	5V
3	GPIO 2 (SDA)	4	5V
5	GPIO 3 (SCL)	6	GND
7	GPIO 4	8	GPIO 14 (TXD)
9	GND	10	GPIO 15 (RXD)
11	GPIO 17	12	GPIO 18
13	GPIO 27	14	GND
15	GPIO 22	16	GPIO 23
17	3.3V	18	GPIO 24
19	GPIO 10 (MOSI)	20	GND
21	GPIO 9 (MISO)	22	GPIO 25
23	GPIO 11 (SCLK)	24	GPIO 8 (CE0)
25	GND	26	GPIO 7 (CE1)
27	ID_SD	28	ID_SC
29	GPIO 5	30	GND
31	GPIO 6	32	GPIO 12
33	GPIO 13	34	GND
35	GPIO 19	36	GPIO 16
37	GPIO 26	38	GPIO 20
39	GND	40	GPIO 21

2.2 读取温湿度传感器数据

温湿度传感器是 IoT 应用中非常常见的设备之一。今天我们使用 DHT11 传感器作为示例。DHT11 是一种廉价且易于使用的传感器，它可以测量环境中的温度和湿度。它只需要一条数据线连接到 Raspberry Pi 的 GPIO 引脚。

2.2.1 硬件连接

DHT11 传感器通常有三个引脚：VCC、GND 和 DATA。将它们分别连接到 Raspberry Pi 的 5V、GND 和 GPIO 4 引脚。连接完成后，你可以使用万用表检查是否有短路或其他问题。

2.2.2 安装驱动库

为了在 Node.js 中读取 DHT11 传感器的数据，我们需要安装一个驱动库。这里我们使用 node-dht-sensor，它是一个非常流行且易于使用的库。安装方法如下：

npm install node-dht-sensor

2.2.3 编写代码

接下来，我们编写一个简单的 Node.js 程序来读取温湿度数据。创建一个名为 dht11.js 的文件，并在其中添加以下代码：

const dhtSensor = require('node-dht-sensor');

// 初始化 DHT11 传感器，连接到 GPIO 4 引脚
const sensorType = 11; // DHT11
const pin = 4;

function readSensorData() {
  dhtSensor.read(sensorType, pin, (err, temperature, humidity) => {
    if (err) {
      console.error('Error reading sensor data:', err);
      return;
    }
    console.log(`Temperature: ${temperature.toFixed(1)}°C`);
    console.log(`Humidity: ${humidity.toFixed(1)}%`);
  });
}

// 每隔 2 秒读取一次数据
setInterval(readSensorData, 2000);

// 立即读取一次数据
readSensorData();

保存文件后，在终端中运行以下命令来启动程序：

node dht11.js

你应该会看到类似如下的输出：

Temperature: 22.0°C
Humidity: 45.0%
Temperature: 22.0°C
Humidity: 45.0%
...

2.3 控制 LED 灯

除了读取传感器数据，我们还可以通过 GPIO 引脚控制执行器。今天我们使用一个简单的 LED 灯作为示例。LED 灯是一种非常常见的执行器，它可以用来指示系统的状态或与其他设备进行交互。

2.3.1 硬件连接

将 LED 灯的正极（长脚）连接到 Raspberry Pi 的 GPIO 17 引脚，负极（短脚）通过一个限流电阻连接到 GND 引脚。限流电阻的阻值可以根据 LED 的规格选择，通常为 220Ω 或 330Ω。

2.3.2 安装驱动库

为了在 Node.js 中控制 GPIO 引脚，我们需要安装一个 GPIO 库。这里我们使用 onoff，它是一个功能强大的 GPIO 控制库。安装方法如下：

npm install onoff

2.3.3 编写代码

接下来，我们编写一个简单的 Node.js 程序来控制 LED 灯的亮灭。创建一个名为 led.js 的文件，并在其中添加以下代码：

const { Gpio } = require('onoff');
const led = new Gpio(17, 'out');

function toggleLed() {
  const state = led.readSync() === 0 ? 1 : 0;
  led.writeSync(state);
  console.log(`LED is ${state === 1 ? 'ON' : 'OFF'}`);
}

// 每隔 1 秒切换一次 LED 状态
setInterval(toggleLed, 1000);

// 立即切换一次 LED 状态
toggleLed();

保存文件后，在终端中运行以下命令来启动程序：

node led.js

你应该会看到 LED 灯每隔 1 秒闪烁一次，并且终端中会输出类似如下的信息：

LED is ON
LED is OFF
LED is ON
LED is OFF
...

3. 设备间通信

在 IoT 应用中，设备之间的通信是非常重要的。我们可以使用多种协议来实现设备间的通信，例如 HTTP、WebSocket、MQTT 等。今天我们将介绍如何使用 MQTT 协议来实现设备之间的消息传递。

3.1 什么是 MQTT？

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，专为低带宽、高延迟或不可靠的网络环境设计。它采用发布/订阅模型，允许设备通过消息代理（Broker）进行通信。MQTT 的主要优点包括：

轻量级：协议头非常小，适合资源受限的设备。
低带宽：只需少量的网络流量即可传输大量数据。
高可靠性：支持 QoS（服务质量）级别，确保消息的可靠传递。
简单易用：API 简单，易于集成到各种应用程序中。

3.2 安装 Mosquitto 消息代理

Mosquitto 是一个轻量级的 MQTT 消息代理，适用于 Raspberry Pi。我们已经在前面的步骤中安装了 Mosquitto，现在我们需要启动它并确保它正在运行。使用以下命令启动 Mosquitto：

sudo systemctl start mosquitto

你可以通过以下命令检查 Mosquitto 是否正在运行：

sudo systemctl status mosquitto

如果一切正常，你应该会看到类似如下的输出：

● mosquitto.service - Lightweight MQTT Broker
   Loaded: loaded (/lib/systemd/system/mosquitto.service; enabled; vendor preset: enabled)
   Active: active (running) since ...

如果你想让 Mosquitto 在系统启动时自动启动，可以使用以下命令：

sudo systemctl enable mosquitto

3.3 发布和订阅消息

为了测试 MQTT 的功能，我们可以使用 mosquitto_pub 和 mosquitto_sub 命令行工具来发布和订阅消息。打开两个终端窗口，分别执行以下命令：

3.3.1 订阅消息

在第一个终端窗口中，运行以下命令来订阅名为 test/topic 的主题：

mosquitto_sub -h localhost -t test/topic

3.3.2 发布消息

在第二个终端窗口中，运行以下命令来发布一条消息到 test/topic 主题：

mosquitto_pub -h localhost -t test/topic -m "Hello, MQTT!"

你应该会在第一个终端窗口中看到类似如下的输出：

Hello, MQTT!

这表明你已经成功地通过 MQTT 发布和订阅了消息。

3.4 使用 Node.js 实现 MQTT 通信

接下来，我们将使用 Node.js 来实现 MQTT 通信。首先，我们需要安装 mqtt 库，这是一个非常流行的 MQTT 客户端库。安装方法如下：

npm install mqtt

3.4.1 发布消息

创建一个名为 mqtt_publisher.js 的文件，并在其中添加以下代码：

const mqtt = require('mqtt');
const client = mqtt.connect('mqtt://localhost');

client.on('connect', () => {
  console.log('Connected to MQTT broker');
  const message = 'Hello, MQTT!';
  client.publish('test/topic', message, (err) => {
    if (err) {
      console.error('Error publishing message:', err);
    } else {
      console.log(`Published message: ${message}`);
    }
    client.end();
  });
});

client.on('error', (err) => {
  console.error('MQTT error:', err);
});

保存文件后，在终端中运行以下命令来启动程序：

node mqtt_publisher.js

你应该会看到类似如下的输出：

Connected to MQTT broker
Published message: Hello, MQTT!

3.4.2 订阅消息

创建一个名为 mqtt_subscriber.js 的文件，并在其中添加以下代码：

const mqtt = require('mqtt');
const client = mqtt.connect('mqtt://localhost');

client.on('connect', () => {
  console.log('Connected to MQTT broker');
  client.subscribe('test/topic', (err) => {
    if (err) {
      console.error('Error subscribing to topic:', err);
    } else {
      console.log('Subscribed to topic: test/topic');
    }
  });
});

client.on('message', (topic, message) => {
  console.log(`Received message on topic ${topic}: ${message.toString()}`);
});

client.on('error', (err) => {
  console.error('MQTT error:', err);
});

保存文件后，在终端中运行以下命令来启动程序：

node mqtt_subscriber.js

你应该会看到类似如下的输出：

Connected to MQTT broker
Subscribed to topic: test/topic

此时，如果你再次运行 mqtt_publisher.js，你应该会在 mqtt_subscriber.js 的终端窗口中看到接收到的消息。

4. 构建一个完整的 IoT 应用

现在我们已经掌握了如何在 Raspberry Pi 上使用 Node.js 读取传感器数据、控制执行器以及实现设备间的通信。接下来，我们将把这些知识结合起来，构建一个完整的 IoT 应用程序。这个应用程序将读取温湿度传感器的数据，并根据温度的变化自动控制 LED 灯的亮灭。此外，它还将通过 MQTT 将温度和湿度数据发布到云端，以便其他设备或应用程序可以访问这些数据。

4.1 项目结构

为了保持代码的整洁和可维护性，我们建议将项目划分为多个文件。以下是推荐的项目结构：

iot-app/
├── package.json
├── index.js
├── dht11.js
├── led.js
└── mqtt.js

4.2 创建 `package.json`

首先，我们需要创建一个 package.json 文件来管理项目的依赖项。在项目根目录下运行以下命令：

npm init -y

这将生成一个默认的 package.json 文件。接下来，我们需要安装所需的依赖项：

npm install node-dht-sensor onoff mqtt

4.3 编写 `dht11.js`

在 dht11.js 文件中，我们定义一个函数来读取温湿度传感器的数据。这个函数将返回一个 Promise，以便我们可以异步处理数据。

const dhtSensor = require('node-dht-sensor');

const sensorType = 11; // DHT11
const pin = 4;

async function readDHT11() {
  return new Promise((resolve, reject) => {
    dhtSensor.read(sensorType, pin, (err, temperature, humidity) => {
      if (err) {
        reject(err);
      } else {
        resolve({ temperature, humidity });
      }
    });
  });
}

module.exports = { readDHT11 };

4.4 编写 `led.js`

在 led.js 文件中，我们定义一个类来控制 LED 灯的状态。这个类提供了 turnOn 和 turnOff 两个方法，用于打开和关闭 LED 灯。

const { Gpio } = require('onoff');
const led = new Gpio(17, 'out');

class LED {
  turnOn() {
    led.writeSync(1);
    console.log('LED is ON');
  }

  turnOff() {
    led.writeSync(0);
    console.log('LED is OFF');
  }
}

module.exports = LED;

4.5 编写 `mqtt.js`

在 mqtt.js 文件中，我们定义一个类来处理 MQTT 通信。这个类提供了 publish 方法，用于将数据发布到指定的主题。

const mqtt = require('mqtt');
const client = mqtt.connect('mqtt://localhost');

class MQTTClient {
  constructor(topic) {
    this.topic = topic;
    client.on('connect', () => {
      console.log('Connected to MQTT broker');
    });
  }

  publish(data) {
    client.publish(this.topic, JSON.stringify(data), (err) => {
      if (err) {
        console.error('Error publishing message:', err);
      } else {
        console.log(`Published message to topic ${this.topic}:`, data);
      }
    });
  }
}

module.exports = MQTTClient;

4.6 编写 `index.js`

在 index.js 文件中，我们将所有的模块组合在一起，创建一个完整的 IoT 应用程序。这个应用程序将每隔 2 秒读取一次温湿度数据，并根据温度的变化控制 LED 灯的亮灭。同时，它还将通过 MQTT 将温度和湿度数据发布到云端。

const { readDHT11 } = require('./dht11');
const LED = require('./led');
const MQTTClient = require('./mqtt');

const led = new LED();
const mqttClient = new MQTTClient('home/sensors/dht11');

async function main() {
  try {
    const { temperature, humidity } = await readDHT11();
    console.log(`Temperature: ${temperature.toFixed(1)}°C`);
    console.log(`Humidity: ${humidity.toFixed(1)}%`);

    // 根据温度控制 LED 灯
    if (temperature > 25) {
      led.turnOn();
    } else {
      led.turnOff();
    }

    // 通过 MQTT 发布数据
    mqttClient.publish({ temperature, humidity });
  } catch (err) {
    console.error('Error reading sensor data:', err);
  }
}

// 每隔 2 秒执行一次主函数
setInterval(main, 2000);

// 立即执行一次主函数
main();

4.7 运行应用程序

保存所有文件后，在终端中运行以下命令来启动应用程序：

node index.js

你应该会看到类似如下的输出：

Connected to MQTT broker
Temperature: 22.0°C
Humidity: 45.0%
LED is OFF
Published message to topic home/sensors/dht11: {"temperature":22,"humidity":45}
Temperature: 22.0°C
Humidity: 45.0%
LED is OFF
Published message to topic home/sensors/dht11: {"temperature":22,"humidity":45}
...

此时，你的 IoT 应用程序已经成功运行，并且可以根据温度的变化自动控制 LED 灯的亮灭。同时，它还会通过 MQTT 将温度和湿度数据发布到云端，以便其他设备或应用程序可以访问这些数据。

5. 总结与展望

恭喜你！你已经成功地在 Raspberry Pi 上使用 Node.js 开发了一个完整的 IoT 应用程序。通过这个项目，你不仅学会了如何读取传感器数据、控制执行器，还掌握了如何使用 MQTT 实现设备间的通信。这些都是构建 IoT 应用的基础技能。

当然，这只是 IoT 开发的冰山一角。随着技术的不断发展，IoT 领域还有许多值得探索的方向。例如，你可以尝试将你的应用程序与云平台（如 AWS IoT、Azure IoT Hub）集成，实现更复杂的远程监控和控制功能。你还可以使用机器学习算法来分析传感器数据，预测设备的故障或优化能源消耗。

无论你选择哪个方向，Node.js 和 Raspberry Pi 都将是你的得力助手。希望今天的讲座能够为你打开一扇通往 IoT 世界的大门，激发你更多的创造力和灵感。如果你有任何问题或想法，欢迎随时与我交流。祝你在 IoT 开发的道路上越走越远，创造出更多令人惊叹的作品！🌟

感谢大家的聆听，我们下次再见！👋

在 Raspberry Pi 上使用 Node.js 开发物联网应用程序

引言

1. 准备工作

1.1 硬件准备

1.2 软件准备

1.2.1 安装操作系统

1.2.2 更新系统

1.2.3 安装 Node.js

1.2.4 安装其他依赖

1.3 配置网络

2. 传感器和执行器的连接

2.1 GPIO 引脚介绍

2.2 读取温湿度传感器数据

2.2.1 硬件连接

2.2.2 安装驱动库

2.2.3 编写代码

2.3 控制 LED 灯

2.3.1 硬件连接

2.3.2 安装驱动库

2.3.3 编写代码

3. 设备间通信

3.1 什么是 MQTT？

3.2 安装 Mosquitto 消息代理

3.3 发布和订阅消息

3.3.1 订阅消息

3.3.2 发布消息

3.4 使用 Node.js 实现 MQTT 通信

3.4.1 发布消息

3.4.2 订阅消息

4. 构建一个完整的 IoT 应用

4.1 项目结构

4.2 创建 package.json

4.3 编写 dht11.js

4.4 编写 led.js

4.5 编写 mqtt.js

4.6 编写 index.js

4.7 运行应用程序

5. 总结与展望

发表回复 取消回复

4.2 创建 `package.json`

4.3 编写 `dht11.js`

4.4 编写 `led.js`

4.5 编写 `mqtt.js`

4.6 编写 `index.js`

发表回复取消回复