ワーカーマンの開発経験の共有: スケーラブルな大規模ネットワーク アプリケーションの構築

ワーカーマンの開発経験の共有: スケーラブルな大規模ネットワーク アプリケーションの構築

はじめに:
今日のインターネットの急速な発展において、ますます多くのインターネット アプリケーションは、多数の同時接続と高負荷を処理します。これらのニーズを満たすために、開発者は効率的で信頼性の高いネットワーク通信フレームワークを選択する必要があります。 Workerman は近年注目を集めているネットワーク プログラミング フレームワークであり、その高いパフォーマンス、拡張性、使いやすさにより、大規模なネットワーク アプリケーションを構築するための最初の選択肢となっています。

1. Workerman の概要
Workerman は、PHP をベースに開発された高性能な非同期ネットワーク プログラミング フレームワークです。従来の同期ブロッキング ネットワーク プログラミング モデルと比較して、Workerman は、多数の同時接続を効率的に処理できる非同期ノンブロッキング ネットワーク プログラミング モデルを採用しています。 Workerman は、イベント駆動型のマルチプロセス アプローチを使用することで、高スループット、低遅延、高同時実行性のネットワーク通信を実現できます。

2. インストールと構成
まず、Composer を通じて Workerman をインストールする必要があります。プロジェクトのルート ディレクトリで次のコマンドを実行します:

composer require workerman/workerman

インストールが完了したら、その後 Workerman クラスと関数を使用するために自動ロード ファイルをプロジェクトに導入できます:

require_once __DIR__ . '/vendor/autoload.php';

次に、ワーカー プロセスの数、リスニング ポートなどの設定など、いくつかの基本的な構成を続行する必要があります。以下は簡単な構成例です。

use WorkermanWorker;

// 创建一个worker实例，监听1234端口
$worker = new Worker('tcp://0.0.0.0:1234');

// 设置worker进程数量
$worker->count = 4;

// worker启动时的回调函数
$worker->onWorkerStart = function ($worker) {
    echo "Worker started
";
};

// 新客户端连接时的回调函数
$worker->onConnect = function ($connection) {
    echo "New connection
";
};

// 接收到数据时的回调函数
$worker->onMessage = function ($connection, $data) {
    echo "Received data: $data
";
};

// 启动worker
Worker::runAll();

上記の構成では、ポート 1234 をリッスンするワーカー インスタンスを作成し、4 つのワーカー プロセスをセットアップしました。新しいクライアントが接続すると onConnect コールバック関数が実行され、クライアントから送信されたデータを受信すると onMessage コールバック関数が実行されます。

3. Workerman を使用してネットワーク アプリケーションを開発する

1. サーバーの作成
   Workerman に基づいてサーバー アプリケーションを作成するには、ワーカー インスタンスを定義して設定するだけです。対応するコールバック関数で十分です。以下は簡単な例です:

   use WorkermanWorker;
   
   // 创建一个worker实例，监听1234端口
   $worker = new Worker('tcp://0.0.0.0:1234');
   
   // 设置worker进程数量
   $worker->count = 4;
   
   // 新客户端连接时的回调函数
   $worker->onConnect = function ($connection) {
    echo "New connection
   ";
   };
   
   // 接收到数据时的回调函数
   $worker->onMessage = function ($connection, $data) {
    echo "Received data: $data
   ";
   };
   
   // 启动worker
   Worker::runAll();

2. クライアントの作成
   Workerman ベースのクライアント アプリケーションを作成するには、クライアント インスタンスを定義し、対応するロジックを記述する必要があります。以下は簡単な例です:

   use WorkermanWorker;
   
   // 创建一个worker实例
   $worker = new Worker();
   
   // 连接服务端
   $connection = new WorkermanConnectionAsyncTcpConnection('tcp://127.0.0.1:1234');
   
   // 连接成功时的回调函数
   $connection->onConnect = function () {
    echo "Connected
   ";
    $connection->send("Hello Server");
   };
   
   // 接收到服务端数据时的回调函数
   $connection->onMessage = function ($connection, $data) {
    echo "Received data: $data
   ";
   };
   
   // 连接断开时的回调函数
   $connection->onClose = function () {
    echo "Connection closed
   ";
   };
   
   // 启动worker
   Worker::runAll();

IV. アプリケーション例
以下は、複数のクライアント間のリアルタイム チャット機能を実現できる簡単なチャット ルーム アプリケーションの例です。 :

use WorkermanWorker;

// 创建一个worker实例
$worker = new Worker('websocket://0.0.0.0:8080');

// 设置worker进程数量
$worker->count = 4;

// 客户端列表
$clients = [];

// 新客户端连接时的回调函数
$worker->onConnect = function ($connection) use (&$clients) {
    echo "New connection
";
    $clients[$connection->id] = $connection;
};

// 接收到消息时的回调函数
$worker->onMessage = function ($connection, $data) use ($clients) {
    echo "Received data: $data
";
    // 广播消息给所有客户端
    foreach ($clients as $client) {
        $client->send($data);
    }
};

// 客户端断开连接时的回调函数
$worker->onClose = function ($connection) use (&$clients) {
    echo "Connection closed
";
    // 从客户端列表中移除断开连接的客户端
    unset($clients[$connection->id]);
};

// 启动worker
Worker::runAll();

概要:
この記事の導入部を通じて、Workerman フレームワークの基本概念、インストールおよび構成方法、使用例について学びました。 Workerman は、その高いパフォーマンス、拡張性、使いやすさにより、大規模なネットワーク アプリケーションを開発するための最初の選択肢となっています。この記事が Web 開発に Workerman を使用する際の皆様のお役に立てれば幸いです。

以上がワーカーマンの開発経験の共有: スケーラブルな大規模ネットワーク アプリケーションの構築の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。