PHP で WebSocket API を使用してリアルタイムメッセージプッシュを行う方法-PHPチュートリアル-php.cn

PHP で WebSocket API を使用してリアルタイムメッセージプッシュを行う方法

PHPz

リリース： 2023-06-17 10:44:01

オリジナル

1318 人が閲覧しました

技術の継続的な発展により、リアルタイムメッセージプッシュは Web アプリケーションの重要な機能の 1 つになりました。 WebSocket は、新興テクノロジーとして、リアルタイムメッセージプッシュの主流テクノロジーの 1 つになりました。この記事では、PHP で WebSocket API を使用してリアルタイムのメッセージプッシュを行う方法を説明します。

1. WebSocket とは

WebSocket は新しいタイプのネットワーク通信プロトコルで、TCP プロトコルをベースにした双方向通信方式です。クライアントとサーバーの間に永続的な接続チャネルを確立し、このチャネル上で双方向通信を実行して、リアルタイムのメッセージプッシュを実現できます。従来の HTTP プロトコルと比較して、WebSocket は遅延が短く、リアルタイムパフォーマンスが高くなります。

2. PHP で WebSocket API を使用する方法

PHP で WebSocket API を使用するには、WebSocket プラグインを導入する必要があります。一般的に使用される WebSocket プラグインには、phpwebsocket や Ratchet などがあります。この記事では、phpwebsocket を例として、WebSocket API を使用してリアルタイムメッセージプッシュを行う方法について説明します。

phpwebsocket のインストール

phpwebsocket は、RFC6455 および Hybi-10 プロトコルをサポートする PHP ベースの WebSocket 実装ライブラリです。使用する前に、phpwebsocketをダウンロードしてインストールする必要があります。 phpwebsocket の最新バージョンは、phpwebsocket 公式 Web サイトからダウンロードするか、composer を使用してインストールできます。

composer require cboden/ratchet

ログイン後にコピー

サーバープログラムの作成

phpwebsocket を使用する場合リアルタイムメッセージプッシュ、サーバープログラムを作成する必要があります。 WebSocket クラスを継承してサーバープログラムを作成できます。コードは次のとおりです:

require_once('WebSocket.php');

class MyWebSocket extends WebSocket
{

    public function process($client, $message)
    {
        // 处理消息
    }

    public function connected($client)
    {
        // 处理连接
    }

    public function closed($client)
    {
        // 处理关闭
    }

}

ログイン後にコピー

process() メソッドは、クライアントによって送信されたメッセージを処理するために使用されます。 ) メソッドはクライアント接続の処理に使用され、
closed() メソッドはクライアントが接続を閉じる処理に使用されます。

サーバープログラムを実行します

require_once('MyWebSocket.php');

$server = new MyWebSocket("127.0.0.1", 8080);

try {
    $server->run();
} catch (Exception $e) {
    $server->stdout($e->getMessage());
}

ログイン後にコピー

Writeクライアントプログラム

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

socket.onopen = function() {
    // 连接成功
};

socket.onmessage = function(event) {
    // 服务器发送消息
};

socket.onclose = function() {
    // 连接关闭
};

// 发送消息
socket.send('Hello, World!');

ログイン後にコピー

3. リアルタイムメッセージプッシュの実装

リアルタイムメッセージプッシュに WebSocket API を使用する場合は、次の点を考慮する必要があります。

単一クライアントへのメッセージのプッシュ

$this->send($client, $message);

ログイン後にコピー

すべてのクライアントにメッセージをプッシュする

foreach ($this->clients as $client) {
    $this->send($client, $message);
}

ログイン後にコピー

グループメッセージ

#指定したクライアントグループにメッセージをプッシュするには、メッセージグループを定義し、そのグループにクライアントを追加する必要があります。グループメッセージを送信する場合は、送信するだけで済みます。グループ内のすべてのクライアントにメッセージを送信します。以上です:

// 定义消息组
$group = array();

// 将客户端加入到消息组中
$group[$client->id] = $client;

// 群发消息
foreach ($group as $member) {
    $this->send($member, $message);
}

ログイン後にコピー

以上がPHP で WebSocket API を使用してリアルタイムメッセージプッシュを行う方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。