Socket.IO — چیست، کتابخانه تعامل بلادرنگ

Socket.IO چیست؟

Socket.IO — کتابخانه متن‌باز جاوااسکریپت برای ارتباط دوطرفه رویدادمحور بین کلاینت و سرور است. این کتابخانه در سال 2010 توسط توسعه‌دهنده Guillermo Rauch ساخته شد و از آن زمان به استاندارد دوفاکتو برای برنامه‌های بلادرنگ در Node.js تبدیل شده است.

برخلاف WebSocket API بومی، Socket.IO انتزاعات اضافی ارائه می‌دهد: اتاق‌ها، فضای نام، اتصال مجدد خودکار و انواع داده باینری. این کتابخانه یک پیاده‌سازی مجزای WebSocket نیست — از Engine.IO به عنوان لایه حمل‌ونقل استفاده می‌کند که ابتدا یک اتصال HTTP long-polling برقرار کرده و سپس سعی در ارتقا به WebSocket می‌کند.

طبق آمار npm (2025)، هفته‌ای بیش از 12 میلیون نسخه از بسته socket.io دانلود می‌شود که آن را به یکی از محبوب‌ترین کتابخانه‌ها در اکوسیستم Node.js تبدیل می‌کند. Socket.IO در تمام پلتفرم‌های مدرن پشتیبانی می‌شود: مرورگرها، iOS، Android، React Native و برنامه‌های دسکتاپ.

تاریخچه ایجاد و نسخه‌ها

Socket.IO نسخه 1.0 در سال 2014 منتشر شد و مفهوم فضای نام (namespaces) را معرفی کرد که امکان مالتی‌پلکس کردن چندین کانال منطقی را از طریق یک اتصال 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). سرور روی سرور HTTP(S) Node.js کار می‌کند و از Engine.IO برای مدیریت لایه حمل‌ونقل استفاده می‌کند.

در اولین اتصال، کلاینت یک درخواست HTTP به سرور ارسال می‌کند. Engine.IO پاسخ می‌دهد و یک اتصال long-polling برقرار می‌کند. پس از آن، کلاینت درخواست ارتقا پروتکل حمل‌ونقل به WebSocket را ارسال می‌کند. اگر سرور از WebSocket پشتیبانی کند، ارتقا در چارچوب یک نشست TCP انجام می‌شود. در غیر این صورت، اتصال روی long-polling باقی می‌ماند و کد برنامه نیازی به تغییر ندارد.

طبق تست‌های عملکرد Socket.IO (2024)، هنگام استفاده از WebSocket تأخیر 2–5 میلی‌ثانیه برای ارسال پیام است، در حالی که long-polling به دلیل سربار HTTP 150–300 میلی‌ثانیه اضافه می‌کند. انتخاب حمل‌ونقل برای توسعه‌دهنده شفاف است.

پروتکل 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 با نوع message و شناسه یکتا برای تأیید تحویل بسته‌بندی می‌شود.

قابلیت‌های کلیدی Socket.IO

Socket.IO مجموعه‌ای از قابلیت‌ها را ارائه می‌دهد که در WebSocket API بومی وجود ندارند و توسعه برنامه‌های بلادرنگ را بسیار ساده‌تر می‌کنند. بیایید مهم‌ترین آنها را بررسی کنیم.

اتصال مجدد خودکار — کلاینت به طور خودکار اتصال را پس از قطعی با تأخیر نمایی (100 ms، 200 ms، 400 ms... تا حداکثر) بازیابی می‌کند. طبق مستندات Socket.IO (2024)، تنظیمات retry از طریق پارامترهای reconnectionDelay و reconnectionAttempts در دسترس است. این گزینه برای برنامه‌های موبایل که اتصال ممکن است هنگام تغییر شبکه قطع شود حیاتی است.

پشتیبانی از اتاق‌ها — سرور می‌تواند سوکت‌ها را در اتاق‌ها گروه‌بندی کرده و پیام‌ها را فقط به اعضای یک اتاق خاص ارسال کند. اتاق‌ها نیاز به ایجاد صریح ندارند — با اولین عضویت سوکت ایجاد می‌شوند. اتاق‌ها در سطح پیاده‌سازی شده و بدون آداپتور ویژه بین سرورهای مختلف به اشتراک گذاشته نمی‌شوند.

فضای نام — تقسیم منطقی کانال‌های ارتباطی روی یک اتصال. به عنوان مثال، فضای /chat برای پیام‌های چت و /notifications برای اعلان‌ها. هر فضای نام دارای اتاق‌ها، middleware و هندلرهای مخصوص خود است. فضای نام‌ها از طریق یک اتصال TCP مالتی‌پلکس می‌شوند که در مصرف منابع صرفه‌جویی می‌کند.

