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

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

Aug 05, 2023 pm 04:09 PM
高い同時実行性 workerman ネットワークプログラミング

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

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

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

composer require workerman/workerman
ログイン後にコピー

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

  1. サーバー クラスの作成

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

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 から削除します。

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

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

<!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 イベントのハンドラー関数で、入力ボックス内のテキストを取得し、サーバーに送信します。

  1. コードの実行

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

php server.php start
ログイン後にコピー

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

概要:

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

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

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

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

Video Face Swap

Video Face Swap

完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

C++ オープンソース ライブラリとは何ですか? C++ オープンソース ライブラリとは何ですか? Apr 22, 2024 pm 05:48 PM

C++ は、次の機能をカバーするオープン ソース ライブラリの豊富なセットを提供します: データ構造とアルゴリズム (標準テンプレート ライブラリ) マルチスレッド、正規表現 (Boost) 線形代数 (Eigen) グラフィカル ユーザー インターフェイス (Qt) コンピューター ビジョン (OpenCV) 機械学習(TensorFlow) 暗号化 (OpenSSL) データ圧縮 (zlib) ネットワーク プログラミング (libcurl) データベース管理 (sqlite3)

C++ 関数はネットワーク プログラミングで DNS クエリをどのように処理しますか? C++ 関数はネットワーク プログラミングで DNS クエリをどのように処理しますか? Apr 27, 2024 pm 06:39 PM

C++ 標準ライブラリは、ネットワーク プログラミングで DNS クエリを処理する関数を提供します。 gethostbyname(): ホスト名に基づいてホスト情報を検索します。 gethostbyaddr(): IP アドレスに基づいてホスト情報を検索します。 dns_lookup(): DNS を非同期的に解決します。

Java ネットワーク プログラミングの一般的なプロトコルは何ですか? Java ネットワーク プログラミングの一般的なプロトコルは何ですか? Apr 15, 2024 am 11:33 AM

Java ネットワーク プログラミングで一般的に使用されるプロトコルには次のものがあります。 TCP/IP: 信頼性の高いデータ送信と接続管理に使用されます。 HTTP: Web データの送信に使用されます。 HTTPS: 暗号化を使用してデータを送信する安全なバージョンの HTTP。 UDP: 高速だが不安定なデータ転送。 JDBC: リレーショナル データベースと対話するために使用されます。

Java ネットワーク プログラミングでは、コネクションレス通信に UDP をどのように使用しますか? Java ネットワーク プログラミングでは、コネクションレス通信に UDP をどのように使用しますか? Apr 15, 2024 pm 12:51 PM

UDP (User Datagram Protocol) は、時間に敏感なアプリケーションで一般的に使用される軽量のコネクションレス型ネットワーク プロトコルです。これにより、アプリケーションは TCP 接続を確立せずにデータを送受信できるようになります。サンプル Java コードを使用して UDP サーバーとクライアントを作成できます。サーバーは受信データグラムをリッスンして応答し、クライアントはメッセージを送信して応答を受信します。このコードを使用して、チャット アプリケーションやデータ収集システムなどの実際のユースケースを構築できます。

C++ 関数はネットワーク プログラミングでネットワーク セキュリティをどのように実装しますか? C++ 関数はネットワーク プログラミングでネットワーク セキュリティをどのように実装しますか? Apr 28, 2024 am 09:06 AM

C++ 関数は、ネットワーク プログラミングでネットワーク セキュリティを実現できます。その方法には、1. 暗号化アルゴリズム (openssl) を使用して通信を暗号化する、2. デジタル署名 (cryptopp) を使用してデータの整合性と送信者の身元を確認する、3. クロスサイト スクリプティング攻撃に対する防御、および( htmlcxx) ユーザー入力をフィルタリングしてサニタイズします。

高同時実行システムにおける Golang フレームワークのアーキテクチャ 高同時実行システムにおける Golang フレームワークのアーキテクチャ Jun 03, 2024 pm 05:14 PM

同時実行性の高いシステムの場合、Go フレームワークはパイプライン モード、Goroutine プール モード、メッセージ キュー モードなどのアーキテクチャ モードを提供します。実際の場合、同時実行性の高い Web サイトでは、Nginx プロキシ、Golang ゲートウェイ、Goroutine プール、およびデータベースを使用して、多数の同時リクエストを処理します。このコード例は、受信リクエストを処理するための Goroutine プールの実装を示しています。適切なアーキテクチャ パターンと実装を選択することで、Go フレームワークはスケーラブルで同時実行性の高いシステムを構築できます。

同時実行性の高いシナリオにおける PHP フレームワークのパフォーマンス 同時実行性の高いシナリオにおける PHP フレームワークのパフォーマンス Jun 06, 2024 am 10:25 AM

ベンチマーク テストによると、同時実行性の高いシナリオにおける PHP フレームワークのパフォーマンスは、Phalcon (RPS2200)、Laravel (RPS1800)、CodeIgniter (RPS2000)、および Symfony (RPS1500) です。実際の事例では、電子商取引 Web サイトのダブル イレブン イベント中に、Phalcon フレームワークが 1 秒あたり 3,000 件の注文を達成したことが示されています。

スクラッチとパイソンの違い スクラッチとパイソンの違い Apr 20, 2024 pm 11:59 PM

Scratch と Python の違いは次のとおりです。 対象読者: Scratch は初心者および教育現場を対象としているのに対し、Python は中級から上級のプログラマーを対象としています。構文: Scratch はドラッグ アンド ドロップのビルディング ブロック インターフェイスを使用しますが、Python はテキスト構文を使用します。特徴: Scratch は使いやすさとビジュアル プログラミングに重点を置いているのに対し、Python はより高度な機能と拡張性を提供します。

See all articles