Pusher — とは、リアルタイムプラットフォームとアプリ連携

Pusherとは？

Pusherは2011年に設立された双方向リアルタイム通信用のクラウドサービスです。独自のWebSocketサーバーを管理することなく、リアルタイムでメッセージを送受信するための既製のインフラを提供します。Pusherはチャット、ライブ通知、共同編集、ゲームのリーダーボード構築に使用されます。

独自サーバーのデプロイとメンテナンスが必要なSocket.IOのようなライブラリとは異なり、PusherはSaaS（Software as a Service）モデルで動作します。開発者は登録してキー（app_id、key、secret）を取得し、Pusher REST APIを使用してイベントを公開します。サーバーインフラは完全にPusherプラットフォームによって管理されます。

Pusher公式ブログ（2025年）によると、このプラットフォームは世界中で25万以上のアクティブプロジェクトをサービスしています。有名なクライアントにはGitHub（リアルタイム通知）、Trello（ボード同期）、Intercom（サポートチャット）があります。Pusherは遅延を最小限に抑えるために米国、欧州、アジアにデータセンターを保有しています。

Pusherの開発史

Pusherは2011年にWebSocket向けの最初のホステッドサービスの1つとしてローンチされました。2014年に同社はPusher Channels — privateチャネルとpresenceチャネルをサポートする現在のアーキテクチャを発表しました。2017年にはサーバーサイドイベント向けのウェブフックサポートが追加されました。2022年にPusherはモバイルプラットフォーム向けプッシュ通知サービスPusher Beamsをローンチしました。

Pusherのアーキテクチャはセルフホステッドソリューションとは異なり、サブスクリプション処理、接続管理、イベントルーティングのすべてがPusher Cloud側で行われます。開発者はバックエンドを介したprivateチャネルの認証のみを管理します。

Pusherの仕組み

Pusherのアーキテクチャはパブリッシャー-サブスクライバーモデルに基づいています。サーバーアプリケーションはPusher REST APIを介してイベントを公開し、クライアントアプリケーションは永続的なWebSocket接続を介してイベントを受信します。Pusherはパブリッシャーとサブスクライバーの間の仲介役として機能します。

サーバーがPusher APIにPOSTリクエストを介してイベントを送信すると、プラットフォームはターゲットチャネルを特定し、そのチャネルにサブスクライブしているすべてのクライアントにメッセージを配信します。クライアントは既に開かれているWebSocket接続を介してイベントを受信し、地理的な場所に応じて50～100ミリ秒のレイテンシを実現します。

各クライアントはPusher Client SDKを介して接続を確立し、SDKが自動的にトランスポートを選択します（WebSocket — 優先、HTTP long-polling — フォールバック）。SDKは開発者の介入なしに再接続、データシリアル化、エラー処理を管理します。Pusher技術ドキュメント（2025年）によると、ネットワーク中断後の再接続時間は1秒未満です。

Pusherのコンポーネント

システムは3つのコンポーネントで構成されています：Pusher Server API（イベント公開用RESTエンドポイント）、Pusher Client SDK（イベントサブスクライブ用ライブラリ）、Pusher WebHook（接続/切断イベントに関するサーバー通知）。すべてのコンポーネントは非同期かつ独立して動作します。

Pusherチャネルの種類

Pusher Channelsは3種類のチャネルをサポートしており、それぞれ異なるユースケース向けに設計されています。チャネルの種類によってアクセスレベル、認証メカニズム、利用可能な機能が決まります。

Publicチャネルは認証なしですべてのクライアントが利用でき、ブロードキャストデータに適しています。Privateチャネルは開発者のサーバーを介した認証が必要です。クライアントはsocket_idとchannel_nameをバックエンドに送信し、サーバーはPusherのシークレットキーでリクエストに署名し、認証トークンを返します。Presenceチャネルはさらにユーザー情報（user_id、user_info）を送信し、現在誰がオンラインかを追跡できます。

Pusherドキュメント（2025年）によると、publicチャネルとprivateチャネルの1チャネルあたりの最大同時接続クライアント数は10,000です。Presenceチャネルの場合、制限は1チャネルあたり10,000ユーザーで、アプリケーションあたり最大100,000ユーザーまでサポートします。

Pusherのイベントとトリガー

Pusherのイベントモデルは、チャネルに公開される名前付きイベントに基づいています。各イベントには名前（最大200文字）、JSON形式のデータ、およびイベント発行者への重複送信を防ぐためのオプションのsocket_idがあります。

トリガーは、チャネルにイベントを公開するPusher APIへのHTTP POSTリクエストです。リクエスト形式：channel、name、dataを含むボディでPOST /apps/{app_id}/events。Pusher Server APIは公式ライブラリ（PHP、Ruby、Python、Go、Java、Node.js）を介して任意のサーバー環境からのトリガーをサポートします。

