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

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

PHPz

リリース： 2023-06-28 08:58:01

オリジナル

1600 人が閲覧しました

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

この記事では、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 サイトの他の関連記事を参照してください。