服务器间大文件分片传输实现问题咨询

我来帮你梳理下这个分片下载实现的问题排查点和优化方向，都是实际部署中容易踩的坑：

先排查现有实现的潜在问题 #

• 核心代码不完整：你贴的partdown.php里fsockopen那行代码是截断的（5...），这会直接导致语法错误，先补全这部分逻辑，尤其是HTTP请求的构建和分片Range头的处理——这可是分片下载的核心。
• 缺少服务器兼容性检查：分片下载依赖服务器支持Range请求（返回206 Partial Content状态码），如果目标服务器不支持，整个逻辑就会失效，得加状态码校验。
• 参数无校验，安全+稳定性双风险：
  • trigger.php直接用$_POST的参数，没做任何校验：比如$partsize如果是负数或字符串，$chunksize = $partsize *1024会变成0或负数，直接崩掉；
  • 没限制本地文件的存储路径，容易被恶意用户利用路径遍历漏洞写入敏感文件。
• 前端无进度反馈+超时风险：大文件下载时，PHP脚本执行时间很容易超过默认的max_execution_time，AJAX请求会直接超时，而且用户完全不知道下载进度，体验极差。
• 错误处理缺失：
  • fsockopen连接失败的情况没处理，比如域名解析失败、服务器拒绝连接时，只会静默失败；
  • 文件写入时没检查权限，比如$outfile所在目录没有写入权限，也不会返回明确的错误信息。

针对性优化建议 #

1. 补全分片下载的核心逻辑 #

先把partdown.php里的copyfile_chunked方法补全，正确实现Range请求和分片写入：

<?php
/**
 * Copy remote file over HTTP one small chunk at a time.
 *
 * @param $infile The full URL to the remote file
 * @param $outfile The path where to save the file
 * @param $partsize Chunk size in KB
 */
class DownInParts {
    public function copyfile_chunked($infile, $outfile, $partsize) {
        $chunksize = $partsize * 1024; // Convert KB to bytes
        $parts = parse_url($infile);
        
        // Validate URL parts
        if (!isset($parts['host'], $parts['path'])) {
            return "无效的远程文件URL";
        }

        // Step 1: Get total file size via HEAD request
        $i_handle = fsockopen($parts['host'], 80, $errstr, $errcode, 5);
        if (!$i_handle) {
            return "连接远程服务器失败: $errstr ($errcode)";
        }

        $path = $parts['path'] . (isset($parts['query']) ? '?' . $parts['query'] : '');
        fwrite($i_handle, "HEAD $path HTTP/1.1\r\nHost: {$parts['host']}\r\nConnection: Close\r\n\r\n");
        
        $head_response = '';
        while (!feof($i_handle)) {
            $head_response .= fgets($i_handle, 1024);
        }
        fclose($i_handle);

        // Parse total file size
        if (!preg_match('/Content-Length: (\d+)/', $head_response, $matches)) {
            return "无法获取远程文件大小";
        }
        $total_size = (int)$matches[1];

        // Step 2: Start chunked download
        $start = 0;
        $o_handle = fopen($outfile, 'wb');
        if (!$o_handle) {
            return "无法打开本地文件进行写入: $outfile (检查权限)";
        }

        while ($start < $total_size) {
            $end = min($start + $chunksize - 1, $total_size - 1);
            $i_handle = fsockopen($parts['host'], 80, $errstr, $errcode, 5);
            if (!$i_handle) {
                fclose($o_handle);
                return "分片连接失败: $errstr ($errcode)";
            }

            // Send Range request
            fwrite($i_handle, "GET $path HTTP/1.1\r\nHost: {$parts['host']}\r\nRange: bytes=$start-$end\r\nConnection: Close\r\n\r\n");
            
            // Skip response headers to get to content
            $response_header = '';
            while (!feof($i_handle)) {
                $line = fgets($i_handle, 1024);
                $response_header .= $line;
                if ($line == "\r\n") {
                    break;
                }
            }

            // Check if server supports partial content
            if (!strpos($response_header, 'HTTP/1.1 206')) {
                fclose($i_handle);
                fclose($o_handle);
                return "远程服务器不支持分片下载";
            }

            // Write chunk to local file
            while (!feof($i_handle)) {
                $buffer = fread($i_handle, 1024);
                fwrite($o_handle, $buffer);
            }
            fclose($i_handle);
            $start = $end + 1;
        }
        fclose($o_handle);
        return "文件下载完成！总大小: " . number_format($total_size / 1024 / 1024, 2) . " MB";
    }
}
?>

