NestJS:llä on sisäänrakennettu mikropalveluiden tuki — se voi toimia mikropalveluna, joka kommunikoi eri kuljettajien (TCP, Redis, NATS, RabbitMQ, Kafka, gRPC) yli HTTP:n sijaan käyttäen johdonmukaista, viestipohjaista ohjelmointimallia. Sama NestJS-rakenne (moduulit, palvelut, DI) pätee; vain kuljettaja ja viestikaaviot muuttuvat.
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
}
}
Kaksi komunikaatiotyyliä: @MessagePattern pyyntö-vastaus-viestinnälle (kutsuva odottaa tulosta, kuten RPC) ja @EventPattern tapahtumille (luo ja unohda, irrotettu — julkaisija ei odota).
@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 (määritetty ClientsModule:n kautta) lähettää viestejä/tapahtumia muille palveluille — send() pyyntö-vastaus-viestinnälle, emit() tapahtumille.
// 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:n sisäänrakennettu mikropalveluiden tuki on merkittävä, koska sen avulla voit rakentaa hajautettuja järjestelmiä käyttäen samaa tuttua NestJS-rakennetta (moduulit, palvelut, DI, dekoraattorit) vaihtaen HTTP:n viestipohjaisten kuljettajien kanssa — merkittävä tuottavuuden ja johdonmukaisuuden etu.
Ymmärtäminen on tärkeää skaalautuvien järjestelmien arkkitehtuurille: viestikaaviön (pyyntö-vastaus) vs tapahtumakaavion (luo ja unohda) eroavaisuus liittyy suoraan mikropalveluiden perustavanlaatuiseen komunikaatiovalintaan — synkronisiin RPC-tyylisiin kutsuihin verrattuna asynkronisiin, irrotettuihin tapahtumiin (jälkimmäinen, viestijohtajien kautta, tarjoaa jäykkyyttä ja väljän kytkennän, jotka tekevät mikropalveluista kestäviä).
Tietäminen, kuinka luoda mikropalveluita, määrittää viesti- ja tapahtumakäsittelijöitä, kutsua muita palveluita ClientProxy:n kautta, rakentaa hybridi HTTP + mikropalvelu -sovelluksia ja valita kuljettajia (kevyt pub/sub vs kestävät jonot kuten Kafka/RabbitMQ vs suorituskykyinen gRPC) on arvokas senior-tason osaaminen hajautettujen takakehityksen suunnitteluun.
Vaikka mikropalvelut lisäävät todellista monimutkaisuutta (eivätkä aina ole oikea valinta monoliitin sijaan), NestJS tekee toteutuksesta puhdasta ja johdonmukaista, mikä tekee tämän tärkeästä arkkitehtonisesta aiheesta suurten mittakaavojen, hajautettujen NestJS-järjestelmien rakentamiseen.