关于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
- {
- "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); // 假设各种处理耗时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
结果分析
上面的代码在服务端延迟 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
全局设定处理器:
- <?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.phpfensi.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();
- }
截止发稿时,Swoole 4.4 新增的 hook Curl 依然是实验性功能,虽然宇润曾为该功能贡献过一部分代码,但是由于需要兼容的工作量非常大,有太多 OPTION 不被支持,我个人是暂时不推荐使用 hook Curl 的。
Tags: Curl Swoole
相关文章
- ·php curl常见错误:SSL错误、bool(false)(2013-11-30)
- ·curl out of memory window下PHP调用curl报内存不够(2013-12-06)
- ·windows 下 php curl 的支持配置方法(2013-12-06)
- ·PHP 利用curl_init发起http请求模仿登录(2014-01-06)
- ·php curl 伪造IP来源程序实现代码(2014-01-07)
- ·php curl 分离header和body信息(2014-01-07)
- ·PHP curl 获取响应的状态实例(2014-01-08)
- ·php curl模块模拟登录后采集页面实例(2014-01-08)
- ·PHP Curl多线程实现原理与实例详解(2014-01-09)
- ·Drupal 通过cURL Post方式发送一个文件(2014-01-10)
- ·php 通过curl post发送json数据实例(2014-01-10)
- ·php用Curl伪造客户端源IP(2014-01-10)
- ·php利用CURL函数登入163邮箱并获取自己的通讯录(2014-06-17)
- ·php中CURL实现多线程的笔记(2014-06-18)
- ·PHP利用Curl模拟登录并获取数据例子(2014-06-21)
- ·php中curl模拟登陆用户百度知道的例子(2014-06-29)
推荐文章
热门文章
最新评论文章
- 写给考虑创业的年轻程序员(10)
- PHP新手上路(一)(7)
- 惹恼程序员的十件事(5)
- PHP邮件发送例子,已测试成功(5)
- 致初学者:PHP比ASP优秀的七个理由(4)
- PHP会被淘汰吗?(4)
- PHP新手上路(四)(4)
- 如何去学习PHP?(2)
- 简单入门级php分页代码(2)
- php中邮箱email 电话等格式的验证(2)