NestJs基于微服务事件的架构

Question

我的问题如下。考虑使用nestJs的微服务架构，一些操作是由事件触发的。

假设我有一个“用户服务”，当一个用户在数据库中注册时，它会抛出"user.created“事件，其他一些服务可以监听这个事件。如果一个服务规模大，意味着有多个实例在同一时间运行一个服务，则消息被同一“类型的服务”多次使用。

如何解决此问题？

在这里，您将找到一个完整的示例项目，其中包含上述用例和运行代码：https://github.com/quentin-bardenet/nest-u-service-scalability-problem

Answer 1

终于没问题了，我用NATS代替了Redis transporter。NATS支持队列，然后我可以创建一种类型的组。

我用工作代码更新了以前的存储库，也许它可以帮助一些人。