PHP WebSocket 開発例: 特定の機能の実装方法のデモンストレーション-PHPチュートリアル-php.cn

PHP WebSocket 開発例: 特定の機能の実装方法のデモンストレーション

WBOY

リリース： 2023-09-12 08:42:02

オリジナル

1349 人が閲覧しました

PHP WebSocket开发实例：如何实现特定功能的演示

PHP WebSocket 開発例: 特定の機能の実装方法のデモンストレーション

WebSocket は、永続的な接続の確立を可能にするリアルタイム双方向通信用のプロトコルです。可能です。 WebSocket は、リアルタイム機能や即時通信を実装する必要がある Web アプリケーションにとって強力なツールです。この記事では、PHP WebSocket 開発を使用して特定の機能を実装する方法を説明します。

環境の準備
開始する前に、PHP 環境がインストールされていることを確認してください。同時に、Chrome、Firefox などの WebSocket をサポートするブラウザーが必要です。次に、単純な WebSocket サーバーを作成して、特定の機能を実装する方法を示します。
WebSocket サーバーの作成
まず、WebSocket サーバーを作成する必要があります。 PHP では、Ratchet ライブラリを使用して WebSocket サーバーを実装できます。まず、Composer を通じて Ratchet ライブラリをインストールします:
```
composer require cboden/ratchet
```
ログイン後にコピー
次に、WebSocket サーバーを定義する server.php ファイルを作成します:
```
<?php
require __DIR__ . '/vendor/autoload.php';

use RatchetServerIoServer;
use RatchetHttpHttpServer;
use RatchetWebSocketWsServer;

class MyWebSocketServer implements RatchetMessageComponentInterface {
 // 实现WebSocket服务器的方法
}

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

$server->run();
```
ログイン後にコピー
この例では、 MyWebSocketServer という名前のクラスを使用して、WebSocket サーバーのインターフェイスメソッドを実装します。このクラスは、受信したメッセージ、接続イベント、終了イベントなどを処理します。
特定の関数の実装
次に、特定の関数の実装を示します。この例では、ユーザーがメッセージを送信したり、他のオンラインユーザーにメッセージをブロードキャストしたりできる簡単なチャットルームを作成します。

MyWebSocketServer クラスに、メッセージ、接続、およびクローズイベントを処理する次のメソッドを追加します。

class MyWebSocketServer implements RatchetMessageComponentInterface {
    protected $clients;

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

    public function onOpen(RatchetConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})
";
    }

    public function onClose(RatchetConnectionInterface $conn) {
        $this->clients->detach($conn);
        echo "Connection {$conn->resourceId} has disconnected
";
    }

    public function onMessage(RatchetConnectionInterface $from, $msg) {
        foreach ($this->clients as $client) {
            $client->send($msg);
        }
    }

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

ログイン後にコピー

上記のコードでは、## を使用します。 # SplObjectStorage は、サーバーに接続されているすべてのクライアントを保存します。新しい接続が存在する場合、それを $clients に保存し、新しい接続のリソース ID を出力します。接続が閉じられると、切断されたクライアントを $clients から削除し、そのリソース ID を出力します。メッセージを受信すると、接続されているすべてのクライアントをループして各クライアントにメッセージを送信します。

サーバーの実行
これで、WebSocket サーバーとサービスロジックの準備が整いました。次のコマンドを実行してサーバーを起動できます:
```
php server.php
```
ログイン後にコピー
サーバーはポート 8080 をリッスンし、クライアント接続、メッセージ、およびシャットダウンイベントの受信と処理を開始します。
最後に、WebSocket サーバーに接続してテストするためのクライアントを実装する必要があります。 JavaScript の WebSocket API を使用して WebSocket 接続を作成し、メッセージを送受信できます。

var socket = new WebSocket("ws://localhost:8080");

socket.onopen = function() {
    console.log("Connected to server");
};

socket.onmessage = function(event) {
    console.log("Received message: " + event.data);
};

socket.onclose = function() {
    console.log("Server connection closed");
};

// 发送消息
function sendMessage(message) {
    socket.send(message);
}

ログイン後にコピー

上記のコードを使用すると、WebSocket サーバーに接続し、

sendMessage 関数を呼び出してメッセージを送信できます。メッセージを受信すると、メッセージの内容がブラウザのコンソールに表示されます。