PHP怎么实现文件批量压缩 文件批量压缩的4种优化方案

$files = glob('/path/to/files/*');
$zip = new ZipArchive();
$zipFile = 'archive.zip';
$batchSize = 100;

for ($i = 0; $i < count($files); $i += $batchSize) {
    $batch = array_slice($files, $i, $batchSize);

    if ($i == 0) {
        $zip->open($zipFile, ZipArchive::CREATE);
    } else {
        $zip->open($zipFile); // Append mode
    }

    foreach ($batch as $file) {
        if (is_file($file)) {
            $zip->addFile($file, basename($file));
        }
    }
    $zip->close();
}

$files = glob('/path/to/files/*'); // 获取所有文件
$zip = new ZipArchive();
$zipFile = 'archive.zip';

if ($zip->open($zipFile, ZipArchive::CREATE) !== TRUE) {
    exit("无法打开 <$zipFile>\n");
}

foreach ($files as $file) {
    if (is_file($file)) {
        $zip->addFile($file, basename($file));
    }
}

echo "总共添加的文件: " . $zip->numFiles . "\n";
$zip->close();
echo "压缩文件 $zipFile 创建成功\n";

$zip = new ZipArchive();
$zipFile = 'archive.zip';

if ($zip->open($zipFile, ZipArchive::CREATE) !== TRUE) {
    exit("无法打开 <$zipFile>\n");
}

$file = '/path/to/large_file.txt';
$chunkSize = 1024 * 1024; // 1MB

$fp = fopen($file, 'rb');
if ($fp) {
    $archivePath = basename($file);
    $index = 0;
    while (!feof($fp)) {
        $chunk = fread($fp, $chunkSize);
        $zip->addFromString($archivePath . '.part' . $index, $chunk);
        $index++;
    }
    fclose($fp);
}

$zip->close();
echo "压缩文件 $zipFile 创建成功\n";

if (!function_exists('pcntl_fork')) {
    die("pcntl 扩展未安装\n");
}

$files = glob('/path/to/files/*');
$numProcesses = 4; // 并行进程数
$filesPerProcess = ceil(count($files) / $numProcesses);

for ($i = 0; $i < $numProcesses; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die("无法 fork 进程\n");
    } else if ($pid) {
        // 父进程
        $pids[] = $pid;
    } else {
        // 子进程
        $start = $i * $filesPerProcess;
        $end = min(($i + 1) * $filesPerProcess, count($files));
        $processFiles = array_slice($files, $start, $end - $start);

        $zip = new ZipArchive();
        $zipFile = 'archive_' . $i . '.zip';
        if ($zip->open($zipFile, ZipArchive::CREATE) !== TRUE) {
            exit("无法打开 <$zipFile>\n");
        }

        foreach ($processFiles as $file) {
            if (is_file($file)) {
                $zip->addFile($file, basename($file));
            }
        }
        $zip->close();
        exit(0); // 子进程结束
    }
}

// 等待所有子进程结束
foreach ($pids as $pid) {
    pcntl_waitpid($pid, $status);
}

echo "所有压缩任务完成\n";

$files = glob('/path/to/files/*');
$zip = new ZipArchive();
$zipFile = 'archive.zip';

try {
    if ($zip->open($zipFile, ZipArchive::CREATE) !== TRUE) {
        throw new Exception("无法打开 <$zipFile>\n");
    }

    foreach ($files as $file) {
        if (!file_exists($file) || !is_readable($file)) {
            error_log("文件 $file 不存在或无法访问\n");
            continue; // 跳过该文件
        }

        if (is_file($file)) {
            if ($zip->addFile($file, basename($file)) !== TRUE) {
                error_log("添加文件 $file 失败\n");
            }
        }
    }

    if ($zip->close() !== TRUE) {
        throw new Exception("关闭 ZIP 文件失败\n");
    }

    echo "压缩文件 $zipFile 创建成功\n";

} catch (Exception $e) {
    error_log("压缩过程中发生错误: " . $e->getMessage() . "\n");
}