php-guzzleHow to send multiple requests with Guzzle in PHP?
Guzzle is a PHP HTTP client that makes it easy to send multiple requests. To send multiple requests with Guzzle, you can use the Pool
class. The Pool
class allows you to send multiple requests concurrently and process the responses as they arrive.
Example code
$client = new GuzzleHttp\Client();
$requests = [
'req1' => $client->getAsync('http://httpbin.org/get'),
'req2' => $client->getAsync('http://httpbin.org/get?foo=bar'),
'req3' => $client->getAsync('http://httpbin.org/get?baz=bam')
];
$pool = new GuzzleHttp\Pool($client, $requests);
$promise = $pool->promise();
$promise->wait();
Output example
Array
(
[req1] => GuzzleHttp\Psr7\Response Object
(
[reasonPhrase:GuzzleHttp\Psr7\Response:private] => OK
[statusCode:GuzzleHttp\Psr7\Response:private] => 200
[headers:GuzzleHttp\Psr7\Response:private] => Array
(
[Date] => Array
(
[0] => Mon, 11 May 2020 11:45:45 GMT
)
[Content-Type] => Array
(
[0] => application/json
)
[Content-Length] => Array
(
[0] => 250
)
[Connection] => Array
(
[0] => keep-alive
)
[Server] => Array
(
[0] => gunicorn/19.9.0
)
)
[headerNames:GuzzleHttp\Psr7\Response:private] => Array
(
[date] => Date
[content-type] => Content-Type
[content-length] => Content-Length
[connection] => Connection
[server] => Server
)
[protocol:GuzzleHttp\Psr7\Response:private] => 1.1
[stream:GuzzleHttp\Psr7\Response:private] => GuzzleHttp\Psr7\Stream Object
(
[stream:GuzzleHttp\Psr7\Stream:private] => Resource id #20
[size:GuzzleHttp\Psr7\Stream:private] =>
[seekable:GuzzleHttp\Psr7\Stream:private] => 1
[readable:GuzzleHttp\Psr7\Stream:private] => 1
[writable:GuzzleHttp\Psr7\Stream:private] => 1
[uri:GuzzleHttp\Psr7\Stream:private] => php://temp
[customMetadata:GuzzleHttp\Psr7\Stream:private] => Array
(
)
)
)
[req2] => GuzzleHttp\Psr7\Response Object
(
[reasonPhrase:GuzzleHttp\Psr7\Response:private] => OK
[statusCode:GuzzleHttp\Psr7\Response:private] => 200
[headers:GuzzleHttp\Psr7\Response:private] => Array
(
[Date] => Array
(
[0] => Mon, 11 May 2020 11:45:45 GMT
)
[Content-Type] => Array
(
[0] => application/json
)
[Content-Length] => Array
(
[0] => 250
)
[Connection] => Array
(
[0] => keep-alive
)
[Server] => Array
(
[0] => gunicorn/19.9.0
)
)
[headerNames:GuzzleHttp\Psr7\Response:private] => Array
(
[date] => Date
[content-type] => Content-Type
[content-length] => Content-Length
[connection] => Connection
[server] => Server
)
[protocol:GuzzleHttp\Psr7\Response:private] => 1.1
[stream:GuzzleHttp\Psr7\Response:private] => GuzzleHttp\Psr7\Stream Object
(
[stream:GuzzleHttp\Psr7\Stream:private] => Resource id #21
[size:GuzzleHttp\Psr7\Stream:private] =>
[seekable:GuzzleHttp\Psr7\Stream:private] => 1
[readable:GuzzleHttp\Psr7\Stream:private] => 1
[writable:GuzzleHttp\Psr7\Stream:private] => 1
[uri:GuzzleHttp\Psr7\Stream:private] => php://temp
[customMetadata:GuzzleHttp\Psr7\Stream:private] => Array
(
)
)
)
[req3] => GuzzleHttp\Psr7\Response Object
(
[reasonPhrase:GuzzleHttp\Psr7\Response:private] => OK
[statusCode:GuzzleHttp\Psr7\Response:private] => 200
[headers:GuzzleHttp\Psr7\Response:private] => Array
(
[Date] => Array
(
[0] => Mon, 11 May 2020 11:45:45 GMT
)
[Content-Type] => Array
(
[0] => application/json
)
[Content-Length] => Array
(
[0] => 250
)
[Connection] => Array
(
[0] => keep-alive
)
[Server] => Array
(
[0] => gunicorn/19.9.0
)
)
[headerNames:GuzzleHttp\Psr7\Response:private] => Array
(
[date] => Date
[content-type] => Content-Type
[content-length] => Content-Length
[connection] => Connection
[server] => Server
)
[protocol:GuzzleHttp\Psr7\Response:private] => 1.1
[stream:GuzzleHttp\Psr7\Response:private] => GuzzleHttp\Psr7\Stream Object
(
[stream:GuzzleHttp\Psr7\Stream:private] => Resource id #22
[size:GuzzleHttp\Psr7\Stream:private] =>
[seekable:GuzzleHttp\Psr7\Stream:private] => 1
[readable:GuzzleHttp\Psr7\Stream:private] => 1
[writable:GuzzleHttp\Psr7\Stream:private] => 1
[uri:GuzzleHttp\Psr7\Stream:private] => php://temp
[customMetadata:GuzzleHttp\Psr7\Stream:private] => Array
(
)
)
)
)
Code explanation
$client = new GuzzleHttp\Client();
- This creates a new Guzzle client.$requests = [
- This creates an array of requests.'req1' => $client->getAsync('http://httpbin.org/get'),
- This adds a request to the array.$pool = new GuzzleHttp\Pool($client, $requests);
- This creates a new Pool object with the client and requests.$promise = $pool->promise();
- This creates a promise for the Pool object.$promise->wait();
- This waits for the promise to be fulfilled.
Helpful links
More of Php Guzzle
- How to use PHP Guzzle to make a batch request?
- What version of PHP is required for Guzzle?
- How to set a user agent in PHP Guzzle?
- How to post form data with PHP Guzzle?
- How to add a bearer token in PHP Guzzle?
- How to set a timeout for a request with PHP Guzzle?
- How to update PHP Guzzle?
- How to stream with PHP Guzzle?
- How to handle a RequestException with PHP Guzzle?
- How to use Promises with PHP Guzzle (with an example)?
See more codes...