NestJS имеет встроенную поддержку микросервисов — он может работать как микросервис, который взаимодействует через различные транспорты (TCP, Redis, NATS, RabbitMQ, Kafka, gRPC) вместо HTTP, используя единую, основанную на сообщениях модель программирования. Одна и та же структура NestJS (модули, сервисы, DI) применяется; меняются только транспорт и паттерны сообщений.
app = .(, {
: .,
: { : , : },
});
app.();
@Controller()
export class MathController {
// REQUEST-RESPONSE: respond to a message and RETURN a result (RPC-style)
@MessagePattern({ cmd: "sum" })
sum(data: number[]): number {
return data.reduce((a, b) => a + b, 0); // the caller awaits this result
}
// EVENT-BASED: react to an event, NO response expected (fire-and-forget)
@EventPattern("order_created")
handleOrderCreated(data: OrderDto) {
this.processOrder(data); // just react; nothing returned
}
}
Два стиля коммуникации: @MessagePattern для request-response (вызывающий ждёт результат, как RPC) и @EventPattern для событий (fire-and-forget, слабая связанность — издатель не ждёт).
@Injectable()
export class AppService {
constructor(@Inject("MATH_SERVICE") private client: ClientProxy) {}
async getSum() {
// send() → request-response (returns an Observable of the result)
return this.client.send({ cmd: "sum" }, [1, 2, 3]);
// emit() → fire an event (no response)
this.client.emit("order_created", orderData);
}
}
ClientProxy (настроенный через ClientsModule) отправляет сообщения/события другим сервисам — send() для request-response, emit() для событий.
// an app can serve HTTP AND connect microservice transports simultaneously
const app = await NestFactory.create(AppModule);
app.connectMicroservice({ transport: Transport.RMQ, options: {...} });
await app.startAllMicroservices();
await app.listen(3000); // HTTP too
TCP → simple direct service-to-service
Redis/NATS → lightweight pub/sub messaging
RabbitMQ/Kafka → robust message queues/streams (durability, retries, decoupling)
gRPC → high-performance, strongly-typed RPC (protobuf)
→ Async message brokers (RMQ/Kafka) give decoupling & resilience; gRPC gives speed+typing.
Встроенная поддержка микросервисов NestJS важна, потому что позволяет вам строить распределённые системы, используя ту же знакомую структуру NestJS (модули, провайдеры, DI, декораторы), одновременно заменяя HTTP на основанные на сообщениях транспорты — огромное преимущество в производительности и консистентности.
Понимание этого важно для проектирования масштабируемых систем: различие между message-pattern (request-response) и event-pattern (fire-and-forget) напрямую отображается на фундаментальный выбор коммуникации в микросервисах — синхронные RPC-подобные вызовы в сравнении с асинхронными, слабосвязанными событиями (последние, через message brokers, обеспечивают отказоустойчивость и слабую связанность, которые делают микросервисы надёжными).
Знание того, как создавать микросервисы, определять обработчики сообщений/событий, вызывать другие сервисы через ClientProxy, строить гибридные HTTP+микросервисные приложения и выбирать транспорты (лёгкий pub/sub в сравнении с долгоживущими очередями вроде Kafka/RabbitMQ в сравнении с высокопроизводительным gRPC) — ценное знание уровня senior для разработки распределённых back-end-ов.
Хотя микросервисы добавляют реальную сложность (и не всегда являются правильным выбором вместо монолита), NestJS делает реализацию чистой и согласованной, что делает эту тему важной для построения крупномасштабных, распределённых NestJS систем.