当前位置:首页 > PHP教程 > php高级应用 > 列表

关于Curl在Swoole协程中的解决方案详析

发布:smiling 来源: PHP粉丝网  添加日期:2021-12-17 11:37:27 浏览: 评论:0 

前言

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

本文会用实际的代码和数据,用最直观的方式,让你明白为什么。

最后还会给出 Curl 在 Swoole 中的解决方案,如果不想看分析可以直接拉到最后。

例程对比

宇润看文章不喜欢那些虚的,所以自己写也比较实在,直接来跑一下代码,用数据看为什么不推荐在 Swoole 使用 Curl。

为了偷懒,我直接用了 YurunHttp 的 Curl 和 Swoole Handler,来替代那些又臭又长的 Curl 代码。

代码

composer.json

  1.   "require": { 
  2.     "yurunsoft/yurun-http""~3.0" 
  3.   } 

server.php

  1. <?php 
  2. $http = new Swoole\Http\Server('127.0.0.1', 9501); 
  3. $http->on('workerstart'function(){ 
  4.   \Swoole\Runtime::enableCoroutine(); 
  5. }); 
  6. $http->on('request'function ($request$response) { 
  7.   sleep(1); // 假设各种处理耗时1秒 
  8.   $response->end($request->get['id'] . ': ' . date('Y-m-d H:i:s')); 
  9. }); 
  10. $http->start(); 

test.php

  1. <?php 
  2.  
  3. use Yurun\Util\YurunHttp; 
  4. use Yurun\Util\HttpRequest; 
  5.  
  6. require __DIR__ . '/vendor/autoload.php'
  7.  
  8. define('REQUEST_COUNT', 3); 
  9.  
  10. go(function(){ 
  11.   // 协程客户端 
  12.   echo 'coroutine http client:', PHP_EOL, PHP_EOL; 
  13.   $time = microtime(true); 
  14.   YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Swoole::class); // 切换为 Swoole Handler 
  15.   $channel = new \Swoole\Coroutine\Channel; 
  16.   for($i = 0; $i < REQUEST_COUNT; ++$i
  17.   { 
  18.     go(function() use($channel$i){ 
  19.       $http = new HttpRequest; 
  20.       $response = $http->get('http://127.0.0.1:9501/?id=' . $i); // 请求地址 
  21.       var_dump($response->body()); 
  22.       $channel->push(1); 
  23.     }); 
  24.   } 
  25.   for($i = 0; $i < REQUEST_COUNT; ++$i
  26.   { 
  27.     $channel->pop(); 
  28.   } 
  29.   $channel->close(); 
  30.   echo 'coroutine http client time: ', (microtime(true) - $time) . 's', PHP_EOL, PHP_EOL; 
  31.  
  32.   // curl 
  33.   echo 'curl:', PHP_EOL, PHP_EOL; 
  34.   $time = microtime(true); 
  35.   YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Curl::class); // 切换为 Curl Handler 
  36.   $channel = new \Swoole\Coroutine\Channel; 
  37.   for($i = 0; $i < REQUEST_COUNT; ++$i
  38.   { 
  39.     go(function() use($channel$i){ 
  40.       $http = new HttpRequest; 
  41.       $response = $http->get('http://127.0.0.1:9501/?id=' . $i); // 请求地址 
  42.       var_dump($response->body()); 
  43.       $channel->push(1); 
  44.     }); 
  45.   } 
  46.   for($i = 0; $i < REQUEST_COUNT; ++$i
  47.   { 
  48.     $channel->pop(); 
  49.   } 
  50.   $channel->close(); 
  51.   echo 'curl time: ', (microtime(true) - $time) . 's', PHP_EOL, PHP_EOL; 
  52. }); 

运行

首次运行需要执行 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

结果分析

上面的代码在服务端延迟 1 秒后返回结果,模拟实际业务的耗时。

通过客户端的耗时可以看出,Curl 3 次请求总共耗时 3 秒多,而协程客户端仅耗时 1 秒多。

因为前一次请求中,Curl 等待返回内容的时间是干不了其他事情的。而协程客户端等待返回内容期间,是挂起当前协程,转而再去执行其它协程中的代码。

解决方案

CoroutineHttpClient

使用 Swoole 内置的协程客户端实现,适合有一定基础的开发者使用。

文档:https://wiki.swoole.com/wiki/...

Guzzle-Swoole

我们在项目中,可能很少直接写 curl,但是用到的很多第三方类库(如某某云们的 SDK)会有用到。

这些第三方类库通常使用的是 Guzzle 作为 Http 客户端,而 Guzzle 底层也是使用 Curl 实现。

宇润专为此种场景研发了 Guzzle-Swoole 包,引入后可以让这些 SDK 轻松支持协程,而不用修改一行代码。

使用方法

执行命令直接安装依赖:composer require yurunsoft/guzzle-swoole ~1.1

全局设定处理器:

  1. <?php 
  2. require dirname(__DIR__) . '/vendor/autoload.php'
  3.  
  4. use GuzzleHttp\Client; 
  5. use Yurun\Util\Swoole\Guzzle\SwooleHandler; 
  6. use GuzzleHttp\DefaultHandler; 
  7.  
  8. DefaultHandler::setDefaultHandler(SwooleHandler::class); 
  9.  
  10. go(function(){ 
  11.   $client = new Client(); 
  12.   $response = $client->request('GET''http://www.phpfensi.com', [ 
  13.     'verify'  => false, 
  14.   ]); 
  15.   var_dump($response->getStatusCode()); 
  16. }); 

手动指定 Swoole 处理器:

  1. use GuzzleHttp\Client; 
  2. use GuzzleHttp\HandlerStack; 
  3. use Yurun\Util\Swoole\Guzzle\SwooleHandler; 
  4.  
  5. go(function(){ 
  6.   $handler = new SwooleHandler(); 
  7.   $stack = HandlerStack::create($handler); 
  8.   $client = new Client(['handler' => $stack]); 
  9.   $response = $client->request('GET''http://www.baidu.com', [ 
  10.     'verify'  => false, 
  11.   ]); 
  12.   var_dump($response->getBody()->__toString(), $response->getHeaders()); 
  13. }); 

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

  1. <?php 
  2. use Yurun\Util\YurunHttp; 
  3. use Yurun\Util\HttpRequest; 
  4.  
  5. // 设置默认请求处理器为 Swoole 
  6. YurunHttp::setDefaultHandler(\Yurun\Util\YurunHttp\Handler\Swoole::class); 
  7.  
  8. // Swoole 处理器必须在协程中调用 
  9. go('test'); 
  10.  
  11. function test() 
  12.   $http = new HttpRequest; 
  13.   $response = $http->get('http://www.baidu.com'); 
  14.   echo 'html:', PHP_EOL, $response->body(); 

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

Tags: Curl Swoole

分享到: