WebSockets ও রিয়েল-টাইম কমিউনিকেশন

১ · রিকোয়েস্ট-রেসপন্সের সীমাবদ্ধতা

L06-এ দেখা REST-এর মতো সাধারণ HTTP মডেলে ক্লায়েন্ট সবসময় প্রথমে রিকোয়েস্ট পাঠায়, সার্ভার একটি রেসপন্স দেয়, এবং কানেকশন বন্ধ হয়ে যায় (বা পরবর্তী রিকোয়েস্টের জন্য অপেক্ষা করে)। এই মডেলে সার্ভার নিজে থেকে ক্লায়েন্টকে কিছু পাঠাতে পারে না — ক্লায়েন্টকেই জিজ্ঞাসা করতে হয়। কিন্তু চ্যাট অ্যাপ, লাইভ স্কোরবোর্ড বা শেয়ার মার্কেট টিকারের মতো সিস্টেমে সার্ভারের কাছেই নতুন তথ্য আগে চলে আসে — সার্ভারকে নিজে থেকে ক্লায়েন্টকে জানাতে দেওয়া দরকার।

এই সমস্যার প্রথম সমাধান ছিল polling — ক্লায়েন্ট প্রতি কয়েক সেকেন্ডে বারবার সার্ভারকে জিজ্ঞাসা করে "নতুন কিছু আছে কি?" — বেশিরভাগ সময় উত্তর "না" হয়, তাই প্রচুর অপ্রয়োজনীয় রিকোয়েস্ট নষ্ট হয়। এরপর এলো long-polling — ক্লায়েন্ট একটি রিকোয়েস্ট পাঠায় এবং সার্ভার তা খোলা রাখে যতক্ষণ না নতুন ডেটা আসে (বা টাইমআউট হয়), তারপর রেসপন্স দিয়ে ক্লায়েন্ট সাথে সাথে আরেকটি নতুন রিকোয়েস্ট পাঠায়। এটি পোলিং-এর চেয়ে ভালো কিন্তু এখনও প্রতিটি "চক্র"-এ একটি নতুন HTTP কানেকশন খোলার ওভারহেড আছে।

২ · WebSocket কী এবং কীভাবে শুরু হয়

WebSocketWebSocketএকটি একক TCP কানেকশনের উপর তৈরি ফুল-ডুপ্লেক্স (দুদিক থেকেই একসাথে) যোগাযোগ প্রোটোকল, যা একটি HTTP "Upgrade" হ্যান্ডশেক দিয়ে শুরু হয়ে সার্ভার ও ক্লায়েন্ট উভয়কেই যেকোনো সময় বার্তা পাঠানোর সুযোগ দেয়। একটি সাধারণ HTTP রিকোয়েস্ট হিসেবেই শুরু হয় — ক্লায়েন্ট একটি বিশেষ হেডার পাঠায় (Connection: Upgrade, Upgrade: websocket)। সার্ভার রাজি হলে 101 Switching Protocols রেসপন্স দেয়, এবং এরপর সেই একই TCP কানেকশনটি একটি WebSocket কানেকশনে "রূপান্তরিত" হয়ে যায় — আর নতুন করে HTTP হেডার/রিকোয়েস্ট লাগে না। এখন থেকে সার্ভার ও ক্লায়েন্ট উভয়ই এই একই কানেকশনে যখন খুশি বার্তা পাঠাতে পারে — এটাই ফুল-ডুপ্লেক্স।

৩ · ব্যবহারিক ক্ষেত্র

• চ্যাট/মেসেজিং — নতুন মেসেজ এলে সাথে সাথে সব অংশগ্রহণকারীর কাছে পৌঁছাতে হয় (L45-এ পূর্ণ কেস স্টাডি)।
• লাইভ নোটিফিকেশন — লাইক, কমেন্ট, ফলো-এর তাৎক্ষণিক আপডেট (L51-এর ক্যাপস্টোনে এই বিষয়ে ফিরে আসব)।
• কোলাবোরেটিভ এডিটিং — একই ডকুমেন্টে একাধিক ইউজার একসাথে টাইপ করলে সবার স্ক্রিনে সাথে সাথে আপডেট।
• লাইভ স্কোর/টিকার — শেয়ার বাজারের দাম বা খেলার স্কোর প্রতি মুহূর্তে আপডেট হওয়া।

