Swoole怎么通過聚合請求高效實現業務

這篇文章主要介紹“Swoole怎么通過聚合請求高效實現業務”的相關知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“Swoole怎么通過聚合請求高效實現業務”文章能幫助大家解決問題。

本示例選取的背景是并發下單業務。常規情況下，后端創建訂單是逐條 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['user_name']}, {$data['amount']}, {$data['mobile']})";
                    $chan->push(['state' => 1]);
                } else {
                    $chan->push(['state' => 0]);
                }
                // unset($rqQueue[$index]);
            }
            $sql .= (implode(',', $inserts) . ';');
            // 模擬創建訂單落庫的邏輯
            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('timeout');
        }
        if (!empty($data = $chan->pop())) {
            // 關閉$chan
            $chan->close();
            // 區分成功或失敗狀態再輸出響應
            if ($data['state'] === 1) {
                $res->end(microtime());
            } else {
                $res->end('error');
            }
        }
    };

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

    $server->handle('/order/create', $orderHandler);
    // 當前協程容器的終點
    $server->start();
});

代碼整體上還是很容易理解的，變量 $rqQueue 就是類比電梯，暫留請求等待一定時間的次數 $times 就是類比電梯需要等待人流依次進入。當然最在希望讀者注意的一點是：在協程環境下，不要使用共享內存而通信，應該使用通信來共享內存。

關于“Swoole怎么通過聚合請求高效實現業務”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識，可以關注億速云行業資訊頻道，小編每天都會為大家更新不同的知識點。