WebSocket gateway'leri kullanarak gerçek zamanlı özellikler nasıl oluşturursunuz?

Question

Accepted Answer

NestJS, **gerçek zamanlı, çift yönlü iletişimi** **WebSocket gateway'leri** aracılığıyla destekler — `@WebSocketGateway()` ile dekore edilen ve WebSocket bağlantılarını ve mesajlarını işleyen sınıflar (tipik olarak Socket.IO üzerinden). Bunlar sohbet, canlı bildirimler ve canlı gösterge panoları gibi özellikleri etkinleştirerek, aynı NestJS yapısını (DI, decorators) kullanır.

## Gateway tanımlama

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

Bir gateway, gelen olayları işlemek için `@SubscribeMessage("event")` kullanır (HTTP için `@Post`'a benzer) ve enjekte edilen `server`'ı istemcilere olayları **yayınlamak** için kullanır — `server.emit` herkese yayın yapar.

## Bağlantı yaşam döngüsü kancaları

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

Gateway'ler istemcilerin bağlanması ve bağlantısı kesilmesine tepki verebilir — durum takibi ve temizlik için yararlıdır.

## Belirli istemciler ve odalar hedefleme

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

**Odalar** istemcileri gruplandırır (örneğin bir sohbet odası, bir belgenin işbirlikçileri), herkese yayın yapmak yerine belirli alt kümelere yayın yapmanıza izin verir — kapsamlı gerçek zamanlı özellikler için gereklidir.

## Gateway'ler NestJS özelliklerini yeniden kullanır

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

## WebSocket'leri ölçeklendirme

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

## Neden önemli

WebSocket gateway'leri, NestJS'in **gerçek zamanlı, çift yönlü özellikleri** — sohbet, canlı bildirimler, durum, işbirlikçi düzenleme, canlı gösterge panoları, çok oyunculu etkileşimler — desteklediği yoldur; bu özellikler REST'in istek-yanıt modelinin sağlayamayacağı şeylerdir (sunucu istemcilere itebilir, sadece isteklere yanıt vermez).

Bunları anlamak, modern etkileşimli uygulamalar oluşturmak için değerli üst düzey bilgidir.

Asıl güç, gateway'lerin NestJS'in tanıdık yapısına uymasıdır: bunlar **dependency injection** destekleyen sağlayıcılardır ve HTTP controller'ları gibi **guards, pipes, interceptors ve filters** kullanabilirler, bu nedenle aynı kalıplar ve kod organizasyonu REST'e olduğu gibi gerçek zamanlıya da uygulanır.

Olayları işlemeyi (`@SubscribeMessage`), istemcilere yayın yapmayı (`server.emit`), yayınları ilgili alt kümelere (sohbet odaları, belge işbirlikçileri) kapsamlandırmak için **odaları** kullanmayı ve bağlantı yaşam döngüsünü (durum, temizlik) yönetmeyi bilmek pratik gerçek zamanlı araç setini kapsar.

Kritik olarak önemli olan **ölçeklendirme göz önüne alınmasıdır**: WebSocket bağlantıları durum sahibidir ve tek bir sunucu örneğine bağlıdır, bu nedenle yatay olarak ölçeklendirmek, örnekler arasında yayınları/odaları koordine etmek için bir **Redis adaptörü** gerektirir (yaygın bir tuzak — seanslar gibi, gerçek zamanlı durum birden fazla örnek çalıştırırken tek bir işlemin belleğinde yaşayamaz).

Bu, modern kullanıcıların beklediği gerçek zamanlı, etkileşimli deneyimleri oluşturmak için önemli ve giderek daha ilgili bir yetenektir ve NestJS'in temiz entegrasyonu bunu erişilebilir kılarken çerçevenin yapısını yeniden kullanır.