时间:2021-05-25
前言
众所周知,在 Swoole 应用中,是不推荐使用 Curl 的,因为 Curl 会阻塞进程。
本文会用实际的代码和数据,用最直观的方式,让你明白为什么。
最后还会给出 Curl 在 Swoole 中的解决方案,如果不想看分析可以直接拉到最后。
例程对比
宇润看文章不喜欢那些虚的,所以自己写也比较实在,直接来跑一下代码,用数据看为什么不推荐在 Swoole 使用 Curl。
为了偷懒,我直接用了 YurunHttp 的 Curl 和 Swoole Handler,来替代那些又臭又长的 Curl 代码。
代码
composer.json
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
<?phpuse 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
全局设定处理器:
<?phprequire 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://'); echo 'html:', PHP_EOL, $response->body();}截止发稿时,Swoole 4.4 新增的 hook Curl 依然是实验性功能。虽然宇润曾为该功能贡献过一部分代码,但是由于需要兼容的工作量非常大,有太多 OPTION 不被支持,我个人是暂时不推荐使用 hook Curl 的。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对的支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
前言Swoole内核团队开设的专栏,会逐渐投入精力写文章介绍Swoole的开发历程,实现原理,应用实践等,大家可以更好的交流,共同学习,建设PHP生态。协程调度
前言本文主要给大家介绍了关于PHP中协程和阻塞的理解与思考,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍:进程、线程、协程关于进程、线程、协程,
问题你想使用生成器(协程)替代系统线程来实现并发。这个有时又被称为用户级线程或绿色线程。解决方案要使用生成器实现自己的并发,你首先要对生成器函数和yield语句
前言从语法上来看,协程和生成器类似,都是定义体中包含yield关键字的函数。yield在协程中的用法:在协程中yield通常出现在表达式的右边,例如:datum
tornado中的协程是如何工作的协程定义Coroutinesarecomputerprogramcomponentsthatgeneralizesubrout