请教一下guzzle的pool问题

用异步请求方法比如getAsync之类的

使用 fiddler 抓包看下请求内容吧 看看是卡在哪个步骤了

guzzle 是支持设置代理的

试试改用 CurlMultiHandler。

准备多点地址试试，如果都是 google，估计 dns，connect 都过不了 方便提供贴一下运行输出的内容吗

你应该看起来好像写的不对哇。给你看看我写的：

/**
* 图片上传到OSS逻辑
*/
$client = new Client(['base_uri' => 'https://' . $this->full_endpoint]);

// 创建 HTTP 请求
$request = function ($images) use ($client) {
    /**
        * @var string $key   文件名
        * @var Stream $image 图片流
        */
    foreach ($images as $key => $image) {
        if ($image['stream'] === null) { // 如果进入此分支，说明之前的下载出现了问题
            continue;
        }

        yield $key => function () use ($client, $image) {
            // 创建请求
            $request = new Request('PUT', $image['generate'], [
                'Host'           => $this->full_endpoint,
                'Content-Type'   => self::MIME_TYPES[$image['ext']],
                'Content-Length' => $image['stream']->getSize(),
                'Date'           => gmdate('D, d M Y H:i:s \G\M\T'),
            ], $image['stream']);

            return $client->sendAsync($this->sign($request, [
                'bucket' => $this->bucket,
                'key'    => $request->getUri()->getPath(),
            ]));
        };
    }
};

// 设置管道
$pool = new Pool($client, $request($imagesMap), [
    'concurrency' => $this->concurrency,
    'rejected'    => function (RequestException $reason, $index) use ($imagesMap) { // 这里是失败处理逻辑
        Log::warning('图片上传失败', [$imagesMap[$index]['original'], $imagesMap[$index]['generate']]);
        dispatch(new XsSaveOssJob($imagesMap[$index]['original'], $imagesMap[$index]['generate']))->delay(5);
    },
]);

pool 相当于把很多请求放在一个array 循环请求，然后看起来是需要之前的请求完成后才会执行后面的请求。
该说不是你想要那种全部请求同时执行
guzzle 的话有专门的方法来做同时请求

不会堵塞。

guzzle 没试过, 我之前用laravel - 并发请求 没问题的。

估计是你代码问题,可以用 laravel 文档的测试。

CurlMultiHandler支持Guzzle的, 另外题主试试加参timeout

$curlMultiHandler = new CurlMultiHandler();
$client           = new Client(['handler' => $curlMultiHandler]);

for ($i = 0; $i < 100; $i++) {

    $client->getAsync('https://www.qq.com/')
    ->then(function (Response $response) {
        var_dump($response->getStatusCode());
    });

}


while (1) {
    $curlMultiHandler->tick();
    usleep(100000);
}

    yield new Request('GET', $uri);  要改为 getAsync