NestJs基于事件的Micro服务体系结构



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

假设我有";用户服务";投掷";user.created";事件当一个用户在DB上注册时,其他一些服务可以侦听此事件。如果一个服务规模,意味着有超过&在同一时间运行的服务的实例中,消息被同一"服务"消耗了很多次;服务种类";。

我该如何解决这个问题?

她说,你会发现一个完整的示例项目,上面有用例和运行代码:https://github.com/quentin-bardenet/nest-u-service-scalability-problem

最后,我用NATS替换Redis传输程序。NATS支持队列,然后我可以创建一类组。

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

最新更新