时间戳

首页 > 解决方案 > NestJS - 在微服务中结合 HTTP 和 RabbitMQ

node.js - NestJS - 在微服务中结合 HTTP 和 RabbitMQ

问题描述

我有一些微服务，它们通过 API 网关公开。网关负责处理身份验证和路由到系统。网关背后的服务大多是简单的 CRUD-Services。每个服务都公开自己的 API，它们通过 HTTP 同步通信。所有这些服务，包括 API-Gateway，都是“默认”的 NestJS 应用程序。

让我们继续使用 Cats 示例。每当Cat-Service更新或创建新的Cat时，我都希望使用CatCreatedEventor CatUpdatedEvent。该事件应该被推送到像 RabbitMQ 这样的消息代理中，另一个服务应该监听这个事件并异步处理该事件。

关于如何以正确的方式“注入”RabbitMQ，我不确定如何实现这一点，我想知道这种方法在一般情况下是否有意义。我看过 NestJS 的 CQRS 模块，但我认为 CQRS 对于这个领域来说有点太多了。特别是因为在这个领域中拆分读写模型没有任何好处。也许我完全走错了路，所以我希望你能给我一些建议。

标签： node.jseventsrabbitmqmicroservicesnestjs

解决方案

Nestjs支持RabbitMQ作为微服务。如果您希望您的应用程序同时支持 http 请求和消息代理，您可以创建一个混合应用程序。

// Create your regular nest application.
const app = await NestFactory.create(ApplicationModule);

// Then combine it with a RabbitMQ microservice
const microservice = app.connectMicroservice({
  transport: Transport.RMQ,
  options: {
    urls: [`amqp://localhost:5672`],
    queue: 'my_queue',
    queueOptions: { durable: false },
  },
});

await app.startAllMicroservicesAsync();
await app.listen(3001);

推荐阅读