使用异步承诺处理Guzzle超时

Question

我正在发送多个异步promise，并将guzzle超时设置为30，我想知道如何捕获是否有promise超时，以便报告此错误。请参阅下面的代码。从本质上讲，我想在超时之前使用我能使用的任何响应，并捕获那些超时的响应。

foreach ($apiRequests as $guzzleParameters) {
$request = new Request($guzzleParameters->getType(), $guzzleParameters->getApiEndpoint(), $guzzleParameters->getHeaders(), $guzzleParameters->getBody());
$promises[$guzzleParameters->createKey()] = $this->client->sendAsync($request)->then(
function (ResponseInterface $res) {
return $res;
},
function (RequestException $e) {
switch ($e->getCode()) {
case 400:
// log error 
break;
case 401:
// log error 
break;
case 403:
// log error 
break;
case 404:
// log error 
break;
}
return $e->getResponse();
}
);
}
$responses = PromiseUtils::settle($promises)->wait(true);

Answer 1

据我所知，您希望以异步方式记录每个请求的时间，然后可以将其相加，并在总和超过30时设置一个标志。

注：未测试的代码，但on_stats部分代码已测试

foreach ($apiRequests as $key => $guzzleParameters) {
$LogStats = [];
$request = new Request($guzzleParameters->getType(), $guzzleParameters->getApiEndpoint(), $guzzleParameters->getHeaders(), $guzzleParameters->getBody());
$promises[$guzzleParameters->createKey()] = $this->client->sendAsync($request, [
'on_stats' => function (GuzzleHttpTransferStats $stats) {
// $LogStats["uri"] = $stats->getEffectiveUri();
$LogStats[$key]["time"] = $stats->getTransferTime();
// $LogStats["stats"] = json_encode($stats->getHandlerStats());
// Log::debug("n--------------------------------nDebug Solr Request Stats :: ", $LogStats);
}
])->then(
function (ResponseInterface $res) {
return $res;
},
function (RequestException $e) {
// ....
}
return $e->getResponse();
}
);
}
$responses = PromiseUtils::settle($promises)->wait(true);

在这里我使用了on_stats，你可以对所有时间进行计数，然后将其相加，一旦达到30，就将标志设置为true。然后你就可以知道在哪个密钥之后请求失败了。