webman中，v5 http-client 协程与guzzlehttp异步并发请求对比

问题描述

webman中，【workerman v5 http-client 协程】与【guzzlehttp/guzzle 异步并发请求】对比优势，似乎并不明显。

这几天研究workerman v5的http-client协程的，目的是提高程序中IO请求的性能。发现协程的方式并不能减少请求时间，而且对并发提升也不多。

• 安装http-client

  php8.1 /usr/local/bin/composer require workerman/workerman v5.0.0-beta.5 revolt/event-loop ^1.0.0 workerman/http-client ^2.0.0

• 安装Http客户端

  php8.1 /usr/local/bin/composer require yzh52521/easyhttp

测试数据

• 对同一post接口连续请求2次，分别使用http-client协程、easyhttp同步、easyhttp异步并发的方式，并使用ab压测。

http-client协程方式代码

app\controller\IndexController::demo1()
执行时间：163ms

$start = Carbon::now();

$http = new Client();

$response1 = $http->request('http://服务iP:8002/search', [
    'method' => 'POST',
    'headers' => [
        'Content-Type' => 'application/json',
    ],
    'data' => json_encode([
    'query' => '我是谁',
    'limit' => 5
    ])

]);

$response2 = $http->request('http://服务iP:8002/search', [
    'method' => 'POST',
    'headers' => [
        'Content-Type' => 'application/json',
    ],
    'data' => json_encode([
        'query' => '我不知道',
        'limit' => 5
    ])

]);

$response = array_merge(json_decode($response1->getBody(), true),
json_decode($response2->getBody(), true)
);

$runtime = Carbon::now()->diffInMilliseconds($start);

return json([
'runtime' => $runtime . 'ms',
'data' => $response
]);

压测结果
ab -n 1000 -c 50 http://192.168.10.10:5001/index/demo1

Server Software:        workerman
Server Hostname:        192.168.10.10
Server Port:            5001

Document Path:          /index/demo1
Document Length:        2867 bytes

Concurrency Level:      50
Time taken for tests:   33.856 seconds
Complete requests:      1000
Failed requests:        999
   (Connect: 0, Receive: 0, Length: 999, Exceptions: 0)
Total transferred:      2983999 bytes
HTML transferred:       2867999 bytes
Requests per second:    29.54 [#/sec] (mean)
Time per request:       1692.787 [ms] (mean)
Time per request:       33.856 [ms] (mean, across all concurrent requests)
Transfer rate:          86.07 [Kbytes/sec] received

Connection Times (ms)
              min  mean[+/-sd] median   max
Connect:        0    0   1.2      0      16
Processing:   987 1670 196.8   1689    2228
Waiting:      987 1670 196.8   1689    2228
Total:        991 1670 196.6   1690    2228

Percentage of the requests served within a certain time (ms)
  50%   1690
  66%   1756
  75%   1777
  80%   1801
  90%   1900
  95%   2033
  98%   2082
  99%   2104
 100%   2228 (longest request)

easyhttp同步

app\controller\IndexController::demo2()
执行时间：168ms

$start = Carbon::now();

$response1 = Http::asJson()->post('http://服务iP:8002/search', [
    'query' => '我不知道',
    'limit' => 5
]);
$response2 = Http::asJson()->post('http://服务iP:8002/search', [
    'query' => '我不知道',
    'limit' => 5
]);

$response = array_merge($response1->json(), $response2->json());

$runtime = Carbon::now()->diffInMilliseconds($start);

return json([
    'runtime' => $runtime . 'ms',
    'data' => $response
]);

压测结果
ab -n 1000 -c 50 http://192.168.10.10:5001/index/demo2

Server Software:        workerman
Server Hostname:        192.168.10.10
Server Port:            5001

Document Path:          /index/demo2
Document Length:        3008 bytes

Concurrency Level:      50
Time taken for tests:   35.976 seconds
Complete requests:      1000
Failed requests:        0
Total transferred:      3124000 bytes
HTML transferred:       3008000 bytes
Requests per second:    27.80 [#/sec] (mean)
Time per request:       1798.794 [ms] (mean)
Time per request:       35.976 [ms] (mean, across all concurrent requests)
Transfer rate:          84.80 [Kbytes/sec] received

Connection Times (ms)
              min  mean[+/-sd] median   max
Connect:        0    0   0.5      0       3
Processing:   189 1758 1414.9   1747   13011
Waiting:      189 1758 1414.9   1747   13011
Total:        192 1758 1415.1   1747   13012

Percentage of the requests served within a certain time (ms)
  50%   1747
  66%   1780
  75%   1803
  80%   1856
  90%   1913
  95%   1960
  98%   7578
  99%  10454
 100%  13012 (longest request)

easyhttp异步并发

app\controller\IndexController::demo3()
执行时间：167ms

$aa = [];
$start = Carbon::now();

$promises = [
    Http::asJson()->postAsync('http://服务iP:8002/search', [
        'query' => '我不知道',
        'limit' => 5
    ]),
    Http::asJson()->postAsync('http://服务iP:8002/search', [
        'query' => '我不知道',
        'limit' => 5
    ])
];
$pool = Http::multiAsync($promises, function (Response $response, $index) use (&$aa) {
    $aa[] = $response->json();
    echo "发起第 $index 个异步请求" . PHP_EOL;
});

$pool->promise()->wait();
$runtime = Carbon::now()->diffInMilliseconds($start);
return json([
    'runtime' => $runtime . 'ms',
    'data' => $aa
]);

压测结果
ab -n 1000 -c 50 http://192.168.10.10:5001/index/demo3

Server Software:        workerman
Server Hostname:        192.168.10.10
Server Port:            5001

Document Path:          /index/demo3
Document Length:        3012 bytes

Concurrency Level:      50
Time taken for tests:   36.145 seconds
Complete requests:      1000
Failed requests:        0
Total transferred:      3128000 bytes
HTML transferred:       3012000 bytes
Requests per second:    27.67 [#/sec] (mean)
Time per request:       1807.252 [ms] (mean)
Time per request:       36.145 [ms] (mean, across all concurrent requests)
Transfer rate:          84.51 [Kbytes/sec] received

Connection Times (ms)
              min  mean[+/-sd] median   max
Connect:        0    0   0.6      0       4
Processing:   170 1767 862.1   1775    9789
Waiting:      170 1767 862.1   1775    9789
Total:        174 1767 862.3   1776    9790

Percentage of the requests served within a certain time (ms)
  50%   1776
  66%   1800
  75%   1816
  80%   1834
  90%   1871
  95%   1912
  98%   4249
  99%   7172
 100%   9790 (longest request)

结论：

使用http-client协程客户端的方式，相对比guzzlehttp同步、异步并发，似乎并不能提高多少性能，而且单次消耗时间是差不多的，是我用法有问题吗？

后面发现是因为第三方接口成为瓶颈，在第三方接口不是瓶颈的情况下，webman协程http-client方式性能提升非常明显