已解決 GuzzleHttpPool 并發(fā)請求沒有生效，并發(fā)請求時間是正常一次的疊加，很奇怪呀

tanhongbin 更新于2023-05-05

問題描述

按照文檔中并發(fā)請求使用的，結(jié)果確實時間疊加，并沒有速度快
這里寫問題描述

$client = new Client();

        $requests = function ($total) {
            $uri = 'http://www.baidu.com';
            for ($i = 0; $i < $total; $i++) {
                yield new GRequest('GET', $uri);
            }
        };

        $pool = new Pool($client, $requests(10), [
            'concurrency' => 10,
            'fulfilled' => function ($response, $index) {
                // this is delivered each successful response
            },
            'rejected' => function ($reason, $index) {
                // this is delivered each failed request
            },
        ]);

// Initiate the transfers and create a promise
        $promise = $pool->promise();

// Force the pool of requests to complete.
        $promise->wait();

 2107  2 1

2個回答

nitron 2023-05-05

你那個GRequest里面是不是用requestAsync請求?

tanhongbin 2023-05-05

這個文檔中的源碼，在webman中有Request 沖突所以用了 as 別名，就是文檔中的源碼，但是請求10次的時間是請求一次的時間的10倍，發(fā)現(xiàn)并發(fā)沒起作用

nitron 2023-05-05

你那個GRequest里面是不是用requestAsync請求?


$requests = function () use ($client, $total) {
    $uri = 'http://www.baidu.com';
        for ($i = 0; $i < $total; $i++) {
             yield function() use ($client, $uri) {
            return $client->requestAsync('GET', $uri);
             };
        }
};

tanhongbin 2023-05-05

不是呀，這個是文檔中的 yield new Request('GET', $uri); Request 不是我封裝的，這個和webman 的support\Request有名字沖突，就起了個別名
nitron 2023-05-05

用你代碼試了,沒這個疊加的問題
本機測試,total = 1 , 耗時70ms, total 1-10 耗時 350ms . total 10以上約等于 total / 10 * 350
tanhongbin 2023-05-05

這不就是疊加嘛，并發(fā)請求應該是 total=1 和total = 10 時間差不多的
nitron 2023-05-05

我concurrency用的5
nitron 2023-05-05

total10的時候,concurrency用的1-10都差不多時間,你調(diào)整total和concurrency,你會發(fā)現(xiàn)到達一個閾值的時候,就是疊加,猜測是本身并concurrency有上限
tanhongbin 2023-05-05

按照道理來說，請求一次和請求五次應該是時間一致的，不會相差很大
tanhongbin 2023-05-05

你可以測試一下請求一次和請求五次，concurrency 設置成5試試，如果時間基本一致，那就是對了，如果還是時間疊加，那就不對
lobtao 2023-07-27

用swoole或者workerman 原始的方式試試