2. 加强参数校验与安全防护 #

在trigger.php里添加严格的参数校验，防止非法输入和路径遍历：

<?php
require 'partdown.php';

// 初始化错误信息
$errors = [];

// 校验远程文件URL
if (empty($_POST["dfile"]) || !filter_var($_POST["dfile"], FILTER_VALIDATE_URL)) {
    $errors[] = "远程文件URL格式不合法";
}

// 校验本地文件名与存储路径
$allowed_storage_dir = '/var/www/safe_downloads/'; // 替换成你的安全存储目录
if (empty($_POST["sfile"])) {
    $errors[] = "本地文件名不能为空";
} else {
    // 只保留文件名，防止路径遍历
    $safe_filename = basename($_POST["sfile"]);
    $outfile = realpath($allowed_storage_dir) . DIRECTORY_SEPARATOR . $safe_filename;
    // 确保文件在允许的目录内
    if (!str_starts_with($outfile, realpath($allowed_storage_dir))) {
        $errors[] = "不允许的存储路径";
    }
}

// 校验分片大小
if (empty($_POST["psize"]) || !is_numeric($_POST["psize"]) || (int)$_POST["psize"] <= 0) {
    $errors[] = "分片大小必须是正整数（单位：KB）";
}

// 如果有错误，直接返回
if (!empty($errors)) {
    echo implode(' | ', $errors);
    exit;
}

// 执行下载
$infile = $_POST["dfile"];
$partsize = (int)$_POST["psize"];
echo $mesg = DownInParts::copyfile_chunked($infile, $outfile, $partsize);
?>

3. 优化前端体验：添加进度反馈与超时处理 #

把原来的jQuery AJAX改成原生XMLHttpRequest，支持进度监听，避免超时无反馈：

function stratdown() {
    var partsizevalue = $('#psize').val();
    var dfilename = $('#dfile').val();
    var sfilename = $('#sfile').val();
    
    // 先做前端参数校验
    if (!dfilename || !sfilename || !partsizevalue || isNaN(partsizevalue) || partsizevalue <=0) {
        alert("请填写合法的参数：远程URL、本地文件名、正整数分片大小");
        return;
    }

    var xhr = new XMLHttpRequest();
    xhr.open('POST', 'trigger.php', true);
    xhr.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded');
    
    // 监听下载进度（后端需配合输出缓冲）
    xhr.onprogress = function(e) {
        if (e.lengthComputable) {
            var progressPercent = (e.loaded / e.total) * 100;
            // 更新页面上的进度条，比如：
            // $('#progress-bar').css('width', progressPercent.toFixed(2) + '%');
            console.log("当前进度：" + progressPercent.toFixed(2) + "%");
        }
    };
    
    // 请求完成处理
    xhr.onload = function() {
        if (xhr.status === 200) {
            alert(xhr.responseText);
            // 重置进度条
            // $('#progress-bar').css('width', '0%');
        } else {
            alert("请求失败：" + xhr.statusText);
        }
    };
    
    // 网络错误处理
    xhr.onerror = function() {
        alert("网络连接错误，请检查后重试");
    };
    
    // 发送表单数据
    var formData = `dfile=${encodeURIComponent(dfilename)}&sfile=${encodeURIComponent(sfilename)}&psize=${encodeURIComponent(partsizevalue)}`;
    xhr.send(formData);
}

4. 调整PHP配置适配大文件 #

修改php.ini的以下配置，避免脚本超时和内存不足：

max_execution_time = 600 ; 10分钟，根据文件大小调整
memory_limit = 64M ; 分片处理不需要太大内存
post_max_size = 8M ; POST参数很小，足够即可
upload_max_filesize = 8M ; 同上

5. 进阶优化：添加断点续传 #

如果要支持断点续传，可以在本地创建一个和下载文件同名的.progress临时文件，记录已下载的字节数，每次启动下载前先读取这个文件的进度，从对应的位置开始下载，避免重复下载已经完成的分片。

内容的提问来源于stack exchange，提问作者Noonou Lone