代码之家 › 专栏 › 技术社区 › Vilx-

如何在不阻塞的情况下处理GuzzleHTTP异步请求?

guzzle asynchronous php

Vilx- · 技术社区 · 7 年前

我需要编写一个处理器,它可能向外部服务发送许多HTTP请求。因为我想最大限度地提高性能,所以我希望最小化阻塞。我使用的是PHP5.6和GuzzyHTTP。

GuzzyHTTP没有异步请求选项。但是由于我们在PHP中只有1个线程可用,所以我需要为它们分配一些时间来进行处理。不幸的是,我只看到一种方法-打电话 wait 在处理所有请求之前都会阻塞。这不是我想要的。

相反,我想要一些方法来处理已经到达的内容,然后返回。这样我就可以做一些事情:

$allRequests = [];

while ( !checkIfNeedToEnd() ) {
    $newItems = getItemsFromQueue();
    $allRequests = $allRequests + spawnRequests($newItems);
    GuzzleHttp::processWhatYouCan($allRequests);
    removeProcessedRequests($allRequests);
}

这有可能吗?

1 回复 | 直到 7 年前

Vilx- 7 年前

$handler = new \GuzzleHttp\Handler\CurlMultiHandler();
$client = new \GuzzleHttp\Client(['handler' => $handler]);
$promise1 = $client->getAsync("http://www.stackoverflow.com");
$promise2 = $client->getAsync("http://localhost/");

$doneCount = 0;

$promise1->then(function() use(&$doneCount) {
    $doneCount++;
    echo 'Promise 1 done!';
});
$promise2->then(function() use(&$doneCount) {
    $doneCount++;
    echo 'Promise 2 done!';
});

$last = microtime(true);
while ( $doneCount < 2 ) {
    $now = microtime(true);
    $delta = round(($now-$last)*1000);
    echo "tick($delta) ";
    $last = $now;

    $handler->tick();
}

CurlMultiHandler tick()

$handler = new \GuzzleHttp\Handler\CurlMultiHandler(['select_timeout' => 0.5]);

推荐文章

Niobos · 如何/是否有方法使通用算法函数同时与同步和异步函数一起工作?

1 年前

Rami Dhouib · Flutter:如果等待时间超过2秒,则执行操作

1 年前

Jess The Witch · GCP云功能中处理延迟任务的模式

1 年前

justiceorjustus · Javascript中异步递归函数块内部是否有同步函数调用?

1 年前

Plup · 连接失败时,PyMongo异步客户端未引发异常

1 年前

user1233894 · 尝试从全局函数传递值

1 年前

ZNackasha · 如何将Arc<RwLock<dyn Child>>转换为Arc<RwLock<dyn-Base>>

1 年前

Grigory Turlykin · 发送媒体python电报机器人(ASYNC)

1 年前

Fabiano Taioli · 管理单线程Rust中的阻塞函数

1 年前

river7816 · 为什么spdlog不在async函数中打印

1 年前