0

我有两个微服务。第一个微服务是前端服务器，它在第二个微服务实例中请求一些工作。NATS 传输的最佳解决方案是排队。我可以发送消息，而 NATS 只会将其发送到其中一个实例。但是，如果我需要向每个队列实例发送消息或事件？

前台服务：


//module

  providers: [
    ...,

    {
      provide: 'CLIENT_PROXY_FACTORY',
      useFactory: (configService: ConfigService) => {
        return ClientProxyFactory.create(configService.get('microservice'));
      },
      inject: [ConfigService],
    }
  ],

// service

constructor(
    @Inject('CLIENT_PROXY_FACTORY')
    private nats: ClientProxy,
) {

}
// in some method
method() {

  this.nats.emit('test', 0);
  this.nats.send('test1', true).toPromise();

}

工人服务：

// bootstrap

  transport: Transport.NATS,
  options: {
    url: 'nats://127.0.0.1:4222',
    queue: 'worker'
  }

// controller

  @MessagePattern('test')
  messagefunc() {
    console.log('Got message!');
  }

  @EventPattern('test1')
  eventfunc() {
    console.log('Got event!');
  }

所以。在我的示例中，我需要创建 2 个或更多实例Worker service。我需要一个解决方案，如何有时将事件或消息传递给所有Worker service实例？

4

1 回答 1

1

使工作人员服务订阅两个主题：

  • 队列组中的主题 A。发布到 A 的消息将仅发送给一名工作人员。
  • 没有队列组的主题 B。发布到 B 的消息将发送给所有工作人员。

抱歉，不知道如何在 NestJS 中实现这一点。

于 2020-10-19T10:16:13.247 回答