关于Curl在Swoole协程中的解决方案详析
前言
众所周知,在 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 SwooleHttpServer('127.0.0.1', 9501);
$http- on('workerstart', function(){
SwooleRuntime::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 YurunUtilYurunHttp;
use YurunUtilHttpRequest;
require __DIR__ . '/vendor/autoload.php';
define('REQUEST_COUNT', 3);
go(function(){
// 协程客户端
echo 'coroutine http client:', PHP_EOL, PHP_EOL;
$time = microtime(true);
YurunHttp::setDefaultHandler(YurunUtilYurunHttpHandlerSwoole::class); // 切换为 Swoole Handler
$channel = new SwooleCoroutineChannel;
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(YurunUtilYurunHttpHandlerCurl::class); // 切换为 Curl Handler
$channel = new SwooleCoroutineChannel;
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 GuzzleHttpClient;
use YurunUtilSwooleGuzzleSwooleHandler;
use GuzzleHttpDefaultHandler;
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 GuzzleHttpClient;
use GuzzleHttpHandlerStack;
use YurunUtilSwooleGuzzleSwooleHandler;
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 YurunUtilYurunHttp;
use YurunUtilHttpRequest;
// 设置默认请求处理器为 Swoole
YurunHttp::setDefaultHandler(YurunUtilYurunHttpHandlerSwoole::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 的。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对ZaLou.Cn的支持。
- Silverlight/aspx/ajax/mvc的UI自动化测试
- Office Open XML学习(1)-创建excel文档,并向单元格中插入字符串
- PyMC3和Theano代码构建贝叶斯深度网络,61页PPT探索贝叶斯深度学习以及实现
- 男程序员是不是都不会和女生表达交流?程序员的回答歪了
- Silverlight Telerik控件学习:主题Theme切换
- Silverlight自定义类库实现应用程序缓存
- Silverlight Telerik控件学习:TreeView数据绑定并初始化选中状态、PanelBar的Accordion效果、TabPanel、Frame基本使用
- 这或许是对小白最友好的python入门了吧——4,列表
- 每个人都应该知道的十个机器学习常识
- 重新带你了解React.js
- WebService又一个不爽的地方
- 劲爆!小程序又增新功能!为落地微信智慧零售方案做铺垫!
- 5G光传送网技术
- 突破封闭 Web 系统的技巧之正面冲锋
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- IPC—进程间通信的基础概念
- Python Django开发 经验技巧总结(一)
- Python SQLite 基本操作和经验技巧(二)
- AkShare-股票数据-主要股东
- 进程间通信的方式(1)
- Python Django开发 经验技巧总结(二)
- 进程间通信的方式(2)
- AkShare-股票数据-机构持股
- View的滑动方式 详细介绍
- AkShare-期货数据-分时数据
- Python 爬取留言板留言(三):多进程版+selenium模拟
- View事件分发、滑动冲突 详解
- Python Django开发 异常及其解决办法(一)
- 带你彻底搞懂-View的工作原理!
- Python 批量下载BiliBili视频 打包成软件