PHP と WebSocket: リアルタイムデータ転送のベストプラクティス-PHPチュートリアル-php.cn

PHP と WebSocket: リアルタイムデータ転送のベストプラクティス

WBOY

リリース： 2023-12-18 14:12:01

オリジナル

1232 人が閲覧しました

PHP和WebSocket: 实现实时数据传输的最佳实践方法

PHP と WebSocket: リアルタイムデータ送信のベストプラクティス

はじめに:
Web アプリケーション開発において、リアルタイムデータ送信は非常に重要です。技術的要件。従来の HTTP プロトコルは要求応答モデルのプロトコルであり、リアルタイムのデータ送信を効果的に実現できません。リアルタイムデータ送信のニーズを満たすために、WebSocket プロトコルが登場しました。

WebSocket は、単一の TCP 接続上で全二重通信を行う方法を提供する全二重通信プロトコルです。 HTTP プロトコルと比較して、WebSocket はより高速なデータ送信とリアルタイムのデータプッシュを実現できます。 WebSocket は、優れたパフォーマンスと幅広いサポートにより、リアルタイムアプリケーションで広く使用されています。

PHP で WebSocket 通信を実装するには、いくつかの成熟したライブラリを使用して開発プロセスを簡素化できます。この記事では、Ratchet ライブラリを使用して PHP と WebSocket の統合を実装する方法を紹介し、リアルタイムデータ送信用のアプリケーションを簡単に構築できるようにいくつかのベストプラクティスを提供します。

1. 設定環境とインストールの依存関係
Ratchet ライブラリを使用するには、次の環境と依存関係の条件を満たす必要があります:

PHP バージョン >= 7.0。
コンポーザツール。

インストール手順は次のとおりです。

新しいプロジェクトディレクトリを作成し、コマンドラインにそのディレクトリを入力します。
Composer を使用して Ratchet ライブラリをインストールします。コマンドラインで次のコマンドを入力します。
```
composer require cboden/ratchet
```
ログイン後にコピー
これにより、Ratchet ライブラリとその依存関係が自動的にダウンロードされ、インストールされます。
インストールが完了したら、プロジェクトで Ratchet の使用を開始できます。

2. WebSocket サーバーの作成
Ratchet ライブラリを使用して WebSocket サーバーを簡単に作成できます。以下は簡単なサンプルコードです:

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

require 'vendor/autoload.php';

class MyWebSocketServer implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "[New connection] - Connection ID: {$conn->resourceId}
";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理收到的消息
        foreach ($this->clients as $client) {
          if ($from !== $client) {
              $client->send($msg);
          }
        }
    }

    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "[Connection closed] - Connection ID: {$conn->resourceId}
";
    }

    public function onError(ConnectionInterface $conn, Exception $e) {
        echo "[Error] - Connection ID: {$conn->resourceId} - {$e->getMessage()}
";
        $conn->close();
    }
}

$server = new RatchetWebSocketWsServer(new MyWebSocketServer());
$server->disableVersion(0);
$server->loop->addPeriodicTimer(60, function() {
    // 定时任务
});

$socket = new ReactSocketServer('0.0.0.0:8080', $server->loop);
$server = new ReactHttpServer($socket, $server->loop);
$server->on('request', function ($request, $response) use (&$socket) {
    $response->end('Hello, World!');
});

echo "WebSocket server is running...
";

$server->run();

ログイン後にコピー

この例では、まず「MyWebSocketServer」という名前のクラスを作成し、Ratchet の MessageComponentInterface インターフェイスを実装します。このインターフェイスには、クライアント接続の処理とメッセージの受信に使用される onOpen、onMessage、onClose、onError の 4 つのメソッドが含まれています。接続を閉じてエラーを処理します。

onOpen メソッドでは、サーバー内のクライアントリストを更新し、新しい接続の ID を出力します。

onMessage メソッドでは、クライアントリストを走査し、受信したメッセージをメッセージの発信元のクライアントを除くすべてのクライアントに送信します。

onClose メソッドでは、クライアントリスト内の閉じられた接続を削除し、接続 ID を出力します。

onError メソッドでは、接続でエラーが発生した状況を処理し、接続を閉じます。

次に、WebSocket サーバーのインスタンスを作成し、MyWebSocketServer をパラメータとして WsServer に渡しました。次に、React HTTP サーバーのインスタンスを作成します。最後に、run メソッドを使用して WebSocket サーバーを起動しました。

3. フロントエンドクライアントページ
WebSocket サーバーをテストするには、WebSocket クライアントをシミュレートする単純なフロントエンドページを作成する必要があります。以下はサンプルページです:

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Client</title>
    <script>
        var socket = new WebSocket("ws://localhost:8080");

        socket.onmessage = function(event) {
            var message = event.data;
            // 处理收到的消息
            console.log(message);
        };

        // 发送消息
        function sendMessage() {
            var message = document.getElementById('message').value;
            socket.send(message);
        }
    </script>
</head>
<body>
    <input type="text" id="message" placeholder="Type a message...">
    <button onclick="sendMessage()">Send</button>
</body>
</html>

ログイン後にコピー

この例では、最初に WebSocket オブジェクトを作成し、サーバーのアドレスとポートを指定します。次に、受信したメッセージを処理するために onmessage イベントハンドラーを登録しました。この例では、メッセージをコンソールに出力するだけです。

さらに、ユーザーがメッセージを入力して送信できるように、テキスト入力ボックスと送信ボタンを追加しました。

4. 実行とテスト
サーバー上で WebSocket サーバースクリプトを実行した後、ブラウザを開いてフロントエンドクライアントページにアクセスします。テキスト入力ボックスと送信ボタンが表示されます。

送信したいメッセージをテキスト入力ボックスに入力し、[送信]ボタンをクリックします。受信したメッセージがコンソールに表示されます。

WebSocket サーバーとフロントエンドクライアントページの例を使用して、Ratchet ライブラリと関連する PHP および JavaScript コードの使用方法を示します。このアプローチを使用すると、リアルタイムデータ転送機能を備えた Web アプリケーションを簡単に構築できます。

結論:
WebSocket プロトコルを使用することで、リアルタイムのデータ送信を実現し、より高速で効率的な通信方法を提供できます。 PHP は人気のあるサーバー側プログラミング言語であり、WebSocket は Ratchet ライブラリを使用して PHP アプリケーションに簡単に統合できます。この記事に示されているサンプルコードとベストプラクティスは、リアルタイムデータ転送機能を備えたアプリケーションの構築を始めるのに役立ちます。

参考資料: