学习NestJS时了解微服务：RabbitMQ场景下微服务与网关通信原理问询

三者核心角色定位 #

• 网关：微服务集群的唯一流量入口，承担请求路由、鉴权、流量控制、统一日志统计等公共横切逻辑，NestJS生态可直接使用@nestjs/gateway模块搭建网关，也可接入APISIX、Kong等独立网关组件。
• NestJS 微服务：按业务领域拆分的独立服务单元，每个服务仅负责单一领域的业务实现，可独立部署、扩容。
• RabbitMQ：异步通信中间件，用于服务间异步解耦、削峰填谷，是NestJS微服务生态常用的传输层实现之一。

标准通信流程 #

1. 客户端到服务端的请求链路（同步场景） #

所有客户端请求首先到达网关：

• 网关先完成统一的鉴权、参数校验、限流等前置逻辑，不合法的请求直接被拦截返回
• 合法请求根据预设的路由规则（路径、Header匹配等），找到对应后端NestJS微服务的实例地址
• 网关将请求转发到对应微服务，微服务处理完业务逻辑后将响应原路返回给网关，再由网关返回给客户端

如果当前请求涉及多个微服务协作，网关会将请求转发到核心业务微服务，再由该微服务内部调用其他关联服务：

• 强依赖返回结果的场景：微服务通过HTTP、gRPC等协议同步调用其他服务接口
• 不需要立即获取返回结果的场景：微服务通过RabbitMQ发送异步消息通知其他服务执行对应逻辑，不需要等待响应即可返回，整体性能更高。

2. 服务间内部通信 #

• 同步调用：通过NestJS内置的HttpService或者gRPC客户端直接调用目标服务的公开接口，适合强一致性要求的业务场景，比如支付结果校验、库存扣减。
• 异步通信：通过RabbitMQ的交换机、队列机制完成消息的生产和消费，适合最终一致性要求的业务场景，比如下单成功后的短信通知、用户积分更新。

NestJS 相关核心实现示例 #

接入RabbitMQ作为微服务传输层，需要先安装@nestjs/microservices和amqplib依赖，配置示例如下：

// 微服务启动RabbitMQ监听配置
import { NestFactory } from '@nestjs/core';
import { Transport, MicroserviceOptions } from '@nestjs/microservices';
import { AppModule } from './app.module';

async function bootstrap() {
  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
    AppModule,
    {
      transport: Transport.RMQ,
      options: {
        urls: ['amqp://localhost:5672'],
        queue: 'service_order_queue',
        queueOptions: {
          durable: true,
        },
      },
    },
  );
  await app.listen();
}
bootstrap();

服务间发送消息可通过注入ClientProxy实例调用send()（同步等待响应）或emit()（异步无响应）方法实现。

内容的提问来源于stack exchange，提问作者Smoke