Socket.IO — thư viện tương tác thời gian thực là gì

Socket.IO là gì?

Socket.IO là thư viện JavaScript mã nguồn mở để giao tiếp hai chiều dựa trên sự kiện giữa máy khách và máy chủ. Nó được tạo ra vào năm 2010 bởi nhà phát triển Guillermo Rauch và từ đó đã trở thành tiêu chuẩn thực tế cho các ứng dụng thời gian thực trên Node.js.

Không giống như API WebSocket gốc, Socket.IO cung cấp các trừu tượng bổ sung: phòng, không gian tên, tự động kết nối lại và kiểu dữ liệu nhị phân. Thư viện này không phải là một triển khai riêng biệt của WebSocket — nó sử dụng Engine.IO làm lớp truyền tải, lớp này đầu tiên thiết lập kết nối HTTP long-polling, sau đó thử nâng cấp lên WebSocket.

Theo thống kê npm (2025), hơn 12 triệu bản sao của gói socket.io được tải xuống hàng tuần, khiến nó trở thành một trong những thư viện phổ biến nhất trong hệ sinh thái Node.js. Socket.IO được hỗ trợ trên tất cả các nền tảng hiện đại: trình duyệt, iOS, Android, React Native và ứng dụng máy tính để bàn.

Lịch sử và phiên bản

Socket.IO phiên bản 1.0 được phát hành vào năm 2014 và giới thiệu khái niệm không gian tên, cho phép ghép kênh nhiều kênh logic qua một kết nối TCP duy nhất. Phiên bản 2.0 (2017) đã thêm hỗ trợ cho dữ liệu nhị phân và cải thiện hiệu suất phân tích cú pháp. Phiên bản hiện tại 4.x (2020–2025) bao gồm hỗ trợ đầy đủ TypeScript, chế độ bộ điều hợp chính để mở rộng quy mô và khả năng tương thích ngược được cải thiện.

Mỗi bản phát hành chính duy trì khả năng tương thích ngược API — máy khách socket.io@2 có thể kết nối với máy chủ socket.io@4 thông qua chế độ tương thích đặc biệt. Điều này quan trọng đối với các dự án dài hạn, nơi việc nâng cấp phía máy khách diễn ra dần dần.

Socket.IO hoạt động như thế nào

Kiến trúc Socket.IO bao gồm hai thành phần: mô-đun máy chủ (gói npm socket.io) và mô-đun máy khách (gói npm socket.io-client). Máy chủ chạy trên máy chủ HTTP(S) Node.js và sử dụng Engine.IO để quản lý lớp truyền tải.

Khi kết nối ban đầu, máy khách gửi yêu cầu HTTP đến máy chủ. Engine.IO phản hồi và thiết lập kết nối long-polling. Sau đó, máy khách gửi yêu cầu nâng cấp giao thức truyền tải lên WebSocket. Nếu máy chủ hỗ trợ WebSocket, việc nâng cấp diễn ra trong một phiên TCP duy nhất. Nếu không, kết nối vẫn ở long-polling và mã ứng dụng không yêu cầu thay đổi.

Theo kiểm tra hiệu suất Socket.IO (2024), khi sử dụng WebSocket, độ trễ là 2–5 ms cho mỗi lần truyền tin nhắn, trong khi long-polling thêm 150–300 ms do chi phí HTTP. Việc lựa chọn phương thức truyền tải là minh bạch đối với nhà phát triển.

Giao thức Engine.IO

Engine.IO là lớp truyền tải cấp thấp mà Socket.IO được xây dựng trên đó. Nó xử lý việc thiết lập kết nối, lựa chọn phương thức truyền tải, heartbeat (ping/pong) và kết thúc kết nối. Các loại gói Engine.IO chính là: open (khởi tạo), close (đóng), ping/pong (giữ kết nối), upgrade (thay đổi phương thức truyền tải) và message (dữ liệu).

Socket.IO xây dựng mô hình dựa trên sự kiện của mình trên Engine.IO — đây là thứ mà nhà phát triển làm việc cùng. Mỗi tin nhắn Socket.IO được đóng gói trong một gói Engine.IO loại message với mã định danh duy nhất để xác nhận gửi.

Các tính năng chính của Socket.IO

Socket.IO cung cấp một tập hợp các tính năng không có trong API WebSocket gốc và giúp việc phát triển ứng dụng thời gian thực dễ dàng hơn đáng kể. Hãy xem các tính năng chính.

Tự động kết nối lại — máy khách tự động khôi phục kết nối khi bị ngắt với độ trễ lũy thừa (100 ms, 200 ms, 400 ms... lên đến tối đa). Theo tài liệu Socket.IO (2024), cài đặt thử lại có sẵn thông qua các tham số reconnectionDelay và reconnectionAttempts. Tùy chọn này rất quan trọng đối với ứng dụng di động, nơi kết nối có thể bị gián đoạn khi chuyển mạng.

Hỗ trợ phòng — máy chủ có thể nhóm các socket vào phòng và chỉ gửi tin nhắn cho những người tham gia một phòng cụ thể. Phòng không yêu cầu tạo rõ ràng — chúng được tạo khi socket đầu tiên tham gia. Phòng được triển khai ở cấp tiến trình và không được chia sẻ giữa các máy chủ khác nhau nếu không có bộ điều hợp đặc biệt.

