Curl 在 Swoole 协程中的解决方案

清华大佬耗费三个月吐血整理的几百G的资源，免费分享！....>>>

Curl 在 Swoole 协程中的解决方案

众所周知，在 Swoole 应用中，是不推荐使用 Curl 的，因为 Curl 会阻塞进程。

composer.json

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

<?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.php

<?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 安装依赖
运行 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

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

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

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

截止发稿时，Swoole 4.4 新增的 hook Curl 依然是实验性功能。虽然宇润曾为该功能贡献过一部分代码，但是由于需要兼容的工作量非常大，有太多 OPTION 不被支持，我个人是暂时不推荐使用 hook Curl 的。