تأیید تحویل — هنگام ارسال پیام می‌توان یک تابع callback ارسال کرد که وقتی سرور دریافت را تأیید کرد فراخوانی می‌شود. این از طریق شناسه یکتای هر بسته پیاده‌سازی شده است. مکانیزم تأیید تضمین می‌کند که پیام‌های حیاتی (مثلاً تراکنش‌های پرداخت) به گیرنده تحویل داده شده‌اند.

Socket.IO در مقابل WebSocket: مقایسه

انتخاب بین Socket.IO و WebSocket بومی به نیازهای پروژه بستگی دارد. WebSocket یک پروتکل استاندارد شده (RFC 6455) است که توسط همه مرورگرهای مدرن پشتیبانیمشود. Socket.IO کتابخانه‌ای است که از WebSocket به عنوان حمل‌ونقل استفاده می‌کند اما قابلیت‌های اضافی اضافه می‌کند.

اگر پروژه حداکثر عملکرد و حداقل اندازه کلاینت را نیاز دارد — WebSocket بومی را انتخاب کنید. اگر تحویل قابل اعتماد، گروه‌بندی و مدل رویدادی نیاز است — Socket.IO زمان توسعه را 2–3 برابر با انتزاعات آماده کاهش می‌دهد.

طبق نظرسنجی State of JS 2024، 67٪ از توسعه‌دهندگان برنامه‌های بلادرنگ Socket.IO را به دلیل راحتی API و پردازش داخلی موارد مرزی (قطع شبکه، اتصال مجدد، داده‌های باینری) ترجیح می‌دهند.

نحوه اتصال Socket.IO در پروژه

نصب Socket.IO به دو بسته نیاز دارد: سرور و کلاینت. بیایید پیکربندی پایه برای پروژه Node.js را بررسی کنیم. سرور یک سرور HTTP ایجاد می‌کند، Socket.IO را مقداردهی اولیه می‌کند و رویدادهای اتصال و قطع اتصال کلاینت‌ها را مدیریت می‌کند.

طبق مستندات Socket.IO (2024)، سرور را می‌توان بدون Express با استفاده از ماژول داخلی http راه‌اندازی کرد، اما در پروژه‌های واقعی معمولاً از Express یا Fastify برای مسیریابی درخواست‌های HTTP استفاده می‌شود.

کد سمت سرور در 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 بر اساس رویدادهای نام‌گذاری شده است. سرور و کلاینت پیام‌های متصل به یک نام رویداد مشخص را ارسال و دریافت می‌کنند. Payload می‌تواند رشته، شیء JSON یا داده‌های باینری (Buffer, ArrayBuffer, Blob) باشد.

هر رویداد از ACK (acknowledgement) — ارسال تابع callback که پس از پردازش رویداد توسط گیرنده در سمت فرستنده اجرا می‌شود — پشتیبانی می‌کند. این امکان پیاده‌سازی الگوی request-response را روی مدل رویدادی فراهم می‌کند. ACK فقط زمانی کار می‌کند که گیرنده به صراحت callback را فراخوانی کند.

طبق مستندات 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 نیاز به حل مشکل اشتراک حالت بین چندین فرآیند سرور دارد. اتاق‌ها، فضای نام و لیست سوکت‌های متصل در حافظه یک فرآیند ذخیره می‌شوند و بدون آداپتور برای سایر فرآیندها قابل مشاهده نیستند.

آداپتورهای رسمی Socket.IO: redis (از طریق Redis Pub/Sub)، mongodb (از طریق MongoDB change streams)، cluster (برای حالت چندفرآیندی Node.js cluster). آداپتور به عنوان کارگزار پیام بین نمونه‌های Socket.IO عمل می‌کند. هنگام ارسال رویداد به یک اتاق، آداپتور آن را در Redis منتشر می‌کند و همه سرورها اعلان دریافت می‌کنند.

طبق تست‌های بار Socket.IO (2024)، یک خوشه از 4 سرور با آداپتور Redis تا 400,000 اتصال همزمان را با تأخیر کمتر از 10 میلی‌ثانیه پردازش می‌کند. بدون آداپتور، حداکثر ظرفیت یک فرآیند Node.js حدود 100,000 اتصال با 1 GB حافظه است.

پیکربندی آداپتور 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، توصیه می‌شود session affinity (sticky sessions) را نیز پیکربندی کنید تا درخواست‌های یک کلاینت به یک سرور هدایت شوند، در غیر این صورت ممکن است در هر اتصال مجدد تخصیص تغییر کند.