我有两个带有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,它工作,我不明白为什么?
1条答案
按热度按时间xnifntxz1#
好吧,所以经过长时间的挖掘,我只需要做
我在接收器上收到了消息