jenner / async-http-php
php http 异步客户端
0.6
2016-11-21 09:46 UTC
Requires
- php: >=5.3.0
- ext-curl: *
Requires (Dev)
- jenner/timer: v0.1
- react/promise: v2.2.1
README
基于 curl_multi* 的异步 HTTP 客户端,非常简单且快速。
这是一个教学实验项目,即使它很稳定,我也建议不要在生产环境中使用它。您可以尝试使用 guzzle。
描述
- 如果您在请求网站时需要使用 ssl 或其他内容,您只需实现一个任务类并扩展 AbstractTask 类。
- 您可以使用 Task 对象注册一个处理器,当响应可用时,Async 类将调用处理器来处理响应。
- 无论是否由处理器处理,它都会返回响应。
- 请求执行时间越长,节省的时间越多。
示例代码
$async = new \Jenner\Http\Async(); $task = \Jenner\Http\Task::createGet("http://www.baidu.com"); $async->attach($task, "baidu"); $task2 = \Jenner\Http\Task::createGet("http://www.sina.com"); $async->attach($task2, "sina"); $task3 = \Jenner\Http\Task::createGet("http://www.qq.com"); $async->attach($task3, "qq"); /** * you can do something here before receive the http responses * eg. query data from mysql or redis. */ $async-start(); while(true){ // nonblock if(!$async->isDone()){ echo "I am running" . PHP_EOL; sleep(1); continue; } $result = $async->execute(); print_r($result); break; } /** * or you just call execute. it will block the process until all tasks are done. * $result = $async->execute(); * print_r($result); */
使用 Promise
$async = new \Jenner\Http\Async(); $task = \Jenner\Http\Task::createGet("http://www.baidu.com"); $promise = $async->attach($task, "baidu"); $promise->then( function ($data) { echo 'success:' . var_export($data, true) . PHP_EOL; }, function ($data) { echo 'error:' . var_export($data, true) . PHP_EOL; } ); $async->execute();
性能测试
[root@huyanping async-http-php]# php tests/performance_sync.php ------------------------------------------ mark:[total diff] time:55.121547937393s memory_real:1536KB memory_emalloc:1300.5859375KB memory_peak_real:2304KB memory_peak_emalloc:1898.640625KB [root@huyanping async-http-php]# php tests/performance_async.php ------------------------------------------ mark:[total diff] time:4.6412570476532s memory_real:256KB memory_emalloc:187.7109375KB memory_peak_real:13312KB memory_peak_emalloc:10387.8671875KB