কিভাবে 2026 সালে WebSockets এবং Node.js সহ একটি রিয়েল-টাইম অ্যাপ তৈরি করবেন

রিয়েল-টাইম বৈশিষ্ট্য — লাইভ চ্যাট, বিজ্ঞপ্তি, সহযোগী সম্পাদনা, লাইভ ড্যাশবোর্ড — ক্লায়েন্ট এবং সার্ভারের মধ্যে একটি অবিরাম সংযোগ প্রয়োজন৷ 2026 সালে,Socket.io এর মাধ্যমে WebSockets বেশিরভাগ রিয়েল-টাইম অ্যাপ্লিকেশনের জন্য সবচেয়ে ব্যবহারিক এবং ব্যাপকভাবে স্থাপন করা সমাধান হিসাবে রয়ে গেছে। এই টিউটোরিয়ালটি Redis Pub/Sub-এর মাধ্যমে স্কেলিং সহ একটি সম্পূর্ণ রিয়েল-টাইম সিস্টেম তৈরি করে।

ওয়েবসকেট বনাম এসএসই বনাম লং পোলিং

প্রকল্প সেটআপ

mkdir realtime-app && cd realtime-app
npm init -y
npm install express socket.io ioredis cors

# Frontend dependencies
npm install -D vite

সার্ভার: Express + Socket.io

// server.js
const express = require('express');
const { createServer } = require('http');
const { Server } = require('socket.io');
const Redis = require('ioredis');
const cors = require('cors');

const app    = express();
const server = createServer(app);
const io     = new Server(server, {
  cors: {
    origin:  "http://localhost:5173",   // Vite dev server
    methods: ["GET", "POST"]
  }
});

app.use(cors());
app.use(express.json());

// Redis Pub/Sub for multi-instance scaling
const pub = new Redis({ host: 'localhost', port: 6379 });
const sub = new Redis({ host: 'localhost', port: 6379 });

// ── Active users tracking ─────────────────────────────────
const activeUsers = new Map();  // socketId → { userId, username, room }

// ── Subscribe to Redis (messages from other server instances) ──
sub.subscribe('chat', 'notifications', (err, count) => {
  console.log(`Subscribed to ${count} Redis channels`);
});

sub.on('message', (channel, message) => {
  const data = JSON.parse(message);
  if (channel === 'chat') {
    io.to(data.room).emit('message', data);
  }
  if (channel === 'notifications') {
    io.to(data.userId).emit('notification', data);
  }
});

// ── Socket.io connection handler ──────────────────────────
io.on('connection', (socket) => {
  console.log(`Client connected: ${socket.id}`);

  // ── Authenticate ───────────────────────────────────────
  socket.on('authenticate', ({ userId, username }) => {
    activeUsers.set(socket.id, { userId, username });
    socket.join(userId);   // join personal room for direct notifications
    socket.emit('authenticated', { userId, socketId: socket.id });
    console.log(`User authenticated: ${username} (${userId})`);
  });

  // ── Join chat room ─────────────────────────────────────
  socket.on('join_room', ({ roomId }) => {
    const user = activeUsers.get(socket.id);
    if (!user) return socket.emit('error', 'Not authenticated');

    socket.join(roomId);
    activeUsers.set(socket.id, { ...user, room: roomId });

    // Notify others in room
    socket.to(roomId).emit('user_joined', {
      userId:   user.userId,
      username: user.username,
      roomId,
      timestamp: Date.now()
    });

    console.log(`${user.username} joined room: ${roomId}`);
  });

  // ── Send message ───────────────────────────────────────
  socket.on('send_message', async ({ roomId, content }) => {
    const user = activeUsers.get(socket.id);
    if (!user) return socket.emit('error', 'Not authenticated');

    const message = {
      id:        `msg_${Date.now()}_${Math.random().toString(36).slice(2)}`,
      userId:    user.userId,
      username:  user.username,
      content,
      room:      roomId,
      timestamp: Date.now()
    };

    // Publish to Redis so ALL server instances receive it
    pub.publish('chat', JSON.stringify(message));

    // TODO: persist to database here
    // await db.messages.create({ data: message });
  });

  // ── Typing indicator ───────────────────────────────────
  socket.on('typing', ({ roomId, isTyping }) => {
    const user = activeUsers.get(socket.id);
    if (!user) return;
    socket.to(roomId).emit('user_typing', {
      userId:   user.userId,
      username: user.username,
      isTyping
    });
  });

  // ── Disconnect ─────────────────────────────────────────
  socket.on('disconnect', () => {
    const user = activeUsers.get(socket.id);
    if (user?.room) {
      socket.to(user.room).emit('user_left', {
        userId:   user.userId,
        username: user.username
      });
    }
    activeUsers.delete(socket.id);
    console.log(`Client disconnected: ${socket.id}`);
  });
});

