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

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

王林

リリース： 2023-08-08 14:49:05

オリジナル

1183 人が閲覧しました

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

はじめに:
今日のインターネットの急速な発展において、ますます多くのインターネットアプリケーションは、多数の同時接続と高負荷を処理します。これらのニーズを満たすために、開発者は効率的で信頼性の高いネットワーク通信フレームワークを選択する必要があります。 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 を使用してネットワークアプリケーションを開発する

サーバーの作成
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();

ログイン後にコピー

クライアントの作成
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 サイトの他の関連記事を参照してください。