Pusherはバッチトリガーをサポートしています。1つのリクエストで複数のチャネルに1つのイベントを公開します。これは順次呼び出しよりも効率的で、アトミックな配信を保証します。Pusherのパフォーマンステスト（2024年）によると、100チャネルへのバッチトリガーは30～50ミリ秒かかるのに対し、順次呼び出しは2～5秒かかります。

Webhook統合

Pusher WebHookを使用すると、サーバーはインフラストラクチャイベント（クライアント接続、切断、エラー発生）に関する通知を受信できます。Webhookリクエストは検証のためにHMAC-SHA256で署名されます。これはロギング、分析、状態同期にとって重要です。

プロジェクトにPusherを統合する方法

Pusherの統合は2つの部分で構成されます：サーバーサイド（イベント公開）とクライアントサイド（イベントサブスクライブ）。サーバー部分はNode.js、クライアント部分はJavaScriptを使用した例を見てみましょう。まず、Pusherダッシュボードでアプリケーションを作成し、認証情報を取得する必要があります。

Pusherドキュメント（2025年）によると、基本プラン（Sandbox）には最大100の同時接続と1日あたり200,000メッセージが含まれており、開発とテストに十分です。プロダクションプランは1000接続で月額49ドルから始まります。

サーバーコード：イベントの公開

const Pusher = require('pusher');

const pusher = new Pusher({
    appId: 'YOUR_APP_ID',
    key: 'YOUR_KEY',
    secret: 'YOUR_SECRET',
    cluster: 'eu',
    useTLS: true
});

pusher.trigger('my-channel', 'my-event', {
    message: 'Hello from server',
    timestamp: Date.now()
}).then(() => {
    console.log('イベント公開');
}).catch(console.error);

クライアントコード：イベントのサブスクライブ

import Pusher from 'pusher-js';

const pusher = new Pusher('YOUR_KEY', {
    cluster: 'eu',
    forceTLS: true
});

const channel = pusher.subscribe('my-channel');

channel.bind('my-event', (data) => {
    console.log('受信イベント:', data);
    displayNotification(data.message);
});

モバイルアプリでのPusher

PusherはiOS（Swift）とAndroid（Java/Kotlin）向けのSDKを提供しており、JavaScriptクライアントの機能を完全に再現しています。モバイルSDKは同じチャネルタイプ、認証メカニズム、イベントモデルをサポートしています。React Nativeの場合は、JavaScriptブリッジを介して動作するpusher-jsパッケージが利用可能です。

モバイルデバイスでは、Pusher SDKが指数バックオフによる再接続メカニズムを使用して、Wi-Fiとモバイルネットワーク間の切り替えを自動的に処理します。これは、iOSがバックグラウンド動作中にWebSocket接続を強制的に閉じる可能性があるiOSアプリにとって特に重要です。

Pusher技術ブログ（2024年）によると、アクティブなイベントがない場合の1つのPusher接続の平均トラフィック消費量は1分あたり1～2KBです。これは30秒間隔の最適化されたハートビートプロトコルによって実現されています。中規模のアプリケーションは、バッテリー寿命に大きな影響を与えることなく、最大1000の同時Pusher接続をサポートできます。

プッシュ通知のためのPusher Beams

Pusher Beamsは、APNs（iOS）とFCM（Android）を介してモバイルデバイスにプッシュ通知を送信するための追加サービスです。BeamsはPusher Channelsと統合されており、チャネルからのイベントがクライアントのオフライン時に自動的にプッシュ通知をトリガーできます。これにより、アプリが閉じているときのメッセージ配信の問題が解決されます。

Pusherのセキュリティと認証

Pusherのセキュリティは複数のレベルで実装されています。Pusher APIへの各リクエストはapp_secretを使用してHMAC-SHA256で署名されます。これにより、認可されたサーバーのみがイベントを公開できることが保証されます。クライアントSDKはアプリケーション識別にapp_keyを使用しますが、privateチャネルとpresenceチャネルへのアクセスには追加の認証が必要です。

Privateチャネルの認証は3つのステップで行われます。クライアントがpusher.subscribe('private-channel')を呼び出し、Pusher Client SDKがバックエンドエンドポイント（/pusher/auth）にHTTPリクエストを送信し、サーバーがユーザーの権限を確認してシークレットキーで署名された認証トークンを返します。Pusherは署名を検証してサブスクリプションを許可します。

すべてのリクエストにTLS接続を使用することを推奨します（SDKでuseTLS: trueを設定）。PusherはREST APIへのサーバーリクエストに対するIPアドレスによるアクセス制限もサポートしています。エンタープライズプランでは、VPC（仮想プライベートクラウド）と分離されたインフラを備えた専用クラスターのサポートが利用可能です。