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

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

WBOY

リリース： 2023-12-17 21:22:02

オリジナル

670 人が閲覧しました

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

近年、インターネットの急速な発展に伴い、リアルタイム通信の需要がますます高まっており、WebSocket の出現により、より洗練されたリアルタイム通信のソリューションが提供されます。時刻データ送信。 Web 開発では、PHP 言語も主流のバックエンド言語の 1 つとして位置を占めています。では、PHP と WebSocket を使用してリアルタイムのデータ送信を実現するにはどうすればよいでしょうか?

1. WebSocket とは

WebSocket は、HTTP/HTTPS プロトコルのポート 80 または 443 を介して通信する全二重通信プロトコルです。 WebSocket が接続を確立すると、クライアントとサーバーの両方が「リクエスト/レスポンス」モードを必要とせずに相互にメッセージを送信できるため、強力なリアルタイムパフォーマンス、双方向通信、低コストという利点があります。オーバーヘッドが少なく、リアルタイムチャット、オンラインゲーム、および高速な対話が必要なその他のシナリオに適しています。

2. PHP での WebSocket の使用

Web 開発で一般的に使用される PHP フレームワークには、Laravel、CodeIgniter などが含まれます。ここではLaravelを例に、PHPとWebSocketを使ってリアルタイムのデータ送信を実現する方法を紹介します。

Ratchet のインストール

Ratchet は、WebSocket サーバーの実装に使用できる PHP 用の WebSocket ライブラリです。 Laravel プロジェクトでは、composer を通じてインストールできます。コマンドは次のとおりです:

$ composer require cboden/ratchet

ログイン後にコピー

WebSocket コントローラーの作成

app/Http/Controllers ディレクトリに WebSocket を作成します。 Laravel プロジェクトコントローラーの ChatController という名前。このコントローラは、Ratchet の MessageComponentInterface インターフェイスを継承し、以下に示すように、その onOpen、onMessage、onClose、および onError メソッドをオーバーライドします。

<?php

namespace AppHttpControllers;

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

class ChatController implements MessageComponentInterface
{
    protected $clients;

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

    public function onOpen(ConnectionInterface $conn)
    {
        $this->clients->attach($conn);
        echo "New connection! ({$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 {$conn->resourceId} has disconnected
";
    }

    public function onError(ConnectionInterface $conn, Exception $e)
    {
        echo "An error has occurred: {$e->getMessage()}
";
        $conn->close();
    }
}

ログイン後にコピー

このコントローラでは、$clients はクライアント接続オブジェクトのコレクションであり、onOpen メソッドはコールバックを表します新しいクライアントが接続するときのコールバックメソッド、onMessage メソッドはクライアントメッセージを受信したときのコールバックメソッド、onClose メソッドはクライアントが切断されたときのコールバックメソッド、onError メソッドは接続エラーが発生したときのコールバックメソッドを表します。

WebSocket サービスの作成

Laravel プロジェクトの Routes/web.php ルーティングファイルに次のコードを追加します。

use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;
use AppHttpControllersChatController;

Route::get('/chat', function () {
    $server = IoServer::factory(
        new HttpServer(
            new WsServer(
                new ChatController()
            )
        ),
        8080
    );
    $server->run();
});

ログイン後にコピー

このコードは、次のことを示しています。 WebSocket サービスはローカルポート 8080 をリッスンし、サービスに対応するコントローラーは ChatController です。

クライアントコード

フロントエンドページでは、次に示すように、JavaScript コードを通じて WebSocket サービスへの接続を確立できます。 # コードは WebSocket とサーバー間の接続が確立されたことを示します。サーバーのメッセージを受信すると、コンソールに出力されます。メッセージを送信する場合は、send メソッドが呼び出されます。

テスト