Curl 在 Swoole 協程中的解決方案

時間 2019-11-11

標籤 curl swoole 解決方案欄目 Linux 简体版

原文原文鏈接

衆所周知，在 Swoole 應用中，是不推薦使用 Curl 的，由於 Curl 會阻塞進程。php

本文會用實際的代碼和數據，用最直觀的方式，讓你明白爲何。html

最後還會給出 Curl 在 Swoole 中的解決方案，若是不想看分析能夠直接拉到最後。git

例程對比

宇潤看文章不喜歡那些虛的，因此本身寫也比較實在，直接來跑一下代碼，用數據看爲何不推薦在 Swoole 使用 Curl。github

爲了偷懶，我直接用了 YurunHttp 的 Curl 和 Swoole Handler，來替代那些又臭又長的 Curl 代碼。json

代碼

composer.json瀏覽器

{
    "require": {
        "yurunsoft/yurun-http": "~3.0"
    }
}

server.phpswoole

<?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); // 假設各類處理耗時1秒
    $response->end($request->get['id'] . ': ' . date('Y-m-d H:i:s'));
});
$http->start();

test.phpcomposer

<?php

use Yurun\Util\YurunHttp;
use Yurun\Util\HttpRequest;

require __DIR__ . '/vendor/autoload.php';

define('REQUEST_COUNT', 3);

go(function(){
    // 協程客戶端
    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;
});

運行

首次運行須要執行 composer update 安裝依賴curl

運行 php server.php，啓動服務端
運行 php test.php，啓動客戶端

運行結果

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

結果分析

上面的代碼在服務端延遲 1 秒後返回結果，模擬實際業務的耗時。ui

經過客戶端的耗時能夠看出，Curl 3 次請求總共耗時 3 秒多，而協程客戶端僅耗時 1 秒多。

由於前一次請求中，Curl 等待返回內容的時間是幹不了其餘事情的。而協程客戶端等待返回內容期間，是掛起當前協程，轉而再去執行其它協程中的代碼。

解決方案

Coroutine\Http\Client

使用 Swoole 內置的協程客戶端實現，適合有必定基礎的開發者使用。

文檔：https://wiki.swoole.com/wiki/page/p-coroutine_http_client.html

Guzzle-Swoole

咱們在項目中，可能不多直接寫 curl，可是用到的不少第三方類庫（如某某雲們的 SDK）會有用到。

這些第三方類庫一般使用的是 Guzzle 做爲 Http 客戶端，而 Guzzle 底層也是使用 Curl 實現。

宇潤專爲此種場景研發了 Guzzle-Swoole 包，引入後可讓這些 SDK 輕鬆支持協程，而不用修改一行代碼。

使用方法

執行命令直接安裝依賴：composer require yurunsoft/guzzle-swoole ~1.1

全局設定處理器：

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

YurunHttp

YurunHttp 是開源的PHP HTTP類庫，支持鏈式操做，簡單易用。

支持全部常見的GET、POST、PUT、DELETE、UPDATE等請求方式，支持瀏覽器級別 Cookies 管理、上傳下載、設置和讀取header、Cookie、請求參數、失敗重試、限速、代理、證書等。

3.0 版完美支持Curl、Swoole 協程；3.2 版支持 Swoole WebSocket 客戶端。

使用方法

執行命令直接安裝依賴：composer require yurunsoft/yurun-http ~3.2

<?php
use Yurun\Util\YurunHttp;
use Yurun\Util\HttpRequest;

// 設置默認請求處理器爲 Swoole
YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Swoole::class);

// Swoole 處理器必須在協程中調用
go('test');

function test()
{
    $http = new HttpRequest;
    $response = $http->get('http://www.baidu.com');
    echo 'html:', PHP_EOL, $response->body();
}