Advanced Workerman ネットワークプログラミング: 同時実行性の高いインスタントメッセージングシステムの実装-Workerman-php.cn

Advanced Workerman ネットワークプログラミング: 同時実行性の高いインスタントメッセージングシステムの実装

WBOY

リリース： 2023-08-05 16:09:07

オリジナル

1107 人が閲覧しました

Workerman Network Programming Advanced: 高同時実行インスタントメッセージングシステムの実装

モバイルインターネットの普及に伴い、インスタントメッセージングシステムは私たちの生活の中でますます重要な役割を果たしています。同時実行性の高いインスタントメッセージングシステムの実装は、ネットワークプログラミングを学習するための重要なマイルストーンです。この記事では、Workerman フレームワークを使用して同時実行性の高いインスタントメッセージングシステムを実装し、コード例を通じて実装プロセスを詳しく紹介します。

まず、Workerman フレームワークをインストールする必要があります。 Workerman は軽量の PHP 非同期ネットワークプログラミングフレームワークであり、豊富なネットワークプログラミング機能を提供し、同時実行性の高いインスタントメッセージングシステムの実装のニーズを満たすことができます。 Workerman は、composer を通じてインストールし、次のコマンドを実行できます。

composer require workerman/workerman

ログイン後にコピー

インストールが完了したら、同時実行性の高いインスタントメッセージングシステムを実装するコードの作成を開始できます。

サーバークラスの作成

まず、クライアント接続とメッセージ送信を処理するサーバークラスを作成します。コード例は次のとおりです。

use WorkermanWorker;

class ChatServer
{
    protected $clients;
    
    public function __construct()
    {
        $this->clients = new SplObjectStorage;
        
        $ws_worker = new Worker('websocket://0.0.0.0:8000');
        
        $ws_worker->onConnect = function($connection) {
            $this->clients->attach($connection);
            echo "New client connected
";
        };
        
        $ws_worker->onMessage = function($connection, $data) {
            // 处理接收到的消息
            foreach ($this->clients as $client) {
                $client->send($data);
            }
        };
        
        $ws_worker->onClose = function($connection) {
            $this->clients->detach($connection);
            echo "Client disconnected
";
        };
        
        Worker::runAll();
    }
}

new ChatServer();

ログイン後にコピー

上記のコードでは、まず Workerman Worker オブジェクトを作成し、そのリスニングアドレスとポートを websocket://0.0.0.0:8000 に設定します。次に、クライアントの接続、受信メッセージ、切断をそれぞれ処理する 3 つのコールバック関数が定義されます。 onConnect コールバック関数では、SplObjectStorage を使用してすべてのクライアント接続オブジェクトを保存します。 onMessage コールバック関数では、すべてのクライアント接続オブジェクトを反復処理し、受信したメッセージを各クライアントに送信します。 onClose コールバック関数では、切断されたクライアントオブジェクトを SplObjectStorage から削除します。

クライアントページの作成

次に、サーバーに接続してメッセージを送受信するためのクライアントページを作成します。コード例は次のとおりです。

<!DOCTYPE html>
<html>
<head>
    <title>Chat App</title>
    <style>
        #messages {
            height: 300px;
            overflow-y: scroll;
        }
    </style>
</head>
<body>
    <div id="messages"></div>
    <form id="form">
        <input type="text" id="message" autocomplete="off">
        <button>Send</button>
    </form>

    <script>
        const messages = document.getElementById('messages');
        const form = document.getElementById('form');
        const input = document.getElementById('message');
        
        const ws = new WebSocket('ws://localhost:8000');
        
        ws.onopen = function() {
            console.log('Connected to the server');
        };
        
        ws.onmessage = function(event) {
            const message = document.createElement('div');
            message.textContent = event.data;
            messages.appendChild(message);
        };
        
        form.addEventListener('submit', function(event) {
            event.preventDefault();
            
            const message = input.value;
            input.value = '';
            
            ws.send(message);
        });
    </script>
</body>
</html>

ログイン後にコピー

上記のコードでは、WebSocket 接続オブジェクトを作成し、サーバーのアドレス ws://localhost:8000 に接続します。次に、onopen、onmessage、および submit イベントのハンドラー関数が定義されます。 onmessage コールバック関数では、div 要素を作成し、受信したメッセージを div 要素に追加してから、その div 要素をページ上のmessages 要素に追加します。 submit イベントのハンドラー関数で、入力ボックス内のテキストを取得し、サーバーに送信します。

コードの実行

上記の 2 つのコードをそれぞれ、server.php および client.html ファイルとして保存します。コマンドラインで次のコマンドを実行します。

php server.php start

ログイン後にコピー

次に、ブラウザで client.html ファイルを開きます。 WebSocket を通じて実装されたインスタントメッセージングシステムページにアクセスできます。複数のクライアントがサーバーに接続した後、メッセージをリアルタイムで送信し、メッセージリストに表示できます。

概要:

上記のコード例を通じて、サーバークラスの作成からクライアントページの作成まで、Workerman フレームワークに基づいた同時実行性の高いインスタントメッセージングシステムを実装しました。この例を学習することで、ネットワークプログラミングにおける同時実行性の高い処理についてより深く理解できます。同時に、強力なネットワークアプリケーションをより迅速に開発できる Workerman フレームワークのパワーとシンプルさについても学びました。この記事がネットワークプログラミングの学習と Workerman フレームワークの使用に役立つことを願っています。

以上がAdvanced Workerman ネットワークプログラミング: 同時実行性の高いインスタントメッセージングシステムの実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。