ホームページ > 記事 > バックエンド開発 > PHPベースのリアルタイムチャットシステムのグループチャットおよびプライベートチャット機能

PHPベースのリアルタイムチャットシステムのグループチャットおよびプライベートチャット機能

王林オリジナル: 2023-08-27 14:43:47915ブラウズ

PHP ベースのリアルタイムチャットシステムのグループチャットとプライベートチャット機能

インターネットの発展に伴い、リアルタイムチャットシステムがますます普及しています。私たちの日常生活において、ますます重要性が増しています。ソーシャルメディアプラットフォームで友人とチャットする場合でも、職場の同僚とコミュニケーションを取る場合でも、ライブチャットシステムは重要な役割を果たします。この記事では、PHP を使用して、グループチャットとプライベートチャット機能をサポートするリアルタイムチャットベースのシステムを開発する方法を紹介します。

まず、リアルタイムチャットリクエストを処理するサーバーをセットアップする必要があります。この機能を実装するには、PHP と WebSocket を使用します。 WebSocket は、ブラウザとサーバー間の全二重通信を可能にする TCP ベースのプロトコルです。 PHP では、Ratchet ライブラリを使用して WebSocket サーバーを作成できます。

まず、Ratchet ライブラリをインストールする必要があります。ターミナルで次のコマンドを実行します:

composer require cboden/ratchet

インストールが完了したら、server.php という名前のファイルを作成し、その中に次のコードを記述します:

<?php
require 'vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;
use RatchetWebSocketWsServer;
use RatchetHttpHttpServer;
use RatchetServerIoServer;
use RatchetWampWampServerProtocol;

class Chat 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)
    {
        // 处理客户端发送的消息
        $data = json_decode($msg);
        $type = $data->type;

        switch ($type) {
            case 'register':
                $from->username = $data->username;
                echo "User registered: " . $from->username . "
";
                break;
            case 'group':
                $message = $data->message;
                $this->broadcastMessage($from, $message);
                break;
            case 'private':
                $recipient = $data->recipient;
                $message = $data->message;
                $this->sendPrivateMessage($from, $recipient, $message);
                break;
        }
    }

    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();
    }

    public function broadcastMessage($from, $message)
    {
        foreach ($this->clients as $client) {
            if ($client !== $from) {
                $client->send($message);
            }
        }
    }

    public function sendPrivateMessage($from, $recipient, $message)
    {
        foreach ($this->clients as $client) {
            if ($client->username == $recipient) {
                $client->send($message);
                $from->send($message);
                break;
            }
        }
    }
}

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

$server->run();

上記のコードでは、接続、メッセージの送信、接続の終了などの操作を処理する Chat という名前のクラスを作成しました。 onMessage メソッドでは、メッセージタイプに基づいてさまざまな操作を実行します。タイプが register の場合は、ユーザー登録接続があることを意味します。タイプが group の場合は、グループメッセージを送信しているユーザーがいることを意味します。タイプが ## の場合は、ユーザー登録接続があることを意味します。 #、プライベートメッセージを送信するユーザーがいることを意味します。グループメッセージをブロードキャストするには broadcastMessage メソッドを使用し、プライベートメッセージを送信するには sendPrivateMessage メソッドを使用します。

次に、

index.html というファイルを作成し、その中に次のコードを記述します。

<!DOCTYPE html>
<html>
<head>
    <title>Chat</title>
</head>
<body>
    <input type="text" id="username" placeholder="Username"><br>
    <input type="text" id="message" placeholder="Message"><br>
    <button onclick="register()">Register</button>
    <button onclick="sendGroupMessage()">Send Group Message</button>
    <button onclick="sendPrivateMessage()">Send Private Message</button>

    <script>
        var conn = new WebSocket('ws://localhost:8080');

        conn.onopen = function(e) {
            console.log("Connection established!");
        };

        conn.onmessage = function(e) {
            var chatbox = document.getElementById("chatbox");
            chatbox.innerHTML += e.data + "<br>";
        };

        function register() {
            var username = document.getElementById("username").value;
            var data = {
                type: 'register',
                username: username
            };
            conn.send(JSON.stringify(data));
        }

        function sendGroupMessage() {
            var message = document.getElementById("message").value;
            var data = {
                type: 'group',
                message: message
            };
            conn.send(JSON.stringify(data));
        }

        function sendPrivateMessage() {
            var recipient = document.getElementById("username").value;
            var message = document.getElementById("message").value;
            var data = {
                type: 'private',
                recipient: recipient,
                message: message
            };
            conn.send(JSON.stringify(data));
        }
    </script>
</body>
</html>

上記のコードでは、WebSocket の接続と登録を作成します。接続コールバック関数。

register 関数では、登録のためにユーザー名をサーバーに送信します。 sendGroupMessage 関数では、グループメッセージをサーバーに送信し、サーバーはメッセージをすべてのユーザーにブロードキャストします。 sendPrivateMessage 関数では、指定されたユーザーにプライベートメッセージを送信します。

これで、ターミナルで

php server.php コマンドを実行してサーバーを起動できます。次に、ブラウザで index.html ファイルを開き、ユーザー名を入力して登録ボタンをクリックします。次に、メッセージを入力して送信ボタンをクリックすると、グループチャットまたはプライベートチャットを行うことができます。サーバーは、対応するメッセージを他のユーザーにブロードキャストするか、指定されたユーザーに送信します。

概要:

この記事では、PHP と WebSocket を使用してリアルタイムチャットシステムを開発し、グループチャットとプライベートチャット機能を実装する方法を紹介します。 WebSocket サーバーを作成して通信することで、他のユーザーからのメッセージをリアルタイムで送受信できるようになります。簡単なコード例を使用して、基本的なリアルタイムチャットシステムを実装しました。コードを拡張することで、ユーザー認証の追加やチャット記録の保存など、より多くの機能を実装できます。

以上がPHPベースのリアルタイムチャットシステムのグループチャットおよびプライベートチャット機能の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

php html register 回调函数 private websocket

声明：

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

前の記事：PHP エラーを解決する方法: 予期しない ";" 記号?次の記事：PHP エラーを解決する方法: 予期しない ";" 記号?

続きを見る