Nest.js RabbitMQ未发送/接收消息

e3bfsja2  于 2022-12-18  发布在  RabbitMQ
关注(0)|答案(1)|浏览(134)

我有两个带有Nest.js的微服务,它们都连接到RabbitMQ服务(一个是发布者,一个是接收者)。我尝试从发布者向接收者发送消息,但似乎它什么也没做
出版商:

auth.module.ts :
 imports:[ClientsModule.registerAsync([
      {
        name: 'RMQ_SERVICE',
        imports: [ConfigModule],
        useFactory: (configService: ConfigService) => ({
          transport: Transport.RMQ,
          options: {
            urls: [`amqp://${configService.get('RMQ_HOST')}:5672`],
            queue: 'api-queue',
            queueOptions: {
              durable: false,
            },
          },
        }),
        inject: [ConfigService],
      },
    ]),
]

auth.service.ts : 
@Inject('RMQ_SERVICE') private readonly client: ClientProxy,

and using it like that : 
 this.client.send({ cmd: 'create-user-data' },{});

接收者:

main.ts : 
app.connectMicroservice<MicroserviceOptions>({
    transport: Transport.RMQ,
    options: {
      noAck: false,
      urls: [`amqp://${process.env.RMQ_HOST}:5672`],
      queue: 'api-queue',
      queueOptions: {
        durable: false,
      },
    },
  });
  await app.startAllMicroservices();

users-data.controler.ts : 
  @MessagePattern({ cmd: 'create-user-data'})
  async createUserData() {
    console.log('create-user-data');
  }

看不到任何错误,我也有rabbitmq网络监视器,看不到有任何消息
知道出什么事了吗
如果我使用emit和EventPattern,它工作,我不明白为什么?

xnifntxz

xnifntxz1#

好吧,所以经过长时间的挖掘,我只需要做

const result = await this.client.send(
        { cmd: 'create-user-data' },
        {
          userId: user.id,
          provider,
          ...socialUser,
        },
      );
      await result.subscribe();

我在接收器上收到了消息

相关问题