Socket.IO — τι είναι, βιβλιοθήκη για αλληλεπίδραση σε πραγματικό χρόνο

Τι είναι το Socket.IO;

Το Socket.IO είναι μια βιβλιοθήκη JavaScript ανοιχτού κώδικα για αμφίδρομη επικοινωνία βασισμένη σε συμβάντα μεταξύ πελάτη και διακομιστή. Δημιουργήθηκε το 2010 από τον προγραμματιστή Guillermo Rauch και από τότε έχει γίνει το de facto πρότυπο για εφαρμογές σε πραγματικό χρόνο στο 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 ms ανά μετάδοση μηνύματος, ενώ το long-polling προσθέτει 150–300 ms λόγω επιβάρυνσης HTTP. Η επιλογή μεταφοράς είναι διαφανής για τον προγραμματιστή.

Πρωτόκολλο Engine.IO

Το Engine.IO είναι το χαμηλού επιπέδου επίπεδο μεταφοράς πάνω στο οποίο είναι χτισμένο το Socket.IO. Είναι υπεύθυνο για τη δημιουργία σύνδεσης, την επιλογή μεταφοράς, τον έλεγχο ζωής (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), οι ρυθμίσεις επαναπροσπάθειας είναι διαθέσιμες μέσω των παραμέτρων reconnectionDelay και reconnectionAttempts. Αυτή η επιλογή είναι κρίσιμη για εφαρμογές κινητών όπου η σύνδεση μπορεί να διακοπεί κατά την αλλαγή δικτύου.

Υποστήριξη δωματίων — ο διακομιστής μπορεί να ομαδοποιεί sockets σε δωμάτια και να στέλνει μηνύματα μόνο στα μέλη ενός συγκεκριμένου δωματίου. Τα δωμάτια δεν απαιτούν ρητή δημιουργία — δημιουργούνται κατά την πρώτη είσοδο ενός socket. Τα δωμάτια υλοποιούνται σε επίπεδο διεργασίας και δεν διαμοιράζονται μεταξύ διαφορετικών διακομιστών χωρίς ειδικό προσαρμογέα.

Χώροι ονομάτων — λογικός διαχωρισμός καναλιών επικοινωνίας σε μία σύνδεση. Για παράδειγμα, ο χώρος ονομάτων /chat για μηνύματα συνομιλίας και /notifications για ειδοποιήσεις. Κάθε χώρος ονομάτων έχει τα δικά του δωμάτια, ενδιάμεσο λογισμικό και χειριστές. Οι χώροι ονομάτων πολυπλέκονται μέσω μίας σύνδεσης TCP, εξοικονομώντας πόρους.

Επιβεβαίωση παράδοσης — κατά την αποστολή μηνύματος μπορεί να μεταβιβαστεί μια συνάρτηση callback που θα κληθεί όταν ο διακομιστής επιβεβαιώσει τη λήψη. Αυτό υλοποιείται μέσω μοναδικού αναγνωριστικού κάθε πακέτου. Ο μηχανισμός επιβεβαίωσης εγγυάται ότι τα κρίσιμα μηνύματα (π.χ. συναλλαγές πληρωμής) έχουν παραδοθεί στον παραλήπτη.

Socket.IO vs 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 βασίζεται σε ονομασμένα συμβάντα. Ο διακομιστής και ο πελάτης στέλνουν και λαμβάνουν μηνύματα συνδεδεμένα με ένα συγκεκριμένο όνομα συμβάντος. Το φορτίο μπορεί να είναι συμβολοσειρά, αντικείμενο 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 απαιτεί επίλυση του προβλήματος καταμερισμού κατάστασης μεταξύ πολλαπλών διεργασιών διακομιστή. Τα δωμάτια, οι χώροι ονομάτων και η λίστα των συνδεδεμένων sockets αποθηκεύονται στη μνήμη μιας διεργασίας και δεν είναι ορατά σε άλλες διεργασίες χωρίς προσαρμογέα.

Επίσημοι προσαρμογείς 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 ms. Χωρίς προσαρμογέα, η μέγιστη χωρητικότητα μιας διεργασίας 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), έτσι ώστε τα αιτήματα από τον ίδιο πελάτη να καταλήγουν στον ίδιο διακομιστή, διαφορετικά η ανάθεση μπορεί να αλλάξει σε κάθε επανασύνδεση.