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パッケージは毎週1200万以上ダウンロードされており、Node.jsエコシステムで最も人気のあるライブラリの1つとなっています。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）の2つのコンポーネントで構成されています。サーバーはNode.js HTTP（S）サーバー上で動作し、トランスポート層を管理するためにEngine.IOを使用します。

最初の接続時、クライアントはサーバーにHTTPリクエストを送信します。Engine.IOが応答し、long-polling接続を確立します。その後、クライアントはトランスポートプロトコルをWebSocketにアップグレードするリクエストを送信します。サーバーがWebSocketをサポートしている場合、アップグレードは単一のTCPセッション内で行われます。そうでない場合、接続はlong-pollingのままで、アプリケーションコードの変更は必要ありません。

Socket.IOパフォーマンステスト（2024）によると、WebSocketを使用した場合のレイテンシはメッセージ送信あたり2〜5msですが、long-pollingはHTTPオーバーヘッドのため150〜300ms追加されます。トランスポートの選択は開発者にとって透過的です。

Engine.IOプロトコル

Engine.IOは、Socket.IOが構築される低レベルのトランスポート層です。接続確立、トランスポート選択、ハートビート（ping/pong）、接続終了を処理します。Engine.IOパケットの主なタイプは、open（初期化）、close（終了）、ping/pong（キープアライブ）、upgrade（トランスポート変更）、message（データ）です。

Socket.IOはEngine.IOの上にイベント駆動モデルを構築します。これが開発者が扱うものです。各Socket.IOメッセージは、配信確認用の一意の識別子を持つEngine.IOパケットにラップされます。

Socket.IOの主な機能

Socket.IOは、ネイティブのWebSocket APIにはなく、リアルタイムアプリケーションの開発を大幅に容易にする一連の機能を提供します。主な機能を見てみましょう。

自動再接続 — 切断時にクライアントは指数バックオフ（100ms、200ms、400ms...最大まで）で自動的に接続を復元します。Socket.IOドキュメント（2024）によると、再試行設定はreconnectionDelayパラメーターとreconnectionAttemptsパラメーターで利用できます。このオプションは、ネットワーク変更中に接続が中断される可能性があるモバイルアプリケーションにとって重要です。

ルームサポート — サーバーはソケットをルームにグループ化し、特定のルームの参加者にのみメッセージを送信できます。ルームは明示的な作成を必要としません。最初のソケットが参加したときに作成されます。ルームはプロセスレベルで実装され、特別なアダプターなしでは異なるサーバー間で共有されません。

名前空間 — 単一の接続上の通信チャネルの論理的な分離。たとえば、チャットメッセージ用の/chat名前空間と通知用の/notifications名前空間。各名前空間には独自のルーム、ミドルウェア、ハンドラーがあります。名前空間は単一のTCP接続で多重化され、リソースを節約します。

配信確認 — メッセージを送信する際に、サーバーが受信を確認したときに呼び出されるコールバック関数を渡すことができます。これは各パケットの一意の識別子を介して実装されます。確認メカニズムにより、重要なメッセージ（支払いトランザクションなど）が受信者に確実に配信されます。

Socket.IO vs 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のインストールには、サーバー側とクライアント側の2つのパッケージが必要です。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つのメッセージの最大サイズは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台のサーバーのクラスターは、10ms未満のレイテンシで最大40万の同時接続を処理します。アダプターがない場合、1つのNode.jsプロセスの最大容量は1GBメモリで約10万接続です。

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を使用する場合、同じクライアントからのリクエストが同じサーバーに届くようにセッションアフィニティ（スティッキーセッション）を追加で設定することをお勧めします。そうしないと、再接続のたびに割り当てが変わる可能性があります。