PHPとWebSocketの連携でリアルタイムチャットルームの開発を実現-PHPチュートリアル-php.cn

PHPとWebSocketの連携でリアルタイムチャットルームの開発を実現

PHPz

リリース： 2023-06-25 13:16:02

オリジナル

1635 人が閲覧しました

Web 開発の分野では、リアルタイムチャット機能がますます普及しています。これにより、ユーザーはリアルタイムで簡単に対話でき、コミュニケーションと理解を強化できます。リアルタイムチャットを実装するには、WebSocket プロトコルを使用する必要があり、WebSocket リクエストを処理できるプログラミング言語が必要です。この記事では、PHP と WebSocket の統合を使用したリアルタイムチャットルームの開発を実装する方法を紹介します。

WebSocket は、ブラウザとサーバー間のリアルタイムのデータ送信を可能にする全二重通信プロトコルです。 HTTP リクエストとは異なり、サーバーは WebSocket 接続の確立後にデータをブラウザにプッシュできます。したがって、WebSocket を介してクライアントとサーバーの間で双方向のデータ通信を行うことができます。ユーザーがチャットルームに参加または退出すると、メッセージはすぐに他のオンラインユーザーにプッシュされます。これがリアルタイムチャットの基本原理です。

まず、WebSocket リクエストを処理するためにサーバー側で PHP スクリプトを作成する必要があります。 PHP の swoole 拡張機能は、WebSocket サーバーの開発に役立ちます。次に、チャットアプリケーションを段階的に実装していきます。

1. swoole 拡張機能をインストールする

swoole 拡張機能を使用するには、まずそれをインストールする必要があります。 Linux システムに swoole をインストールするには、次のコマンドを使用します。

pecl install swoole

ログイン後にコピー

Windows システムで PHP を使用する場合は、swoole の GitHub リポジトリから関連する DLL ファイルをダウンロードして手動でインストールできます。

2. WebSocket サーバーのセットアップ

swoole 拡張機能のインストールが完了したら、それを使用して WebSocket サーバーの作成を開始できます。以下は、WebSocket サーバーを作成する基本コードです。

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) {
    echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}
";
    $server->push($frame->fd, json_encode(["hello", "world"]));
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) {
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

ログイン後にコピー

このコードスニペットでは、WebSocket サーバーを作成し、イベントハンドラー関数を登録します。「open」イベントでは、WebSocket 接続が開いているというメッセージを出力します。「message」イベントでは、WebSocket セッションに関する情報を出力し、クライアントにメッセージを送信します。「close」イベントでは、WebSocket 接続が閉じられたというメッセージを出力します。

3. チャットルームロジックのセットアップ

これで、WebSocket サーバーが正常に作成され、イベント処理関数がセットアップされました。次に、チャットルームロジックの実装を開始できます。

ユーザーがチャットルームに参加または退出したときにすべてのオンラインユーザーに通知するメッセージブロードキャスト機能を設定する必要があります。以下は、メッセージブロードキャスト関数のコードです。

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

ログイン後にコピー

このコードスニペットでは、switch ステートメントを使用してさまざまな種類のメッセージを処理します。ユーザーがチャットルームに参加または退出すると、ユーザーリストが更新され、通知メッセージが送信されます。ユーザーがメッセージを送信すると、メッセージの前にユーザー名が付けられ、すべてのオンラインユーザーにブロードキャストされます。

4. 完全なチャットルームコード

必要なコンポーネントがすべて準備できたので、完全なチャットルームコードの作成を開始できます。以下は完全なチャットルームコードです:

//创建WebSocket服务器
$server = new swoole_websocket_server("0.0.0.0", 9501);

//定义用户列表
$users = [];

//广播消息
function broadcast($server, $frame, $users) {
    $data = json_decode($frame->data, true);
    switch ($data['type']) {
        case 'enter':
            $users[$frame->fd] = $data['name'];
            $msg = $data['name'] . ' joined the room.';
            break;
        case 'leave':
            $name = $users[$frame->fd];
            unset($users[$frame->fd]);
            $msg = $name . ' left the room.';
            break;
        case 'msg':
            $name = $users[$frame->fd];
            $msg = $name . ': ' . $data['msg'];
            break;
    }
    foreach ($server->connections as $fd) {
        $server->push($fd, json_encode(['type' => 'msg', 'msg' => $msg]));
    }
}

//监听WebSocket连接打开事件
$server->on('open', function (swoole_websocket_server $server, $request) {
    echo "server: handshake success with fd{$request->fd}
";
});

//监听WebSocket消息事件
$server->on('message', function (swoole_websocket_server $server, $frame) use ($users) {
    broadcast($server, $frame, $users);
});

//监听WebSocket连接关闭事件
$server->on('close', function ($ser, $fd) use ($users) {
    unset($users[$fd]);
    echo "client {$fd} closed
";
});

//启动WebSocket服务器
$server->start();

ログイン後にコピー

このコードスニペットでは、すべてのオンラインユーザーの情報を $users 配列に保存します。ユーザーがチャットルームに参加または退出したときに、この配列を更新します。 WebSocket メッセージイベントでは、broadcast() 関数を使用してメッセージをブロードキャストします。 WebSocket 接続の終了イベントでは、切断されたユーザーを $users 配列から削除します。

5. チャットルームをテストする

これで、チャットルームアプリケーションが正常に作成されました。 Google Chrome、Firefox、Safari など、WebSocket をサポートするすべてのブラウザでテストできます。チャットルームをテストする手順は次のとおりです。

PHP コマンドを使用して上記のコードを実行します
index.html ファイルをブラウザで開きます
ユーザー名を入力し、[チャットルームに入る] ボタンをクリックします。
チャットボックスにメッセージを入力し、[送信] ボタンをクリックします。

メッセージが表示されるはずです。すべてのオンラインユーザーのチャットでボックス内でブロードキャストします。

概要

この記事では、PHP と WebSocket の統合を使用してリアルタイムチャットルームの開発を実装する方法を紹介しました。 swoole 拡張機能を使用して WebSocket サーバーを作成し、簡単なチャットルームアプリケーションを作成しました。この記事では、WebSocket プロトコルを使用してリアルタイムデータ送信接続を確立する方法、PHP で WebSocket サーバーを実装する方法、およびそれを使用してチャットルームアプリケーションを実装する方法を学習できます。

以上がPHPとWebSocketの連携でリアルタイムチャットルームの開発を実現の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。