Nodejs Nestjs MQTT通信插件nestjs-mqtt的使用

nestjs-mqtt 是一个用于 NestJS 应用程序的 MQTT 通信插件。它允许你轻松地集成 MQTT 协议到你的 NestJS 项目中。以下是如何安装和使用 nestjs-mqtt 的基本步骤：

安装

首先，你需要通过 npm 安装 nestjs-mqtt：

npm install @nestjs-modules/mqtt

如果你的应用使用了 TypeScript，可能还需要安装 @types/node（虽然大多数情况下不需要显式安装，因为它是作为 node 包的一部分）：

npm install --save-dev @types/node

配置

然后，在你的应用模块中配置 MQTTModule。例如，在 app.module.ts 中：

import { Module } from '@nestjs/common';
import { MqttModule, MqttOptions } from '@nestjs-modules/mqtt';

@Module({
  imports: [
    MqttModule.forRoot({
      // MQTT 连接配置
      connect: {
        url: 'mqtt://broker.hivemq.com', // MQTT broker 地址
        port: 1883, // 端口，默认是1883
        clientId: 'your_client_id', // 客户端ID
        username: 'your_username', // 用户名，如果有
        password: 'your_password', // 密码，如果有
      },
      defaultTopic: '/default/topic', // 默认主题
    }),
    // 其他模块
  ],
  controllers: [AppController],
  providers: [AppService],
})
export class AppModule {}

使用

发布消息

你可以创建一个服务来发布 MQTT 消息：

import { Injectable } from '@nestjs/common';
import { ClientProxy } from '@nestjs/microservices';

@Injectable()
export class MqttPublisherService {
  constructor(private readonly clientProxy: ClientProxy) {}

  publishMessage(topic: string, message: string) {
    this.clientProxy.emit(topic, message);
  }
}

订阅消息

同样地，创建一个服务来订阅消息：

import { Injectable } from '@nestjs/common';
import { ClientProxy } from '@nestjs/microservices';

@Injectable()
export class MqttSubscriberService {
  constructor(private readonly clientProxy: ClientProxy) {}

  subscribeToTopic(topic: string, callback: (message: any) => void) {
    this.clientProxy.subscribe(topic, (message) => {
      callback(message);
    });
  }
}

在控制器中使用

最后，在控制器中注入这些服务：

import { Controller, Get } from '@nestjs/common';
import { MqttPublisherService } from './mqtt-publisher.service';
import { MqttSubscriberService } from './mqtt-subscriber.service';

@Controller()
export class AppController {
  constructor(
    private readonly mqttPublisherService: MqttPublisherService,
    private readonly mqttSubscriberService: MqttSubscriberService,
  ) {}

  @Get('publish')
  publishMessage() {
    this.mqttPublisherService.publishMessage('/test/topic', 'Hello MQTT');
  }

  @Get('subscribe')
  subscribeMessage() {
    this.mqttSubscriberService.subscribeToTopic('/test/topic', (message) => {
      console.log(`Received message: ${message}`);
    });
  }
}

以上就是如何在 NestJS 应用程序中使用 nestjs-mqtt 插件的基本流程。希望这对你有所帮助！