首页 > 编程语言> 文章详细

php – Guzzle：使用Guzzle的Pool并行文件下载：batch()和`sink`选项

2019-10-01 20:32:00 阅读：1014 来源： 互联网

标签：guzzle php guzzle6

您可以使用Guzzle的Pool：batch()方法并行执行http请求.它允许您使用第三个参数中的options键为请求设置默认选项.

但是如果我需要池中不同请求的不同选项呢？我想使用池执行GET请求,并将每个响应流式传输到磁盘上的不同文件.有一个接收器选项.但是如何将这个选项的不同值应用于请求？

解决方法:

Rastor’s example几乎是正确的,但如果要为Pool()构造函数提供“选项”,则会错误地实现它.

他错过了here提到的Pool options数组的关键实现.

Guzzle文档说：

When a function is yielded by the iterator, the function is provided
the “request_options” array that should be merged on top of any
existing options, and the function MUST then return a wait-able
promise.

另外,如果你查看我链接的注释下面的Pool()代码,你可以看到Guzzle的Pool调用可调用的并给它Pool的“选项”作为参数,正是这样你应该将它应用到你的请求.

正确的优先顺序是

Per-request options > Pool options > Client defaults.

如果你没有将Pool()对象的options数组应用于你的请求对象,你将会遇到严重的错误,例如你尝试制作一个新的游泳池($client,$requests(100),[‘options’=&gt [ ‘超时’=&GT 30.0]]);.如果没有我更正的代码,您的Pool-options将根本不会应用,因为您不支持正确合并池选项,因此最终会丢弃它们.

所以这里是支持Pool()选项的正确代码：

<?php

$client = new \GuzzleHttp\Client();

$requests = function ($total) use ($client) {
    for ($i = 0; $i < $total; $i++) {
        $url = "domain.com/picture/{$i}.jpg";
        $filepath = "/tmp/{$i}.jpg";

        yield function($poolOpts) use ($client, $url, $filepath) {
            /** Apply options as follows:
             * Client() defaults are given the lowest priority
             * (they're used for any values you don't specify on
             * the request or the pool). The Pool() "options"
             * override the Client defaults. And the per-request
             * options ($reqOpts) override everything (both the
             * Pool and the Client defaults).
             * In short: Per-Request > Pool Defaults > Client Defaults.
             */
            $reqOpts = [
                'sink' => $filepath
            ];
            if (is_array($poolOpts) && count($poolOpts) > 0) {
                $reqOpts = array_merge($poolOpts, $reqOpts); // req > pool
            }

            return $client->getAsync($url, $reqOpts);
        };
    }
};

$pool = new Pool($client, $requests(100));

但请注意,如果您知道永远不会向新的Pool()构造函数添加任何选项,则不必支持Pool()选项.在这种情况下,您可以查看the official Guzzle docs作为示例.

官方示例如下：

// Using a closure that will return a promise once the pool calls the closure.
$client = new Client();

$requests = function ($total) use ($client) {
    $uri = '127.0.0.1:8126/guzzle-server/perf';
    for ($i = 0; $i < $total; $i++) {
        yield function() use ($client, $uri) {
            return $client->getAsync($uri);
        };
    }
};

$pool = new Pool($client, $requests(100));

标签：guzzle,php,guzzle6
来源： https://codeday.me/bug/20191001/1839757.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

php – Guzzle：使用Guzzle的Pool并行文件下载：batch()和`sink`选项