jenner/async-http-php

php http 异步客户端

安装次数: 5,790

依赖项: 0

建议者: 0

安全性: 0

星标: 30

关注者: 7

分支: 14

类型:软件包

0.6 2016-11-21 09:46 UTC

This package is auto-updated.

Last update: 2024-09-14 11:45:41 UTC


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