用PHP和Guzzle实现远程文件流式传输

要使用 PHP 和 Guzzle 实现远程文件的流式传输，可以有效地处理大文件而不会占用过多的服务器内存。以下是详细的步骤和示例代码：

步骤一：安装 Guzzle

首先，确保你已经安装了 Guzzle。你可以使用 Composer 来安装：

composer require guzzlehttp/guzzle

步骤二：编写流式传输代码

下面是一个示例代码，展示如何使用 Guzzle 从远程服务器流式下载文件并将其输出到客户端：

<?php
require 'vendor/autoload.php'; // 引入 Composer 的自动加载器

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

// 远程文件的URL
$remoteFileUrl = 'https://example.com/largefile.zip';

// 客户端配置
$client = new Client([
    'timeout'  => 0, // 设置为0表示不超时
    'headers'  => [
        'User-Agent' => 'MyCustomUserAgent/1.0', // 可选：自定义用户代理
    ],
]);

try {
    // 发起GET请求，并启用流式响应
    $response = $client->get($remoteFileUrl, [
        'stream' => true, // 启用流式响应
    ]);

    // 获取响应头中的内容类型和内容长度（可选）
    $contentType = $response->getHeaderLine('Content-Type');
    $contentLength = $response->getHeaderLine('Content-Length');

    // 设置适当的响应头，以便浏览器识别并处理文件
    header("Content-Type: $contentType");
    if ($contentLength) {
        header("Content-Length: $contentLength");
    }
    header('Content-Disposition: attachment; filename="' . basename(parse_url($remoteFileUrl, PHP_URL_PATH)) . '"');

    // 获取流资源
    $body = $response->getBody();

    // 设置适当的缓冲区大小（例如1MB）
    $chunkSize = 1024 * 1024;

    // 逐块读取并输出数据
    while (!$body->eof()) {
        echo $body->read($chunkSize);
        // 可选：刷新输出缓冲区
        flush();
        if (connection_status() != 0) {
            // 如果连接中断，停止传输
            break;
        }
    }

} catch (RequestException $e) {
    // 处理请求异常
    if ($e->hasResponse()) {
        echo 'Error: ' . $e->getResponse()->getBody();
    } else {
        echo 'Error: ' . $e->getMessage();
    }
}

代码说明

引入自动加载器和命名空间：
- 使用 require 'vendor/autoload.php'; 引入 Composer 的自动加载器。
- 使用 use 语句引入 Guzzle 的 Client 和 RequestException 类。
配置 Guzzle 客户端：
- 创建一个 Client 实例，可以设置超时时间、自定义头部等。
发起流式 GET 请求：
- 使用 $client->get($remoteFileUrl, ['stream' => true]); 发起 GET 请求，并启用流式响应。
设置响应头：
- 根据远程文件的 Content-Type 和 Content-Length 设置适当的响应头，以便浏览器正确处理下载。
- 使用 Content-Disposition 指示浏览器以附件形式下载文件，并设置文件名。
读取并输出数据：
- 获取响应的主体流 $body = $response->getBody();。
- 设置一个缓冲区大小（如 1MB），然后在一个循环中逐块读取并输出数据。
- 使用 flush() 将输出缓冲区的内容发送到客户端。
- 检查连接状态，如果连接中断则停止传输。
异常处理：
- 使用 try-catch 块捕获可能的请求异常，并根据情况输出错误信息。