Socket.IO — यह क्या है, रियल-टाइम इंटरैक्शन के लिए लाइब्रेरी

Socket.IO क्या है?

Socket.IO एक ओपन-सोर्स JavaScript लाइब्रेरी है जो क्लाइंट और सर्वर के बीच द्विदिश ईवेंट-संचालित संचार के लिए है। इसे 2010 में डेवलपर Guillermo Rauch द्वारा बनाया गया था और तब से यह Node.js पर रियल-टाइम अनुप्रयोगों के लिए डी-फैक्टो मानक बन गया है।

नेटिव WebSocket API के विपरीत, Socket.IO अतिरिक्त एब्स्ट्रैक्शन प्रदान करता है: कमरे, नामस्थान, स्वचालित पुनःकनेक्शन और बाइनरी डेटा प्रकार। लाइब्रेरी WebSocket का अलग कार्यान्वयन नहीं है — यह ट्रांसपोर्ट लेयर के रूप में Engine.IO का उपयोग करती है, जो पहले HTTP long-polling कनेक्शन स्थापित करती है, फिर WebSocket में अपग्रेड करने का प्रयास करती है।

npm आँकड़े (2025) के अनुसार, साप्ताहिक रूप से socket.io पैकेज की 12 मिलियन से अधिक प्रतियाँ डाउनलोड की जाती हैं, जो इसे Node.js इकोसिस्टम में सबसे लोकप्रिय लाइब्रेरीज़ में से एक बनाता है। Socket.IO सभी आधुनिक प्लेटफ़ॉर्म पर समर्थित है: ब्राउज़र, iOS, Android, React Native और डेस्कटॉप अनुप्रयोग।

इतिहास और संस्करण

Socket.IO संस्करण 1.0 2014 में जारी किया गया था और इसने नामस्थान की अवधारणा पेश की, जो एक TCP कनेक्शन पर कई तार्किक चैनलों को मल्टीप्लेक्स करने की अनुमति देते हैं। संस्करण 2.0 (2017) ने बाइनरी डेटा के लिए समर्थन जोड़ा और पार्सिंग प्रदर्शन में सुधार किया। वर्तमान संस्करण 4.x (2020–2025) में TypeScript के लिए पूर्ण समर्थन, स्केलिंग के लिए प्रमुख एडेप्टर मोड और बेहतर बैकवर्ड संगतता शामिल है।

प्रत्येक प्रमुख रिलीज़ API बैकवर्ड संगतता बनाए रखती है — एक socket.io@2 क्लाइंट एक विशेष संगतता मोड के माध्यम से socket.io@4 सर्वर से कनेक्ट हो सकता है। यह लंबे समय तक चलने वाली परियोजनाओं के लिए महत्वपूर्ण है जहाँ क्लाइंट-साइड अपग्रेड धीरे-धीरे होते हैं।

Socket.IO कैसे काम करता है

Socket.IO आर्किटेक्चर में दो घटक होते हैं: सर्वर मॉड्यूल (npm पैकेज socket.io) और क्लाइंट मॉड्यूल (npm पैकेज socket.io-client)। सर्वर Node.js HTTP(S) सर्वर के ऊपर चलता है और ट्रांसपोर्ट लेयर को प्रबंधित करने के लिए Engine.IO का उपयोग करता है।

प्रारंभिक कनेक्शन पर, क्लाइंट सर्वर को HTTP अनुरोध भेजता है। Engine.IO प्रतिक्रिया देता है और एक long-polling कनेक्शन स्थापित करता है। उसके बाद, क्लाइंट ट्रांसपोर्ट प्रोटोकॉल को WebSocket में अपग्रेड करने का अनुरोध भेजता है। यदि सर्वर WebSocket का समर्थन करता है, तो अपग्रेड एक TCP सत्र के भीतर होता है। यदि नहीं, तो कनेक्शन long-polling पर बना रहता है और एप्लिकेशन कोड में कोई बदलाव की आवश्यकता नहीं होती।

Socket.IO प्रदर्शन परीक्षण (2024) के अनुसार, WebSocket का उपयोग करते समय विलंबता 2–5 ms प्रति संदेश होती है, जबकि long-polling HTTP ओवरहेड के कारण 150–300 ms जोड़ता है। ट्रांसपोर्ट का चयन डेवलपर के लिए पारदर्शी है।

Engine.IO प्रोटोकॉल

Engine.IO निम्न-स्तरीय ट्रांसपोर्ट लेयर है जिस पर Socket.IO बनाया गया है। यह कनेक्शन स्थापना, ट्रांसपोर्ट चयन, heartbeat (ping/pong) और कनेक्शन समाप्ति को संभालता है। Engine.IO पैकेट के मुख्य प्रकार हैं: open (आरंभीकरण), close (समापन), ping/pong (जीवित रखना), upgrade (ट्रांसपोर्ट परिवर्तन) और message (डेटा)।

