Workerman に基づいた同時実行性の高いオンライン注文システムの実装

Workerman をベースとした高同時実行性オンライン注文システム

はじめに:

インターネットの普及と人々の生活水準の向上に伴い、ますます家で料理をする代わりに外食を選ぶ人が増えています。したがって、オンライン注文システムは徐々にケータリング業界の重要な部分になってきました。同時にオンラインで食品を注文する多数のユーザーのニーズを満たすために、高性能 PHP ソケット フレームワークである Workerman を使用して、同時実行性の高いオンライン注文システムを構築できます。

パート 1: 環境の準備

1. PHP のインストール: Workerman は PHP ベースの Socket フレームワークであるため、最初に PHP をサーバーにインストールする必要があります。
2. Composer のインストール: Composer は、サードパーティのライブラリを簡単に導入できる PHP パッケージ管理ツールです。 Composer をサーバーにインストールします。
3. Workerman のインストール: Composer を使用して Workerman ライブラリをインストールし、コマンド composer require workman/workerman を実行します。

パート 2: サーバー側の実装

1. WebSocket サーバーの作成:

   <?php
   require_once __DIR__.'/vendor/autoload.php';
   
   // 创建一个Worker监听8080端口
   $ws_worker = new WorkermanWorker('websocket://0.0.0.0:8080');
   
   // 运行线程数
   $ws_worker->count = 4;
   
   // 处理连接事件
   $ws_worker->onConnect = function ($connection) {
       echo "新连接
   ";
   };
   
   // 处理消息事件
   $ws_worker->onMessage = function ($connection, $data) {
       echo "收到消息：".$data."
   ";
       // TODO：处理消息逻辑
       $connection->send("收到消息：".$data);
   };
   
   // 启动服务器
   WorkermanWorker::runAll();

   このコードは、WebSocket サーバーを作成し、8080 ポートをリッスンします。複数の接続を処理できます。新しい接続が接続されると、onConnect イベントがトリガーされ、メッセージを受信すると、onMessage イベントがトリガーされます。

2. 順序付けロジックの追加:

   // 处理消息事件
   $ws_worker->onMessage = function ($connection, $data) {
       echo "收到消息：".$data."
   ";
       
       // 将收到的消息转换为数组
       $data_array = json_decode($data, true);
       
       // TODO：根据消息内容处理点餐逻辑
       $menu_id = $data_array['menu_id'];
       $menu_name = getMenuName($menu_id);
       $order_id = createOrder($menu_name);
       
       $result = array(
           'status' => 'success',
           'order_id' => $order_id,
       );
       
       // 将处理结果发送给客户端
       $connection->send(json_encode($result));
   };

   メッセージを受信すると、まず受信したメッセージを配列に変換し、次にメッセージの内容に基づいて順序付けロジック処理を実行します。メニュー名の取得や注文の作成などの操作が含まれます。最後に処理結果を配列にカプセル化し、JSON形式に変換してクライアントに送信します。

パート 3: クライアントの実装

クライアントは、Web ブラウザをクライアントとして使用し、JavaScript を通じてサーバーと通信できます。

<script>
// 创建WebSocket对象
var ws = new WebSocket('ws://localhost:8080');

// 连接成功事件
ws.onopen = function() {
    console.log('连接成功');
};

// 收到消息事件
ws.onmessage = function(evt) {
    console.log('收到消息：' + evt.data);
};

// 发送消息
function sendMessage(message) {
    ws.send(message);
}
</script>

この JavaScript コードは、WebSocket オブジェクトを作成し、接続成功イベントとメッセージ受信イベントのコールバック関数を設定します。メッセージを送信するときは、sendMessage 関数を呼び出してメッセージをサーバーに送信できます。

概要:

この記事では、Workerman フレームワークに基づいた高度な同時オンライン注文システムを実装する方法を紹介します。 Workerman の高性能 PHP Socket フレームワークを使用すると、WebSocket サーバーを簡単に作成し、複数の接続と同時リクエストを処理できます。これにより、システムの応答速度が向上し、同時にオンラインで食品を注文する多数のユーザーのニーズを満たすことができます。この記事が皆さんのお役に立てば幸いです。

以上がWorkerman に基づいた同時実行性の高いオンライン注文システムの実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。