Πώς δημιουργείς real-time features με WebSocket gateways;

Question

Accepted Answer

Το NestJS υποστηρίζει **real-time, bidirectional communication** μέσω **WebSocket gateways** — κλάσεις διακοσμημένες με `@WebSocketGateway()` που χειρίζονται WebSocket συνδέσεις και μηνύματα (συνήθως μέσω Socket.IO). Ενεργοποιούν χαρακτηριστικά όπως chat, live notifications και live dashboards, χρησιμοποιώντας την ίδια δομή NestJS (DI, decorators).

## Ορισμός gateway

```ts
import { WebSocketGateway, SubscribeMessage, MessageBody, WebSocketServer } from "@nestjs/websockets";
import { Server } from "socket.io";

@WebSocketGateway({ cors: true })
export class ChatGateway {
  @WebSocketServer()
  server: Server;                        // the Socket.IO server instance

// handle a 'message' event from a client
  @SubscribeMessage("message")
  handleMessage(@MessageBody() data: { text: string }) {
    // BROADCAST to all connected clients
    this.server.emit("message", data);   // everyone receives the message
  }
}
```

Ένα gateway χρησιμοποιεί `@SubscribeMessage("event")` για να χειριστεί εισερχόμενα events (ανάλογο με `@Post` για HTTP) και το injected `server` για να **εκπέμψει** events πίσω στους clients — `server.emit` μεταδίδει σε όλους.

## Connection lifecycle hooks

```ts
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
  }
}
```

Τα gateways μπορούν να αντιδράσουν όταν οι clients συνδέονται και αποσυνδέονται — χρήσιμο για presence tracking και cleanup.

## Στόχευση συγκεκριμένων clients και rooms

```ts
@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
}
```

**Rooms** ομαδοποιούν clients (π.χ. ένα chat room, τους συνεργάτες ενός εγγράφου), επιτρέποντάς σου να μεταδώσεις σε συγκεκριμένα υποσύνολα αντί για όλους — απαραίτητο για scoped real-time features.

## Τα gateways επαναχρησιμοποιούν χαρακτηριστικά NestJS

```text
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.
```

## Scaling WebSockets

```text
⚠️ 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 gateways είναι ο τρόπος με τον οποίο το NestJS υποστηρίζει **real-time, bidirectional features** — chat, live notifications, presence, collaborative editing, live dashboards, multiplayer interactions — που το request-response model του REST δεν μπορεί να παρέχει (ο server μπορεί να push στους clients, όχι απλώς να αποκριθεί σε αιτήματα).

Η κατανόηση τους είναι πολύτιμη γνώση επιπέδου senior για τη δημιουργία σύγχρονων διαδραστικών εφαρμογών.

Η κύρια δύναμη είναι ότι τα gateways προσαρμόζονται στη γνώριμη δομή του NestJS: είναι providers που υποστηρίζουν **dependency injection** και μπορούν να χρησιμοποιούν **guards, pipes, interceptors, και filters** όπως οι HTTP controllers, έτσι τα ίδια patterns και η organization του κώδικα ισχύουν για real-time όπως και για REST.

Η γνώση του πώς να χειρίζεσαι events (`@SubscribeMessage`), να μεταδίδεις στους clients (`server.emit`), να χρησιμοποιείς **rooms** για να περιορίσεις τις μεταδόσεις σε σχετικά υποσύνολα (chat rooms, document collaborators), και να διαχειρίζεσαι το connection lifecycle (presence, cleanup) καλύπτει το πρακτικό real-time toolkit.

Εξαιρετικά σημαντική είναι η **scaling consideration**: WebSocket συνδέσεις είναι stateful και δεμένες σε μια μόνο server instance, έτσι το horizontal scaling απαιτεί έναν **Redis adapter** για να συντονίσει broadcasts/rooms σε instances (μια κοινή παγίδα — όπως sessions, η real-time state δεν μπορεί να ζει στη μνήμη ενός process όταν τρέχουν πολλές instances).

Αυτό είναι ένα σημαντικό, ολοένα πιο σχετικό capability για τη δημιουργία των real-time, interactive experiences που περιμένουν οι σύγχρονοι users, και η καθαρή ενοποίηση του NestJS το κάνει προσβάσιμο ενώ επαναχρησιμοποιεί τη δομή του framework.