PHP と Websocket を使用してリアルタイム集約プッシュ システムを実装する方法

インターネットの急速な発展に伴い、リアルタイムのプッシュ データを必要とするアプリケーション シナリオがますます増えており、リアルタイム アグリゲーション プッシュ システムが登場しました。このシステムでは、サーバーがリアルタイムでデータをクライアントにプッシュできるため、リアルタイムのデータ更新の効果が得られます。

この記事では、PHP と Websocket を使用してリアルタイム集計プッシュ システムを実装する方法を紹介し、関連するテクノロジと実装手順を理解できるようにします。

1. Websocket とは

Websocket は HTML5 仕様の新しいプロトコルで、クライアントとサーバー間の双方向通信を実現するために使用されます。従来の HTTP プロトコルと比較して、Websocket は HTTP プロトコルの欠点を十分に克服し、クライアントとサーバー間のリアルタイム通信を実現できます。

以前の HTTP プロトコルは要求/応答モデルに基づいており、サーバーはクライアントの要求を受信した後にのみデータをクライアントに返すことができました。 Websocket プロトコルを使用すると、クライアントとサーバーの間に永続的な接続を確立でき、サーバーはクライアントのリクエストを待たずに、この接続を通じてリアルタイムでクライアントにデータをプッシュできます。

2. PHP での Websocket サーバーの実装

PHP での Websocket サーバーの実装は比較的複雑ですが、このタスクを完了するのに役立つオープン ソース ライブラリがいくつかあります。より人気のあるものはラチェットとスウールです。

1. Ratchet を使用して Websocket サーバーを実装する

Ratchet は、Websocket サーバーを迅速に実装するのに役立つ PHP Websocket ライブラリです。

まず、Composer を使用して Ratchet ライブラリをインストールする必要があります:

composer require cboden/ratchet

次に、PHP ファイル websocket-server.php を作成し、次のコードを記述します:

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
use MyAppChat;

require dirname(__DIR__) . '/vendor/autoload.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new Chat()
        )
    ),
    8080
);

$server->run();

このコードでは、IoServer::factory() メソッドを通じて Websocket サーバーを作成します。最初のパラメータは Websocket サーバーの実装であり、HttpServer クラスと WsServer クラスを組み合わせたものです。

2 番目のパラメータはサーバーのポート番号で、ポート 8080 を使用します。最後に、$server->run() メソッドが呼び出され、サーバーが起動されます。クライアントがこのサーバーに接続すると、データをクライアントにプッシュできます。

2. Swoole を使用して Websocket サーバーを実装する

Swoole は、非同期 IO とマルチスレッドをサポートする PHP 用の高性能ネットワーク通信フレームワークです。 Swoole を使用して Websocket サーバーを実装することも比較的簡単です。

まず、Composer を使用して Swoole ライブラリをインストールする必要があります:

composer require swoole/swoole

次に、PHP ファイル websocket-server.php を作成し、次のコードを記述します:

use SwooleWebSocketServer;

$server = new Server("0.0.0.0", 8080);

$server->on('open', function (Server $server, $request) {
    echo "Client {$request->fd} connected
";
});

$server->on('message', function (Server $server, $frame) {
    echo "Received message: {$frame->data}
";
    $server->push($frame->fd, json_encode(['message' => 'Hello, world!']));
});

$server->on('close', function (Server $server, $fd) {
    echo "Client {$fd} disconnected
";
});

$server->start();

このコードでは、SwooleWebSocketServer クラスを使用して Websocket サーバーを実装し、リスニング IP アドレスを 0.0.0.0 として、リスニング ポート番号を 8080 として指定します。

次に、$server->on() メソッドを使用して、クライアント接続、メッセージ受信、およびクライアント切断のコールバック関数を設定します。このコールバック関数は通常、クライアントにデータをプッシュするために使用されます。データをプッシュする関数を実装するには $server->push() メソッドを使用します。

最後に、$server->start() メソッドを呼び出してサーバーを起動します。クライアントがこのサーバーに接続すると、データをクライアントにプッシュできます。

3. リアルタイム集約プッシュ システムの実装

Websocket サーバーの実装方法を理解した後、リアルタイム集約プッシュ システムの実装方法を見てみましょう。

まず、プッシュするデータ型とデータ ソースを決定する必要があります。ここではニュース情報を例に挙げますが、時々新しい記事をプッシュするニュース Web サイトが複数あるとします。

次に、Websocket サーバーを通じてこれらのニュースをリアルタイムでプッシュできます。サーバーは複数のニュース サイトから新しい記事を取得し、それらの記事をクライアントにプッシュできます。

サーバー側でコードを記述する場合、複数のニュース Web サイトから新しい記事を定期的に取得する必要があります。これは、5 分ごとにニュース Web サイトをリクエストするなど、スケジュールされたタスクによって実現できます。新しい記事を取得した後、これらの記事は Websocket を通じてすべてのクライアントにプッシュできます。

クライアント側でコードを記述する場合は、サーバーに接続し、サーバーからプッシュされたニュース記事を受信する必要があります。一般に、クライアントはニュース記事をリアルタイムで受信し、ユーザーに表示する必要があります。これは Websocket を通じて実現でき、サーバーが新しい記事をプッシュすると、クライアントはこれらの記事をページ上に動的に表示できます。

4. 概要

この記事の導入部を通じて、PHP と Websocket を使用してリアルタイム集計プッシュ システムを実装する方法を学ぶことができます。 Websocket プロトコルは、クライアントとサーバー間の双方向通信を実現でき、リアルタイム データ プッシュの問題をうまく解決できます。 PHP では、Ratchet や Swoole などのオープン ソース ライブラリを使用して Websocket サーバーを実装できます。これらの技術的手段を通じて、さまざまなアプリケーション シナリオのニーズを満たすリアルタイム集約プッシュ システムを簡単に実装できます。

以上がPHP と Websocket を使用してリアルタイム集約プッシュ システムを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。