Không gian tên — phân tách logic các kênh truyền thông trên một kết nối duy nhất. Ví dụ: không gian tên /chat cho tin nhắn chat và /notifications cho thông báo. Mỗi không gian tên có phòng, middleware và trình xử lý riêng. Các không gian tên được ghép kênh qua một kết nối TCP duy nhất, tiết kiệm tài nguyên.

Xác nhận gửi — khi gửi tin nhắn, có thể truyền một hàm callback sẽ được gọi khi máy chủ xác nhận đã nhận. Điều này được triển khai thông qua mã định danh duy nhất cho mỗi gói. Cơ chế xác nhận đảm bảo rằng các tin nhắn quan trọng (ví dụ: giao dịch thanh toán) được gửi đến người nhận.

Socket.IO vs WebSocket: so sánh

Sự lựa chọn giữa Socket.IO và WebSocket gốc phụ thuộc vào yêu cầu của dự án. WebSocket là giao thức được tiêu chuẩn hóa (RFC 6455) được tất cả các trình duyệt hiện đại hỗ trợ. Socket.IO là thư viện sử dụng WebSocket làm phương thức truyền tải nhưng bổ sung thêm các tính năng.

Nếu dự án của bạn yêu cầu hiệu suất tối đa và kích thước máy khách tối thiểu — hãy chọn WebSocket gốc. Nếu bạn cần gửi tin đáng tin cậy, nhóm và mô hình dựa trên sự kiện — Socket.IO sẽ giảm thời gian phát triển xuống 2–3 lần nhờ các trừu tượng có sẵn.

Theo khảo sát State of JS 2024, 67% nhà phát triển ứng dụng thời gian thực thích Socket.IO vì API tiện lợi và xử lý tích hợp các trường hợp đặc biệt (ngắt mạng, kết nối lại, dữ liệu nhị phân).

Cách kết nối Socket.IO trong dự án

Cài đặt Socket.IO yêu cầu hai gói: phía máy chủ và phía máy khách. Hãy xem thiết lập cơ bản cho dự án Node.js. Máy chủ tạo máy chủ HTTP, khởi tạo Socket.IO và xử lý các sự kiện kết nối và ngắt kết nối của máy khách.

Theo tài liệu Socket.IO (2024), máy chủ có thể được khởi động mà không cần Express bằng mô-đun http tích hợp, nhưng trong các dự án thực tế, thường sử dụng Express hoặc Fastify để định tuyến yêu cầu HTTP.

Mã phía máy chủ trong 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('Máy khách đã kết nối:', socket.id);

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

    socket.on('disconnect', () => {
        console.log('Máy khách đã ngắt kết nối');
    });
});

server.listen(3000, () => {
    console.log('Máy chủ đang chạy trên cổng 3000');
});

Mã phía máy khách trong trình duyệt

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!'
});

Sự kiện và phòng trong Socket.IO

Mô hình sự kiện Socket.IO dựa trên các sự kiện có tên. Máy chủ và máy khách gửi và nhận tin nhắn gắn với một tên sự kiện cụ thể. Tải trọng có thể là chuỗi, đối tượng JSON hoặc dữ liệu nhị phân (Buffer, ArrayBuffer, Blob).

Mỗi sự kiện hỗ trợ ACK (xác nhận) — truyền một hàm callback thực thi ở phía người gửi sau khi sự kiện được người nhận xử lý. Điều này cho phép triển khai mẫu yêu cầu-phản hồi trên mô hình sự kiện. ACK chỉ hoạt động nếu người nhận gọi callback một cách rõ ràng.

Theo tài liệu Socket.IO (2024), kích thước tối đa của một tin nhắn không được vượt quá 1 MB để có hiệu suất tối ưu. Các tin nhắn lớn hơn nên được chia thành các đoạn hoặc gửi qua một kênh riêng.

Làm việc với phòng

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');
});

Mở rộng quy mô Socket.IO

Mở rộng quy mô theo chiều ngang Socket.IO yêu cầu giải quyết vấn đề chia sẻ trạng thái giữa nhiều tiến trình máy chủ. Phòng, không gian tên và danh sách các socket đã kết nối được lưu trữ trong bộ nhớ của một tiến trình duy nhất và không hiển thị với các tiến trình khác nếu không có bộ điều hợp.

Các bộ điều hợp chính thức của Socket.IO: redis (qua Redis Pub/Sub), mongodb (qua MongoDB change streams), cluster (cho chế độ đa tiến trình của Node.js cluster). Bộ điều hợp hoạt động như một nhà môi giới tin nhắn giữa các phiên bản Socket.IO. Khi một sự kiện được gửi đến một phòng, bộ điều hợp sẽ công bố nó trên Redis và tất cả các máy chủ đều nhận được thông báo.

Theo kiểm tra tải Socket.IO (2024), một cụm 4 máy chủ với bộ điều hợp Redis xử lý tới 400.000 kết nối đồng thời với độ trễ dưới 10 ms. Không có bộ điều hợp, dung lượng tối đa của một tiến trình Node.js là khoảng 100.000 kết nối với 1 GB bộ nhớ.

Cấu hình bộ điều hợp 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));

Khi sử dụng Kubernetes hoặc Docker Swarm, nên cấu hình thêm ái lực phiên (sticky sessions) để các yêu cầu từ cùng một máy khách đến cùng một máy chủ; nếu không, việc chỉ định có thể thay đổi sau mỗi lần kết nối lại.