高い同時実行性のインスタンス共有: Swoole はリクエストの集約を通じてビジネスを効率的に実装します

この記事では、Swoole の高同時実行性の集約リクエストの例を紹介し、データベースのバッチ処理を最大限に活用して、高同時実行性のシナリオでのリクエストの集約を通じてビジネス機能をより効率的に実装する方法を紹介します。この例は、より深い思考を刺激することを目的として、出発点としてのみ使用されます。

推奨関連ビデオ コース: 「 数千万のデータ同時実行ソリューション (理論的および実践的) 」

高同時実行性に関する面接の質問をいくつか共有します: 15 高同時実行性に関する PHP 面接の質問 (要約)

この例で選択された背景は、同時注文ビジネスです。通常の状況では、バックエンドで注文を作成するには、insert 操作を 1 つずつ実行します。同時実行性が低い場合、データベースの insert 操作は実際に良好な効率を維持できますが、リクエストの数が増加すると、データベース は単一の insert を頻繁に実行します。注文ビジネスの全体的な効率が低下します (この記事では、単に 1 件の注文 = 1insert) と仮定します。

上記の説明を通じて、最適化が必要な領域を考えるのは実際には簡単です。現実のエレベーターに乗るシーンに似ています。エレベーター は満員になり、その後上昇します 。これにより、人の流れの圧力をできるだけ早く軽減できます。

私たちのアイデアをコードで簡単に実装してみましょう:

<?php

Swoole\Runtime::enableCoroutine($flags = SWOOLE_HOOK_ALL);

// 最大等待次数
const MAX_TIMES = 10;
// 按批处理时, 每一批的最大请求暂留数量
const MAX_REQUEST = 3;
// 服务端最大超时时间, 避免客户端一直等待
const MAX_TIMEOUT = 5;

Co\run(function () {
    // 请求传输的channel, 原因是不要在swoole的协程环境中, 使用多个协程修改同一个全局变量
    // 如果是golang, 当然是可以不定义这里的$rqChannel
    // 只需要简单的将下面的$rqQueue和$times定义为全局变量即可达到一样的效果
    // 但是最好的方式任然是是通过channel共享内存
    $rqChannel = new Swoole\Coroutine\Channel(MAX_REQUEST);

    // 模拟创建订单
    $createOrder = function () use ($rqChannel) {
        // 使用数组模拟请求暂留队列
        $rqQueue = [];
        // 使用等待次数模拟tick效果
        $times = MAX_TIMES;
        while (true) {
            $times--;
            // 必须带上timeout参数, 否则channel是阻塞的
            $rq = $rqChannel->pop(1);
            // 保存1个正常的请求数据
            if (!empty($rq)) {
                $rqQueue[] = $rq;
            }
            // 请求数量未达上限或者还有等待次数时, 提前进入下一次循环
            if ($times > 0 && count($rqQueue) < MAX_REQUEST) {
                continue;
            }
            // 重置等待次数
            $times = MAX_TIMES;
            // 初始化SQL
            $sql = "INSERT INTO orders VALUES ";
            $inserts = [];
            // 模拟数据验证
            $validator = function ($input): bool {
                // 为了缩减代码, 没有真的做数据验证的处理
                array_filter($input);
                return true;
            };
            // $rqQueue在协程上下文是并发安全的, 所以遍历时不用担心
            foreach ($rqQueue as $index => $rq) {
                list($data, $chan) = $rq;
                // 这里可以考虑后置执行, 原因是后面可以有一些补救逻辑
                unset($rqQueue[$index]);
                // 判断$chan是否关闭å
                if ($chan->errCode === SWOOLE_CHANNEL_CLOSED) {
                    $data = null;
                    continue;
                }
                $bool = $validator($data);
                if ($bool) {
                    $inserts[] = "({$data[&#39;user_name&#39;]}, {$data[&#39;amount&#39;]}, {$data[&#39;mobile&#39;]})";
                    $chan->push([&#39;state&#39; => 1]);
                } else {
                    $chan->push([&#39;state&#39; => 0]);
                }
                // unset($rqQueue[$index]);
            }
            $sql .= (implode(&#39;,&#39;, $inserts) . &#39;;&#39;);
            // 模拟创建订单落库的逻辑
            echo $sql;
        }
    };

    // 新手要注意这一句代码的位置, 原因是 $server->start() 之后的代码不会执行
    go($createOrder);

    // 路由处理器
    $orderHandler = function ($rq, $res) use ($rqChannel) {
        $chan = new Swoole\Coroutine\Channel(1);
        // 使用timeout参数模拟超时
        $bool = $rqChannel->push([$rq->post, $chan], MAX_TIMEOUT);
        if (!$bool) {
            // 关闭$chan
            $chan->close();
            $res->end(&#39;timeout&#39;);
        }
        if (!empty($data = $chan->pop())) {
            // 关闭$chan
            $chan->close();
            // 区分成功或失败状态再输出响应
            if ($data[&#39;state&#39;] === 1) {
                $res->end(microtime());
            } else {
                $res->end(&#39;error&#39;);
            }
        }
    };

    $server = new Co\Http\Server("0.0.0.0", 9502, false);

    $server->handle(&#39;/order/create&#39;, $orderHandler);
    // 当前协程容器的终点
    $server->start();
});

コードは全体としてはまだ非常に理解しやすいですが、Variables$rqQueue はエレベーター。保留リクエストが一定時間待機する必要がある回数 $times は、エレベーターが に次々と人が入ってくるのを待つ必要があることに似ています。もちろん、読者の皆様に注目していただきたい最も重要な点は次のとおりです。 コルーチン環境では、通信に共有メモリを使用するのではなく、メモリを共有するために通信を使用します。

推奨学習: swoole チュートリアル

以上が高い同時実行性のインスタンス共有: Swoole はリクエストの集約を通じてビジネスを効率的に実装しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。