PHP中实现文件操作的准事务性：通过目录原子交换确保数据一致性

<?php

$liveCachePath = '/path/to/cache/live_cache';
$tempCachePath = '/path/to/cache/temp_cache_' . uniqid(); // 使用唯一ID避免冲突

// 确保父目录存在
if (!is_dir(dirname($liveCachePath))) {
    mkdir(dirname($liveCachePath), 0755, true);
}

// 创建临时目录
if (!mkdir($tempCachePath, 0755, true)) {
    die("无法创建临时目录: " . $tempCachePath);
}

echo "临时目录创建成功: " . $tempCachePath . PHP_EOL;

// 模拟生成10-15个缓存文件
for ($i = 0; $i < 15; $i++) {
    $fileName = $tempCachePath . '/cache_' . $i . '.json';
    $content = json_encode(['data' => "这是新的缓存数据 " . $i, 'timestamp' => time()]);
    if (file_put_contents($fileName, $content) === false) {
        // 如果文件写入失败，需要回滚或处理错误
        // 例如：删除已创建的临时目录和文件
        // rmdir_recursive($tempCachePath);
        die("文件写入失败: " . $fileName);
    }
    // 模拟耗时操作
    // sleep(1); 
}

echo "所有新缓存文件已生成到临时目录。" . PHP_EOL;

// 2. 执行原子性目录交换

// 为旧缓存目录生成一个临时名称，以便稍后删除
$oldCacheToDeletePath = '/path/to/cache/old_cache_' . uniqid();

// 步骤 A: 将当前活动的缓存目录重命名，使其脱离服务
// 注意：如果liveCachePath不存在，rename会失败。
// 在首次运行时，liveCachePath可能不存在，需要特殊处理或确保它已存在。
if (is_dir($liveCachePath)) {
    if (!rename($liveCachePath, $oldCacheToDeletePath)) {
        // 重命名失败，可能存在权限问题或目录被占用
        // 此时，tempCachePath中的新文件仍然存在，liveCachePath也未受影响
        rmdir_recursive($tempCachePath); // 清理新生成的临时目录
        die("无法重命名旧缓存目录。回滚操作。");
    }
    echo "旧缓存目录已重命名为: " . $oldCacheToDeletePath . PHP_EOL;
} else {
    // 首次运行或liveCachePath不存在，无需重命名旧目录
    echo "当前没有活动的缓存目录，直接切换。" . PHP_EOL;
}


// 步骤 B: 将新生成的临时目录重命名为活动缓存目录
if (!rename($tempCachePath, $liveCachePath)) {
    // 理论上，如果步骤A成功，这里应该不会失败。
    // 如果失败，应用程序可能指向旧的（已重命名）目录，或liveCachePath不存在。
    // 这是一个关键的失败点，需要紧急处理。
    // 尝试将旧目录（oldCacheToDeletePath）恢复到liveCachePath
    if (isset($oldCacheToDeletePath) && is_dir($oldCacheToDeletePath)) {
        rename($oldCacheToDeletePath, $liveCachePath);
    }
    rmdir_recursive($tempCachePath); // 清理新生成的临时目录
    die("无法将新缓存目录切换为活动目录。系统可能处于不稳定状态。");
}

echo "新缓存目录已成功切换为活动目录: " . $liveCachePath . PHP_EOL;

// 3. 清理旧目录（异步或在后续操作中）
if (isset($oldCacheToDeletePath) && is_dir($oldCacheToDeletePath)) {
    echo "开始清理旧缓存目录: " . $oldCacheToDeletePath . PHP_EOL;
    // 实际生产环境中，可能将此操作放入队列或后台任务中执行，避免阻塞当前请求
    rmdir_recursive($oldCacheToDeletePath);
    echo "旧缓存目录清理完成。" . PHP_EOL;
}

echo "所有操作完成。应用程序现在正在使用最新缓存。" . PHP_EOL;

/**
 * 递归删除目录及其内容
 * @param string $dirPath
 * @return bool
 */
function rmdir_recursive($dirPath) {
    if (!is_dir($dirPath)) {
        return false;
    }
    $files = array_diff(scandir($dirPath), array('.', '..'));
    foreach ($files as $file) {
        (is_dir("$dirPath/$file")) ? rmdir_recursive("$dirPath/$file") : unlink("$dirPath/$file");
    }
    return rmdir($dirPath);
}

?>