높은 동시성 인스턴스 공유: Swoole은 요청 집계를 통해 비즈니스를 효율적으로 구현합니다.

이 글에서는 Swoole의 높은 동시성 집계 요청의 예를 공유하고, 높은 동시성 시나리오에서 요청 집계를 통해 데이터베이스의 일괄 처리를 최대한 활용하여 비즈니스 기능을 보다 효율적으로 구현하는 방법을 소개합니다. 이 예는 보다 심층적인 사고를 자극하기 위한 출발점으로만 사용됩니다.

추천 관련 동영상 강좌: "수백만 개의 데이터 동시성 솔루션(이론 + 실무) "

높은 동시성 인터뷰 질문 공유: 높은 동시성에 대한 PHP 인터뷰 질문 15개(요약)

이번 사례에서 선택한 배경은 동시주문 사업이다. 일반적인 상황에서 백엔드에서 주문을 생성하는 것은 하나씩 삽입 작업입니다. 동시성이 낮을 때는 데이터베이스의 insert 작업이 실제로 좋은 효율성을 유지할 수 있지만, 요청 수가 증가하면 데이터베이스가 단일 insert를 자주 수행하게 됩니다insert 的操作。在并发较低的时候，数据库的 insert 操作的确能保持不错的效率，但是当遇到请求数量增多，数据库 频繁地单次 insert 就会让下单业务整体效率变低 （本文简单地假设1次下单=1个 insert）。

通过上面的描述，其实已经很容易想到需要优化的地方了。类比现实生活中乘坐电梯的场景：一架电梯 装满后再上行，可以最快地缓解人流压力。

下面我们就来用代码简单实现一下我们思路：

<?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();
});

代码整体上还是很容易理解的，变量 $rqQueue 就是类比电梯，暂留请求等待一定时间的次数 $times 전체적인 효율성을 높이세요 of ordering business lower(이 글에서는 단순히 주문 1건 = 삽입 1건이라고 가정합니다).

위의 설명을 통해 실제로 최적화가 필요한 영역을 쉽게 생각해 볼 수 있습니다. 실생활에서 엘리베이터를 타는 장면에 비유하면 엘리베이터는

올라가기 전에 가득 차서, 사람들의 흐름에 따른 압박감을 최대한 빨리 완화할 수 있습니다.

이제 우리의 아이디어를 코드로 간단히 구현해 보겠습니다. 🎜rrreee🎜코드 전체는 여전히 이해하기 쉽습니다. 🎜변수 $rqQueue는 엘리베이터에 비유됩니다. 요청은 일정 시간$times 동안 기다려야 합니다. 이는 엘리베이터가 사람들의 흐름이 차례로 들어올 때까지 기다려야 한다는 사실과 유사합니다🎜. 물론 독자들이 주목하길 바라는 가장 중요한 점은 🎜코루틴 환경에서는 통신을 위해 공유 메모리를 사용하지 마세요🎜. 🎜🎜추천 학습: 🎜swoole 튜토리얼🎜🎜

위 내용은 높은 동시성 인스턴스 공유: Swoole은 요청 집계를 통해 비즈니스를 효율적으로 구현합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!