// ── REST API: send notification from backend ──────────────
app.post('/notify', (req, res) => {
  const { userId, type, message } = req.body;
  pub.publish('notifications', JSON.stringify({ userId, type, message, timestamp: Date.now() }));
  res.json({ ok: true });
});

server.listen(3001, () => console.log('Server running on port 3001'));

ক্লায়েন্ট: প্রতিক্রিয়া + Socket.io

// hooks/useSocket.ts
import { useEffect, useRef, useState } from 'react';
import { io, Socket } from 'socket.io-client';

export function useSocket(userId: string, username: string) {
  const socket  = useRef<Socket | null>(null);
  const [connected, setConnected] = useState(false);
  const [messages, setMessages]   = useState<Message[]>([]);
  const [notifications, setNotifications] = useState<Notification[]>([]);
  const [typingUsers, setTypingUsers]     = useState<Set<string>>(new Set());

  useEffect(() => {
    socket.current = io('http://localhost:3001');

    socket.current.on('connect', () => {
      setConnected(true);
      socket.current!.emit('authenticate', { userId, username });
    });

    socket.current.on('message', (msg: Message) => {
      setMessages(prev => [...prev, msg]);
    });

    socket.current.on('notification', (notif: Notification) => {
      setNotifications(prev => [notif, ...prev]);
    });

    socket.current.on('user_typing', ({ username: typer, isTyping }) => {
      setTypingUsers(prev => {
        const next = new Set(prev);
        isTyping ? next.add(typer) : next.delete(typer);
        return next;
      });
    });

    socket.current.on('disconnect', () => setConnected(false));

    return () => { socket.current?.disconnect(); };
  }, [userId, username]);

  const joinRoom  = (roomId: string) => socket.current?.emit('join_room', { roomId });
  const sendMessage = (roomId: string, content: string) =>
    socket.current?.emit('send_message', { roomId, content });
  const setTyping = (roomId: string, isTyping: boolean) =>
    socket.current?.emit('typing', { roomId, isTyping });

  return { connected, messages, notifications, typingUsers, joinRoom, sendMessage, setTyping };
}

রেডিস পাব/সাবের সাথে স্কেলিং

সার্ভার কোডে Redis Pub/Sub প্যাটার্ন অনুভূমিক স্কেলিং করার অনুমতি দেয়: যখন একটি Node.js উদাহরণে একটি বার্তা আসে, তখন এটি Redis-এ প্রকাশ করে। অন্যান্য সমস্ত দৃষ্টান্ত (Redis-এ সদস্যতা) এটি গ্রহণ করে এবং তাদের সংযুক্ত ক্লায়েন্টদের কাছে নির্গত করে। এর মানে হল আপনি একটি লোড ব্যালেন্সারের পিছনে 10টি Node.js ইন্সট্যান্স চালাতে পারেন এবং বার্তাগুলি সমস্ত ব্যবহারকারীর কাছে পৌঁছায়, তারা যে উদাহরণের সাথে সংযুক্ত থাকুক না কেন।

# Run multiple instances
PORT=3001 node server.js &
PORT=3002 node server.js &
PORT=3003 node server.js &

