আপনি WebSocket গেটওয়ে দিয়ে রিয়েল-টাইম বৈশিষ্ট্য কীভাবে তৈরি করেন?

Question

Accepted Answer

NestJS **রিয়েল-টাইম, দ্বিমুখী যোগাযোগ** সমর্থন করে **WebSocket গেটওয়ে** এর মাধ্যমে — `@WebSocketGateway()` দিয়ে সজ্জিত ক্লাস যা WebSocket সংযোগ এবং বার্তা পরিচালনা করে (সাধারণত Socket.IO এর উপর)। তারা চ্যাট, লাইভ বিজ্ঞপ্তি এবং লাইভ ড্যাশবোর্ডের মতো বৈশিষ্ট্য সক্ষম করে, একই NestJS কাঠামো ব্যবহার করে (DI, ডেকোরেটর)।

## গেটওয়ে সংজ্ঞায়িত করা

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

একটি গেটওয়ে আসন্ন ইভেন্ট পরিচালনা করতে `@SubscribeMessage("event")` ব্যবহার করে (HTTP এর জন্য `@Post` এর অনুরূপ) এবং ইনজেক্ট করা `server` ক্লায়েন্টদের কাছে ইভেন্ট **নির্গমন** করতে ব্যবহার করে — `server.emit` সবার কাছে সম্প্রচার করে।

## সংযোগ জীবনচক্র হুক

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

গেটওয়েগুলি ক্লায়েন্টদের সংযোগ এবং বিচ্ছিন্ন হওয়ার প্রতি প্রতিক্রিয়া জানাতে পারে — উপস্থিতি ট্র্যাকিং এবং পরিচ্ছন্নতার জন্য দরকারী।

## নির্দিষ্ট ক্লায়েন্ট এবং রুম লক্ষ্য করা

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

**রুম** ক্লায়েন্টদের গোষ্ঠীবদ্ধ করে (যেমন একটি চ্যাট রুম, একটি ডকুমেন্টের সহযোগী), যা আপনাকে সবার পরিবর্তে নির্দিষ্ট উপসেটে সম্প্রচার করতে দেয় — সুযোগভিত্তিক রিয়েল-টাইম বৈশিষ্ট্যের জন্য অপরিহার্য।

## গেটওয়েগুলি 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.
```

## WebSocket স্কেল করা

```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 গেটওয়েগুলি হল কীভাবে NestJS **রিয়েল-টাইম, দ্বিমুখী বৈশিষ্ট্য** সমর্থন করে — চ্যাট, লাইভ বিজ্ঞপ্তি, উপস্থিতি, সহযোগিতামূলক সম্পাদনা, লাইভ ড্যাশবোর্ড, মাল্টিপ্লেয়ার মিথস্ক্রিয়া — যা REST এর অনুরোধ-প্রতিক্রিয়া মডেল প্রদান করতে পারে না (সার্ভার ক্লায়েন্টদের কাছে পুশ করতে পারে, শুধুমাত্র অনুরোধের প্রতিক্রিয়া নয়)।

সেনিয়র-স্তরের জ্ঞান হিসেবে এগুলি বোঝা আধুনিক ইন্টারেক্টিভ অ্যাপ্লিকেশন তৈরির জন্য মূল্যবান।

মূল শক্তি হল গেটওয়েগুলি NestJS এর পরিচিত কাঠামোতে ফিট করে: তারা প্রদানকারী যা **নির্ভরতা ইনজেকশন** সমর্থন করে এবং HTTP কন্ট্রোলারদের মতো **গার্ড, পাইপ, ইন্টারসেপ্টর এবং ফিল্টার** ব্যবহার করতে পারে, তাই একই প্যাটার্ন এবং কোড সংগঠন রিয়েল-টাইম এবং REST উভয়ের জন্য প্রয়োগ করা যায়।

ইভেন্ট পরিচালনা করা (`@SubscribeMessage`), ক্লায়েন্টদের কাছে সম্প্রচার করা (`server.emit`), প্রাসঙ্গিক উপসেটের জন্য সম্প্রচার স্কোপ করতে **রুম** ব্যবহার করা (চ্যাট রুম, ডকুমেন্ট সহযোগী), এবং সংযোগ জীবনচক্র পরিচালনা করা (উপস্থিতি, পরিচ্ছন্নতা) ব্যবহারিক রিয়েল-টাইম টুলকিট কভার করে।

সমালোচনামূলকভাবে গুরুত্বপূর্ণ হল **স্কেলিং বিবেচনা**: WebSocket সংযোগগুলি স্টেটফুল এবং একটি একক সার্ভার ইনস্ট্যান্সের সাথে যুক্ত, তাই অনুভূমিকভাবে স্কেল করা উদাহরণগুলি জুড়ে সম্প্রচার/রুমগুলি সমন্বয় করার জন্য একটি **Redis অ্যাডাপ্টার** প্রয়োজন (একটি সাধারণ ত্রুটি — সেশনের মতো, রিয়েল-টাইম স্টেট একাধিক উদাহরণ চালানোর সময় একটি প্রক্রিয়ার মেমোরিতে থাকতে পারে না)।

এটি একটি গুরুত্বপূর্ণ, ক্রমবর্ধমান-প্রাসঙ্গিক ক্ষমতা রিয়েল-টাইম, ইন্টারেক্টিভ অভিজ্ঞতা তৈরির জন্য যা আধুনিক ব্যবহারকারীরা প্রত্যাশা করে, এবং NestJS এর পরিষ্কার একীকরণ এটি অ্যাক্সেসযোগ্য করে তোলে যখন ফ্রেমওয়ার্কের কাঠামো পুনরায় ব্যবহার করে।