Socket.IO Engine.IO के ऊपर अपना ईवेंट-संचालित मॉडल बनाता है — डेवलपर इसी के साथ काम करता है। प्रत्येक Socket.IO संदेश वितरण पुष्टि के लिए एक अद्वितीय पहचानकर्ता के साथ Engine.IO पैकेट में लपेटा जाता है।

Socket.IO की मुख्य विशेषताएँ

Socket.IO ऐसी सुविधाओं का एक सेट प्रदान करता है जो नेटिव WebSocket API में मौजूद नहीं हैं और रियल-टाइम अनुप्रयोगों के विकास को काफी आसान बनाती हैं। आइए मुख्य विशेषताओं पर नज़र डालें।

स्वचालित पुनःकनेक्शन — क्लाइंट डिस्कनेक्ट होने पर एक्सपोनेंशियल बैकऑफ़ (100 ms, 200 ms, 400 ms... अधिकतम तक) के साथ स्वचालित रूप से कनेक्शन बहाल करता है। Socket.IO दस्तावेज़ीकरण (2024) के अनुसार, पुनःप्रयास सेटिंग्स reconnectionDelay और reconnectionAttempts पैरामीटर के माध्यम से उपलब्ध हैं। यह विकल्प मोबाइल अनुप्रयोगों के लिए महत्वपूर्ण है जहाँ नेटवर्क बदलने पर कनेक्शन बाधित हो सकता है।

कक्ष (रूम) समर्थन — सर्वर सॉकेट को कमरों में समूहित कर सकता है और केवल किसी विशिष्ट कक्ष के सदस्यों को संदेश भेज सकता है। कमरों को स्पष्ट निर्माण की आवश्यकता नहीं होती — वे पहले सॉकेट के जुड़ने पर बनाए जाते हैं। कमरे प्रक्रिया स्तर पर कार्यान्वित होते हैं और बिना किसी विशेष एडेप्टर के विभिन्न सर्वरों के बीच साझा नहीं होते।

नामस्थान — एक कनेक्शन पर संचार चैनलों का तार्किक विभाजन। उदाहरण के लिए, चैट संदेशों के लिए /chat नामस्थान और सूचनाओं के लिए /notifications। प्रत्येक नामस्थान के अपने कमरे, मिडलवेयर और हैंडलर होते हैं। नामस्थान एक TCP कनेक्शन पर मल्टीप्लेक्स होते हैं, जिससे संसाधनों की बचत होती है।

वितरण पुष्टि — संदेश भेजते समय, एक कॉलबैक फ़ंक्शन पास किया जा सकता है जो सर्वर द्वारा प्राप्ति की पुष्टि करने पर कॉल किया जाएगा। यह प्रत्येक पैकेट के लिए एक अद्वितीय पहचानकर्ता के माध्यम से कार्यान्वित किया जाता है। पुष्टि तंत्र सुनिश्चित करता है कि महत्वपूर्ण संदेश (जैसे भुगतान लेन-देन) प्राप्तकर्ता तक पहुँचाए जाएँ।

Socket.IO बनाम WebSocket: तुलना

Socket.IO और नेटिव WebSocket के बीच चयन परियोजना की आवश्यकताओं पर निर्भर करता है। WebSocket एक मानकीकृत प्रोटोकॉल (RFC 6455) है जो सभी आधुनिक ब्राउज़रों द्वारा समर्थित है। Socket.IO एक लाइब्रेरी है जो WebSocket को ट्रांसपोर्ट के रूप में उपयोग करती है लेकिन अतिरिक्त सुविधाएँ जोड़ती है।

यदि आपकी परियोजना को अधिकतम प्रदर्शन और न्यूनतम क्लाइंट आकार की आवश्यकता है — नेटिव WebSocket चुनें। यदि आपको विश्वसनीय वितरण, समूहीकरण और ईवेंट-आधारित मॉडल की आवश्यकता है — Socket.IO तैयार एब्स्ट्रैक्शन के कारण विकास समय को 2–3 गुना कम कर देगा।

State of JS 2024 सर्वेक्षण के अनुसार, 67% रियल-टाइम एप्लिकेशन डेवलपर सुविधाजनक API और सीमांत मामलों (नेटवर्क डिस्कनेक्शन, पुनःकनेक्शन, बाइनरी डेटा) के अंतर्निहित प्रबंधन के कारण Socket.IO पसंद करते हैं।

प्रोजेक्ट में Socket.IO कैसे कनेक्ट करें

Socket.IO स्थापित करना के लिए दो पैकेजों की आवश्यकता है: सर्वर-साइड और क्लाइंट-साइड। आइए Node.js प्रोजेक्ट के लिए बुनियादी सेटअप देखें। सर्वर एक HTTP सर्वर बनाता है, Socket.IO को प्रारंभ करता है और क्लाइंट कनेक्शन और डिस्कनेक्शन ईवेंट को संभालता है।

Socket.IO दस्तावेज़ीकरण (2024) के अनुसार, सर्वर को अंतर्निहित http मॉड्यूल का उपयोग करके Express के बिना शुरू किया जा सकता है, लेकिन वास्तविक परियोजनाओं में HTTP अनुरोध रूटिंग के लिए आमतौर पर Express या Fastify का उपयोग किया जाता है।