# Nginx load balancer with sticky sessions (WebSocket requirement)
upstream websocket {
    ip_hash;  # sticky sessions - same client hits same server
    server localhost:3001;
    server localhost:3002;
    server localhost:3003;
}

প্রায়শই জিজ্ঞাসিত প্রশ্ন

প্রশ্ন: Socket.io বনাম নেটিভ ওয়েবসকেট API?
উত্তর: Socket.io যোগ করে: স্বয়ংক্রিয় পুনঃসংযোগ, রুম/নেমস্পেস, লং-পোলিং-এ ফলব্যাক, এবং ইভেন্ট-ভিত্তিক API। নেটিভ ওয়েবসকেট নিম্ন স্তরের। উত্পাদনের জন্য Socket.io ব্যবহার করুন — পুনঃসংযোগের যুক্তি একাই কাজের ঘন্টা বাঁচায়।

প্রশ্ন: Node.js কতগুলি সমবর্তী ওয়েবসকেট সংযোগগুলি পরিচালনা করতে পারে?
উত্তর: 8GB RAM সহ একটি একক 4-কোর সার্ভারে, বার্তা ফ্রিকোয়েন্সির উপর নির্ভর করে 10,000-50,000 সমবর্তী সংযোগ আশা করুন। Redis ক্লাস্টারিং স্কেল সহ Socket.io একাধিক সার্ভার জুড়ে লক্ষ লক্ষ।

প্রশ্নঃ ওয়েবসকেট কি ফায়ারওয়াল এবং প্রক্সির মাধ্যমে কাজ করে?
উত্তর: বেশিরভাগ আধুনিক নেটওয়ার্ক পোর্ট 443 (HTTPS/WSS) এ ওয়েবসকেটের অনুমতি দেয়। যদি WebSocket ব্লক করা থাকে তাহলে Socket.io লং-পোলিংয়ে ফিরে আসে। উৎপাদনে WSS (নিরাপদ ওয়েবসকেট) ব্যবহার করুন।

প্রশ্ন: আমি কীভাবে চ্যাট বার্তাগুলি চালিয়ে যেতে পারি?
উত্তর: PostgreSQL বা MongoDB-তে স্টোর করুন। দ্রুত পুনরুদ্ধারের জন্য (রুমআইডি, টাইমস্ট্যাম্প) দ্বারা সূচক। শেষ 50টি বার্তা লোড করুন যখন একজন ব্যবহারকারী REST API এর মাধ্যমে একটি রুমে যোগদান করেন; WebSocket এর মাধ্যমে নতুন বার্তা স্ট্রিম করুন।

প্রশ্ন: একটি পরিচালিত WebSocket পরিষেবা বিকল্প আছে?
উত্তর: Pusher, Ably, এবং AWS API গেটওয়ে ওয়েবসকেট বিকল্পগুলি পরিচালিত হয়৷ উচ্চ খরচ কিন্তু কোন পরিকাঠামো ব্যবস্থাপনা. ছোট আকারের জন্য বা যখন বিকাশকারীর সময় বাধাগ্রস্ত হয় তখন ভাল।

উপসংহার

Socket.io এবং Redis Pub/Sub-এর সাথে WebSockets হল 2026 সালে রিয়েল-টাইম অ্যাপ্লিকেশনের জন্য প্রমাণিত, মাপযোগ্য আর্কিটেকচার। এই টিউটোরিয়ালের সার্ভার কোডটি একক উদাহরণে হাজার হাজার সমসাময়িক ব্যবহারকারীকে পরিচালনা করে এবং চাহিদা বাড়লে Redis এর মাধ্যমে অনুভূমিকভাবে স্কেল করে। একটি একক উদাহরণ দিয়ে শুরু করুন, যখন আপনাকে একটি সার্ভারের বাইরে স্কেল করতে হবে তখন Redis যোগ করুন এবং অপারেশনাল ওভারহেড সমস্যা হলে শুধুমাত্র পরিচালিত ওয়েবসকেট পরিষেবাগুলিতে যান৷