README

快速开始

该模块是对amqplib的封装，方便在nestjs快速使用rabbitmq的topic模式

安装

npm i @sevenfifteen/nestjs-rabbitmq

在 app.module 中引入

import { RabbitmqModule } from '@sevenfifteen/nestjs-rabbitmq';
@Module({
  imports: [
    RabbitmqModule.register({
      urls: ['amqp://server:123456@localhost:5672?heartbeat=60'],
    }),
  ],
})
export class AppModule {}

消费者监听消息

import { RabbitmqSubscribe } from '@sevenfifteen/nestjs-rabbitmq';
@Injectable()
class TestConsumer {
  @RabbitmqSubscribe('exchangeName', 'routingKey', 'queueName')
  async getInfo(info: any) {
    console.log(`this is the info from producer ${info}`);
  }
}

生产者发布消息

import { RabbitmqConnection } from '@sevenfifteen/nestjs-rabbitmq';
@Injectable()
class ProducerService {
  constructor(private readonly amqpConnection: RabbitmqConnection) {}
  async sendInfo() {
    await this.amqpConnection.publish('test', 'routingKey', { test: 'hello' });
  }
}

API

导入依赖

@sevenfifteen/nestjs-rabbitmq 采用全局导入，这样子用户不需要在各个 module 中再次导入该 module。它拥有同步导入和异步导入两种模式。

同步导入模式

函数RabbitmqModule.register(options: RabbitmqConnectionOption):DynamicModule,

参数名	必填	描述
options.name	N	rabbitmq 连接的名字
options.urls	Y	rabbitmq 的链接 url 数组
options.AmqpConnectionManagerOptions	N	amqp 的 AmqpConnectionManagerOptions

例如:

@Module({
  imports: [
    RabbitmqModule.register({
      urls: ['amqp://server:123456@localhost:5672?heartbeat=60'],
    }),
  ],
})
export class AppModule {}

异步导入

函数registerAsync(options: RabbitmqAsyncConnectionOption): DynamicModule | 参数名 | 必填 | 描述 | | :----------------------------------: |:--:|:----------------------------------: | | options.name | N |rabbitmq 连接的名字 | | options.useFactory | Y | 返回RabbitmqConnectionOption的函数 | | options.inject | N | useFactory 的依赖注入 |

例如

@Injectable()
class ConfigService {
  get(key: string) {
    return {
      name: 'test',
      urls: ['amqp://server:123456@localhost:5672?heartbeat=60'],
    };
  }
}

@Module({
  imports: [
    RabbitmqModule.registerAsync({
      imports: [ConfigModule],
      useFactory: (config: ConfigService) => config.get('rabbitmq'),
      inject: [ConfigService],
    }),
  ],
})
export class AppModule {}

消息订阅

例如

@Injectable()
class TestConsumer {
  @RabbitmqSubscribe('exchangeName', 'routingKey', 'queueName')
  async getInfo(info: any) {
    console.log(`this is the info from producer ${info}`);
  }
}

消息发布

由于rabbitmqModule已经全局引入了，所以消息发布只需要注入RabbitmqConnection依赖即可, 例如：

@Injectable()
class ProducerService {
  constructor(private readonly amqpConnection: RabbitmqConnection) {}
  async sendInfo() {
    await this.amqpConnection.publish('test', 'routingKey', { test: 'hello' });
  }
}

Usage no npm install needed!