ロングポーリング

ロングポーリングとは

ロングポーリング (Long Polling) は、クライアントがサーバーにリクエストを送り、サーバーがデータの準備ができるまでレスポンスを保留する手法である。通常のポーリング (短いポーリング) が定期的にリクエストを繰り返すのに対し、ロングポーリングはサーバー側でイベントが発生するまで接続を維持する。

通常のポーリングとの比較

通常のポーリングはデータの有無にかかわらず即座にレスポンスを返すため、データがない間も無駄なリクエストが繰り返される。ロングポーリングはサーバーがデータの到着まで接続を保持し、データが来た時点でレスポンスを返す。これにより無駄なリクエストが減り、リアルタイム性も向上する。

短いポーリング:
  クライアント → リクエスト → サーバー (データなし → 即座に空レスポンス)
  クライアント → リクエスト → サーバー (データなし → 即座に空レスポンス)
  クライアント → リクエスト → サーバー (データあり → レスポンス)

ロングポーリング:
  クライアント → リクエスト → サーバー (データが来るまで保留...)
                                        (データあり → レスポンス)
  クライアント → 即座に再リクエスト → サーバー (保留...)

リアルタイム通信手法の比較

リアルタイム通信手法の比較を以下に示す。

手法	方向	レイテンシ	複雑さ	サーバー負荷
短いポーリング	クライアント → サーバー	高い (間隔依存)	低い	高い (空リクエスト多数)
ロングポーリング	擬似双方向	中程度	中程度	中程度
SSE	サーバー → クライアント	低い	低い	低い
WebSocket	双方向	最低	高い	低い

クライアント側の実装

クライアント側の実装のコード例を示す。

async function longPoll(url: string) {
  while (true) {
    try {
      const response = await fetch(url, {
        signal: AbortSignal.timeout(30000), // 30秒タイムアウト
      });
      const data = await response.json();
      handleData(data);
    } catch (error) {
      if (error instanceof DOMException && error.name === 'TimeoutError') {
        continue; // タイムアウト → 再接続
      }
      await new Promise(r => setTimeout(r, 3000)); // エラー → 3秒待って再接続
    }
  }
}

サーバー側の実装

サーバー側の実装のコード例を示す。

app.get('/api/notifications', async (req, res) => {
  const timeout = setTimeout(() => {
    res.json({ data: null }); // 30秒でタイムアウト
  }, 30000);

  const data = await waitForNewData(req.query.lastId); // データが来るまで待機
  clearTimeout(timeout);
  res.json({ data });
});

Lambda での制約

Lambda は最大 29 秒 (API Gateway のタイムアウト) しか接続を維持できないため、ロングポーリングには不向き。代替手段として、API Gateway WebSocket (Lambda と WebSocket の統合)、AppSync Subscriptions (GraphQL のリアルタイム通知)、SQS + 短いポーリング (クライアントが SQS を定期的にチェック) がある。

使うべきケース

WebSocket や SSE が使えない環境 (プロキシ制限、古いブラウザ)
シンプルな通知機能で、WebSocket ほどの双方向通信が不要
既存の HTTP インフラをそのまま使いたい場合

ロングポーリングの理解を深めるには関連書籍が参考になる。