৪ · স্কেলিং চ্যালেঞ্জ — কানেকশন স্টেটফুল

একটি সাধারণ স্টেটলেস HTTP রিকোয়েস্ট (L12-এ বিস্তারিত) যেকোনো সার্ভার ইনস্ট্যান্স হ্যান্ডল করতে পারে, কারণ প্রতিটি রিকোয়েস্ট স্বতন্ত্র। কিন্তু একটি WebSocket কানেকশন দীর্ঘস্থায়ী — একবার ক্লায়েন্ট সার্ভার A-এর সাথে কানেকশন খুললে, সেই নির্দিষ্ট কানেকশনটি সার্ভার A-এর মেমরিতেই থাকে। এখন সমস্যা — ইউজার B যদি ইউজার A-কে একটি মেসেজ পাঠাতে চায়, কিন্তু ইউজার A-এর কানেকশন সার্ভার A-তে আছে, আর ইউজার B-এর রিকোয়েস্ট লোড ব্যালেন্সার (L11) সার্ভার C-তে পাঠিয়েছে — সার্ভার C কীভাবে জানবে ইউজার A কোথায় আছে?

সমাধান — প্রতিটি সার্ভার ইনস্ট্যান্স একটি শেয়ার্ড pub/sub ব্যাকএন্ডে (যেমন Redis Pub/Sub, M6/L22-এ বিস্তারিত) পাবলিশ করে, এবং যে সার্ভার প্রাপকের কানেকশন ধরে আছে সে সেই টপিক সাবস্ক্রাইব করে বার্তাটি নিজের ধরে রাখা কানেকশনে ফরোয়ার্ড করে। এভাবে যেকোনো সার্ভার যেকোনো ক্লায়েন্টের কাছে বার্তা পৌঁছাতে পারে, কানেকশন আসলে কোন সার্ভারে আছে তা নির্বিশেষে। বিকল্প হিসেবে "sticky sessions" (একই ইউজারকে সবসময় একই সার্ভারে পাঠানো) ব্যবহার করা যায়, কিন্তু সেটি লোড ব্যালেন্সিং-এর নমনীয়তা কমিয়ে দেয়।

৫ · কোড দিয়ে দেখা — একাধিক ক্লায়েন্টে Broadcast

নিচে একটি সরল broadcast(message, subscribers) ফাংশন — এটি একটি WebSocket সার্ভার একই সময়ে একাধিক কানেক্টেড ক্লায়েন্টকে কীভাবে একটি বার্তা পাঠায় তার মূল ধারণাটি সিমুলেট করে (real pub/sub ব্যাকএন্ড ছাড়াই, শুধু লজিকটি বোঝার জন্য)।

subscribers = ["client_1", "client_2", "client_3", "client_4"]

def broadcast(message, subscribers):
    delivered = []
    for client in subscribers:
        # বাস্তবে এখানে প্রতিটি ক্লায়েন্টের খোলা WebSocket কানেকশনে ডেটা পাঠানো হতো
        delivered.append(client)
        print(f"  পাঠানো হলো -> {client}: \"{message}\"")
    return delivered

print("=== broadcast: নতুন চ্যাট মেসেজ ===")
delivered = broadcast("রহিম: হ্যালো সবাই!", subscribers)
print(f"\nমোট {len(delivered)}টি ক্লায়েন্ট মেসেজ পেয়েছে: {delivered}")

# client_3 চ্যাট রুম থেকে বেরিয়ে গেল (WebSocket কানেকশন বন্ধ, unsubscribe)
subscribers.remove("client_3")

print("\n=== client_3 চলে যাওয়ার পর আবার broadcast ===")
delivered_2 = broadcast("করিম: client_3 কোথায় গেল?", subscribers)
print(f"\nমোট {len(delivered_2)}টি ক্লায়েন্ট মেসেজ পেয়েছে: {delivered_2}")
print(f"client_3 এবার মেসেজ পেয়েছে কি? {'client_3' in delivered_2}")