Node.js में सर्वर-साइड कोड

const express = require('express');
const http = require('http');
const Server = require('socket.io');

const app = express();
const server = http.createServer(app);
const io = new Server(server, {
    cors: { origin: '*' }
});

io.on('connection', (socket) => {
    console.log('क्लाइंट कनेक्ट हुआ:', socket.id);

    socket.emit('welcome', { message: 'Hello from server' });

    socket.on('disconnect', () => {
        console.log('क्लाइंट डिस्कनेक्ट हुआ');
    });
});

server.listen(3000, () => {
    console.log('सर्वर पोर्ट 3000 पर चल रहा है');
});

ब्राउज़र में क्लाइंट-साइड कोड

import { io } from 'socket.io-client';

const socket = io('http://localhost:3000', {
    transports: ['websocket', 'polling'],
    reconnectionDelay: 1000
});

socket.on('welcome', (data) => {
    console.log(data.message);
});

socket.emit('chat message', {
    user: 'Alice',
    text: 'Hello everyone!'
});

Socket.IO में ईवेंट और कमरे

Socket.IO ईवेंट मॉडल नामित ईवेंट पर आधारित है। सर्वर और क्लाइंट एक विशिष्ट ईवेंट नाम से बंधे संदेश भेजते और प्राप्त करते हैं। पेलोड एक स्ट्रिंग, JSON ऑब्जेक्ट या बाइनरी डेटा (Buffer, ArrayBuffer, Blob) हो सकता है।

प्रत्येक ईवेंट ACK (पावती) का समर्थन करता है — एक कॉलबैक फ़ंक्शन पास करना जो रिसीवर द्वारा ईवेंट प्रसंस्करण के बाद प्रेषक की ओर निष्पादित होता है। यह ईवेंट मॉडल के ऊपर अनुरोध-प्रतिक्रिया पैटर्न लागू करने की अनुमति देता है। ACK तभी काम करता है जब रिसीवर स्पष्ट रूप से कॉलबैक को कॉल करता है।

Socket.IO दस्तावेज़ीकरण (2024) के अनुसार, इष्टतम प्रदर्शन के लिए एक संदेश का अधिकतम आकार 1 MB से अधिक नहीं होना चाहिए। बड़े संदेशों को टुकड़ों में विभाजित किया जाना चाहिए या एक अलग चैनल के माध्यम से भेजा जाना चाहिए।

कमरों के साथ काम करना

io.on('connection', (socket) => {
    socket.join('room-1');

    socket.to('room-1').emit('user joined', {
        userId: socket.id
    });

    io.to('room-1').emit('message', {
        text: 'Broadcast to room'
    });

    socket.leave('room-1');
});

Socket.IO की स्केलिंग

क्षैतिज स्केलिंग के लिए कई सर्वर प्रक्रियाओं के बीच स्थिति साझा करने की समस्या को हल करने की आवश्यकता होती है। कमरे, नामस्थान और कनेक्टेड सॉकेट की सूची एक प्रक्रिया की मेमोरी में संग्रहीत होती है और बिना एडेप्टर के अन्य प्रक्रियाओं को दिखाई नहीं देती।

आधिकारिक Socket.IO एडेप्टर: redis (Redis Pub/Sub के माध्यम से), mongodb (MongoDB change streams के माध्यम से), cluster (Node.js क्लस्टर मल्टीप्रोसेस मोड के लिए)। एडेप्टर Socket.IO इंस्टेंस के बीच संदेश ब्रोकर के रूप में कार्य करता है। जब किसी कक्ष में कोई ईवेंट भेजा जाता है, तो एडेप्टर इसे Redis में प्रकाशित करता है और सभी सर्वरों को सूचना मिलती है।

Socket.IO लोड टेस्टिंग (2024) के अनुसार, Redis एडेप्टर के साथ 4 सर्वरों का क्लस्टर 10 ms से कम विलंबता के साथ 400,000 समवर्ती कनेक्शन तक संभालता है। एडेप्टर के बिना, एक Node.js प्रक्रिया की अधिकतम क्षमता 1 GB मेमोरी के साथ लगभग 100,000 कनेक्शन है।

Redis एडेप्टर कॉन्फ़िगरेशन

const Server = require('socket.io');
const RedisAdapter = require('@socket.io/redis-adapter');
const Redis = require('ioredis');

const pubClient = new Redis({ host: 'localhost', port: 6379 });
const subClient = pubClient.duplicate();
const io = new Server(server);
io.adapter(RedisAdapter(pubClient, subClient));

Kubernetes या Docker Swarm का उपयोग करते समय, सत्र आत्मीयता (स्टिकी सेशन) कॉन्फ़िगर करने की अनुशंसा की जाती है ताकि एक ही क्लाइंट के अनुरोध एक ही सर्वर पर जाएँ; अन्यथा प्रत्येक पुनःकनेक्शन पर असाइनमेंट बदल सकता है।