在 Swoole 應(yīng)用中，是不推薦使用 Curl 的，因為 Curl 會阻塞進程。
本文會用實際的代碼和數(shù)據(jù)，用最直觀的方式，讓你明白為什么。
最后還會給出 Curl 在 Swoole 中的解決方案，如果不想看分析可以直接拉到最后。
例程對比
宇潤看文章不喜歡那些虛的，所以自己寫也比較實在，直接來跑一下代碼，用數(shù)據(jù)看為什么不推薦在 Swoole 使用 Curl。
為了偷懶，我直接用了 YurunHttp 的 Curl 和 Swoole Handler，來替代那些又臭又長的 Curl 代碼。
代碼
composer.json
{
"require": {
"yurunsoft/yurun-http": "~3.0"
}
}
server.php
<?php
$http = new Swoole\Http\Server('127.0.0.1', 9501);
$http->on('workerstart', function(){
\Swoole\Runtime::enableCoroutine();
});
$http->on('request', function ($request, $response) {
sleep(1); // 假設(shè)各種處理耗時1秒
$response->end($request->get['id'] . ': ' . date('Y-m-d H:i:s'));
});
$http->start();
test.php
<?php
use Yurun\Util\YurunHttp;
use Yurun\Util\HttpRequest;
require __DIR__ . '/vendor/autoload.php';
define('REQUEST_COUNT', 3);
go(function(){
// 協(xié)程客戶端
echo 'coroutine http client:', PHP_EOL, PHP_EOL;
$time = microtime(true);
YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Swoole::class); // 切換為 Swoole Handler
$channel = new \Swoole\Coroutine\Channel;
for($i = 0; $i < REQUEST_COUNT; ++$i)
{
go(function() use($channel, $i){
$http = new HttpRequest;
$response = $http->get('http://127.0.0.1:9501/?id=' . $i); // 請求地址
var_dump($response->body());
$channel->push(1);
});
}
for($i = 0; $i < REQUEST_COUNT; ++$i)
{
$channel->pop();
}
$channel->close();
echo 'coroutine http client time: ', (microtime(true) - $time) . 's', PHP_EOL, PHP_EOL;
// curl
echo 'curl:', PHP_EOL, PHP_EOL;
$time = microtime(true);
YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Curl::class); // 切換為 Curl Handler
$channel = new \Swoole\Coroutine\Channel;
for($i = 0; $i < REQUEST_COUNT; ++$i)
{
go(function() use($channel, $i){
$http = new HttpRequest;
$response = $http->get('http://127.0.0.1:9501/?id=' . $i); // 請求地址
var_dump($response->body());
$channel->push(1);
});
}
for($i = 0; $i < REQUEST_COUNT; ++$i)
{
$channel->pop();
}
$channel->close();
echo 'curl time: ', (microtime(true) - $time) . 's', PHP_EOL, PHP_EOL;
});
運行
首次運行需要執(zhí)行 composer update 安裝依賴
運行 php server.php，啟動服務(wù)端
運行 php test.php，啟動客戶端
運行結(jié)果
coroutine http client:
string(22) "1: 2019-09-11 08:35:54"
string(22) "0: 2019-09-11 08:35:54"
string(22) "2: 2019-09-11 08:35:54"
coroutine http client time: 1.0845630168915s
curl:
string(22) "0: 2019-09-11 08:35:55"
string(22) "1: 2019-09-11 08:35:56"
string(22) "2: 2019-09-11 08:35:57"
curl time: 3.0139901638031s
結(jié)果分析
上面的代碼在服務(wù)端延遲 1 秒后返回結(jié)果，模擬實際業(yè)務(wù)的耗時。
通過客戶端的耗時可以看出，Curl 3 次請求總共耗時 3 秒多，而協(xié)程客戶端僅耗時 1 秒多。
因為前一次請求中，Curl 等待返回內(nèi)容的時間是干不了其他事情的。而協(xié)程客戶端等待返回內(nèi)容期間，是掛起當(dāng)前協(xié)程，轉(zhuǎn)而再去執(zhí)行其它協(xié)程中的代碼。
解決方案
Coroutine\Http\Client
使用 Swoole 內(nèi)置的協(xié)程客戶端實現(xiàn)，適合有一定基礎(chǔ)的開發(fā)者使用。
文檔：https://wiki.swoole.com/wiki/page/p-coroutine_http_client.html
Guzzle-Swoole
我們在項目中，可能很少直接寫 curl，但是用到的很多第三方類庫（如某某云們的 SDK）會有用到。
這些第三方類庫通常使用的是 Guzzle 作為 Http 客戶端，而 Guzzle 底層也是使用 Curl 實現(xiàn)。
宇潤專為此種場景研發(fā)了 Guzzle-Swoole 包，引入后可以讓這些 SDK 輕松支持協(xié)程，而不用修改一行代碼。
使用方法
執(zhí)行命令直接安裝依賴：composer require yurunsoft/guzzle-swoole ~1.1
全局設(shè)定處理器：
<?php
require dirname(__DIR__) . '/vendor/autoload.php';
use GuzzleHttp\Client;
use Yurun\Util\Swoole\Guzzle\SwooleHandler;
use GuzzleHttp\DefaultHandler;
DefaultHandler::setDefaultHandler(SwooleHandler::class);
go(function(){
$client = new Client();
$response = $client->request('GET', 'http://www.baidu.com', [
'verify' => false,
]);
var_dump($response->getStatusCode());
});
手動指定 Swoole 處理器：
use GuzzleHttp\Client;
use GuzzleHttp\HandlerStack;
use Yurun\Util\Swoole\Guzzle\SwooleHandler;
go(function(){
$handler = new SwooleHandler();
$stack = HandlerStack::create($handler);
$client = new Client(['handler' => $stack]);
$response = $client->request('GET', 'http://www.baidu.com', [
'verify' => false,
]);
var_dump($response->getBody()->__toString(), $response->getHeaders());
});
