NestJS palaiko realiojo laiko, dvikryptį komunikaciją per WebSocket gateway'us — klases su @WebSocketGateway() dekoratoriumi, kurie tvarko WebSocket ryšius ir žinutes (paprastai per Socket.IO). Jie įgalina funkcijas, tokias kaip pokalbiai, tiesioginiai pranešimai ir dinaminiai prietaisai, naudojant tą pačią NestJS struktūrą (DI, dekoratoriai).
{ , , , } ;
{ } ;
({ : })
{
()
: ;
()
() {
..(, data);
}
}
Gateway naudoja @SubscribeMessage("event") gaunančioms įvykiams tvarkyti (panašiai kaip @Post HTTP) ir injektintą server objektą siuntinėti įvykius grįžtamais link klientų — server.emit transliuoja visiems.
export class ChatGateway implements OnGatewayConnection, OnGatewayDisconnect {
handleConnection(client: Socket) {
console.log(`Client connected: ${client.id}`); // a user joined
}
handleDisconnect(client: Socket) {
console.log(`Client disconnected: ${client.id}`); // a user left — clean up
}
}
Gateway'ai gali reaguoti į klientų prisijungimus ir atsisjungimus — naudinga kliento buvimui stebėti ir ištekliams valyti.
@SubscribeMessage("joinRoom")
handleJoin(@ConnectedSocket() client: Socket, @MessageBody() room: string) {
client.join(room); // add the client to a room
}
@SubscribeMessage("roomMessage")
sendToRoom(@MessageBody() data: { room: string; text: string }) {
this.server.to(data.room).emit("message", data.text); // emit only to that room
// client.emit(...) → just that client; server.emit(...) → everyone
}
Kambariai grupuoja klientus (pvz. pokalbių kambarys, dokumento bendradarbiai), leidžiant jums transliuoti konkretiems pogrupiams, o ne visiems — būtina apribotoms realiojo laiko funkcijoms.
Gateways are providers → they support dependency injection (inject services),
and can use guards, pipes, interceptors, and filters — just like HTTP controllers.
→ The same structure/patterns apply to real-time as to REST.
⚠️ WebSocket connections are STATEFUL and live on ONE server instance.
To scale across multiple instances, use a Redis adapter (socket.io-redis) so
broadcasts/rooms work across all instances. (Like sessions, don't keep state in
one process's memory when scaling horizontally.)
WebSocket gateway'ai yra tai, kaip NestJS palaiko realiojo laiko, dvikryptę funkcionalumą — pokalbius, tiesiogines notifikacijas, buvimą, bendradarbiavimo redagavimą, dinaminius prietaisus, daugiaž žaidžiančias sąveikas — kurių REST užklausų-atsakų modelis negali pateikti (serveris gali siųsti klientams, o ne tik atsakyti į užklausas).
Jų supratimas yra vertinga aukšto lygio žinios modernių interaktyvių aplikacijų kūrimui.
Pagrindinė stiprybė yra tai, kad gateway'ai tinka NestJS žinomai struktūrai: jie yra teikėjai, palaikantys dependency injection ir gali naudoti guard'us, pipes, interceptor'ius ir filters kaip HTTP kontroleriai, todėl tie patys šablonai ir kodo organizavimas taikomi realiajam laikui ir REST'ui.
Žinoti, kaip tvarkyti įvykius (@SubscribeMessage), transliuoti klientams (server.emit), naudoti kambarius apriboti transliavimą atitinkamams pogrupiams (pokalbių kambariai, dokumento bendradarbiai) ir valdyti ryšio ciklą (buvimą, išteklių valymą) — tai apima praktinį realiojo laiko įrankių rinkinį.
Kritiškai svarbu yra mastelio apsvarstymas: WebSocket ryšiai yra su būsena ir susieti su viena serverio instancija, todėl horizontalus mastelis reikalauja Redis adapter'io koordinuoti transliavimus/kambarius per instancijas (dažna klaida — kaip sesijos, realiojo laiko būsena negali būti vieno proceso atmintyje, kai veikia kelios instancijos).
Tai svarbi, vis labiau aktuali galimybė kurti realiojo laiko, interaktyvias patirtis, kurias tikisi šiuolaikiniai vartotojai, ir NestJS švariai integruota versija ją daro pasiekiamą, naudojant framework'o struktūrą.