آپ WebSocket gateways کے ساتھ حقیقی وقت کی خصوصیات کیسے بناتے ہیں؟

Question

Accepted Answer

NestJS **حقیقی وقت، دو طرفہ communication** کو **WebSocket gateways** کے ذریعے سپورٹ کرتا ہے — یہ کلاسز ہیں جو `@WebSocketGateway()` سے سجی ہوئی ہوں اور WebSocket کنکشنز اور پیغامات کو سنبھالتی ہوں (عام طور پر Socket.IO کے ذریعے)۔ یہ چیٹ، لائیو نوٹیفیکیشنز، اور لائیو ڈیش بورڈز جیسی خصوصیات کو فعال کرتے ہیں، نفس 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 کو سنبھالنے کے لیے (HTTP کے لیے `@Post` کی طرح) اور injected `server` کو **emit** events کو clients کو واپس بھیجنے کے لیے — `server.emit` سب کو broadcast کرتا ہے۔

## 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 کو کنکٹ اور disconnect ہوتے ہوئے دیکھ سکتے ہیں — presence tracking اور cleanup کے لیے مفید ہے۔

## مخصوص clients اور rooms کو target کرنا

```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 کو گروپ کرتے ہیں (مثلاً ایک چیٹ room، ایک دستاویز کے تعاون کنندگان)، آپ کو سب کی بجائے مخصوص subsets کو broadcast کرنے دیتے ہیں — scoped حقیقی وقت کی خصوصیات کے لیے ضروری ہے۔

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

## WebSockets کو Scale کرنا

```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 **حقیقی وقت، دو طرفہ خصوصیات** کو سپورٹ کیسے کرتا ہے — چیٹ، لائیو نوٹیفیکیشنز، presence، تعاونی ترمیم، لائیو ڈیش بورڈز، multiplayer interactions — جو REST کے request-response ماڈل فراہم نہیں کر سکتے (server clients کو push کر سکتا ہے، صرف requests کا جواب نہیں دے سکتے)۔

junior سے بزرگ سطح کے لیے یہ سمجھنا قیمتی علم ہے جدید interactive applications بنانے کے لیے۔

بنیادی طاقت یہ ہے کہ gateways NestJS کے واقف ڈھانچے میں فٹ ہوتے ہیں: یہ providers ہیں جو **dependency injection** سپورٹ کرتے ہیں اور **guards، pipes، interceptors، اور filters** استعمال کر سکتے ہیں بالکل HTTP controllers کی طرح، تو نفس patterns اور code organization حقیقی وقت اور REST دونوں پر لاگو ہوتے ہیں۔

Events کو سنبھالنا (`@SubscribeMessage`)، clients کو broadcast کرنا (`server.emit`)، **rooms** استعمال کرنا broadcasts کو relevant subsets تک scope کرنے کے لیے (چیٹ rooms، document تعاون کنندگان)، اور connection lifecycle کو سنبھالنا (presence، cleanup) عملی حقیقی وقت کے toolkit کو cover کرتا ہے۔

سب سے اہم **scaling کی غور و فکر** ہے: WebSocket کنکشنز stateful ہوتے ہیں اور ایک واحد server instance سے منسلک ہوتے ہیں، تو افقی scaling کے لیے **Redis adapter** ضروری ہے broadcasts/rooms کو instances کے دوران ہماہنگ کرنے کے لیے (ایک عام غلطی — sessions کی طرح، حقیقی وقت کی state ایک process کی memory میں نہیں رہ سکتی جب متعدد instances چل رہے ہوں)۔

یہ ایک اہم، بڑھتے ہوئے متعلقہ صلاحیت ہے حقیقی وقت، interactive experiences بنانے کے لیے جو جدید صارفین کی توقع رکھتے ہیں، اور NestJS کی صاف integration اسے accessible بناتی ہے جبکہ framework کے ڈھانچے کو دوبارہ استعمال کرتے ہوئے۔