PHP文件缓存更新的原子性处理：零停机切换方案

<?php

// 配置常量
define('CACHE_BASE_DIR', __DIR__ . '/cache_data'); // 缓存文件基准目录
define('ACTIVE_CACHE_POINTER', CACHE_BASE_DIR . '/active_cache'); // 指向当前活动缓存的符号链接或文件

// --- 辅助函数 ---

/**
 * 递归删除目录及其内容。
 * @param string $dir 要删除的目录路径。
 * @return bool 成功返回 true，失败返回 false。
 */
function rrmdir($dir) {
    if (!file_exists($dir)) {
        return true;
    }
    if (!is_dir($dir)) {
        return unlink($dir);
    }
    foreach (scandir($dir) as $item) {
        if ($item == '.' || $item == '..') {
            continue;
        }
        if (!rrmdir($dir . DIRECTORY_SEPARATOR . $item)) {
            return false;
        }
    }
    return rmdir($dir);
}

/**
 * 在指定目录中生成模拟缓存文件。
 * @param string $targetDir 缓存文件生成的目标目录。
 * @return bool 成功返回 true，失败返回 false。
 */
function generateNewCache($targetDir) {
    echo "正在新的缓存目录中生成缓存: " . $targetDir . "\n";
    if (!is_dir($targetDir) && !mkdir($targetDir, 0755, true)) {
        echo "错误: 无法创建目标目录: " . $targetDir . "\n";
        return false;
    }

    // 模拟耗时较长的缓存生成过程
    for ($i = 1; $i <= 5; $i++) {
        $filename = $targetDir . "/data_{$i}.json";
        $data = json_encode(['id' => $i, 'timestamp' => time(), 'content' => "这是缓存内容 {$i}。"]);
        if (file_put_contents($filename, $data) === false) {
            echo "错误: 无法写入文件: " . $filename . "\n";
            return false;
        }
        echo "已生成 " . basename($filename) . "\n";
        sleep(1); // 模拟工作负载
    }
    echo "缓存生成完成。\n";
    return true;
}

// --- 主要缓存更新逻辑 ---

/**
 * 执行原子性缓存更新操作。
 * @return bool 成功返回 true，失败返回 false。
 */
function updateCacheAtomically() {
    // 1. 获取当前活动缓存目录的路径
    $currentActiveDir = '';
    if (file_exists(ACTIVE_CACHE_POINTER)) {
        // 尝试读取符号链接目标
        $currentActiveDir = readlink(ACTIVE_CACHE_POINTER);
        if ($currentActiveDir === false) {
            // 如果不是符号链接，可能是包含路径的普通文件
            $currentActiveDir = trim(file_get_contents(ACTIVE_CACHE_POINTER));
        }
    }
    echo "当前活动缓存目录: " . ($currentActiveDir ?: "无") . "\n";

    // 2. 准备一个新的临时缓存目录
    $newCacheVersion = 'cache_' . time(); // 使用时间戳作为版本号
    $newCacheDir = CACHE_BASE_DIR . '/' . $newCacheVersion;

    // 确保基准目录存在
    if (!is_dir(CACHE_BASE_DIR) && !mkdir(CACHE_BASE_DIR, 0755, true)) {
        echo "严重错误: 无法创建缓存基准目录: " . CACHE_BASE_DIR . "\n";
        return false;
    }

    // 3. 生成新的缓存内容
    if (!generateNewCache($newCacheDir)) {
        echo "缓存生成失败。中止更新。正在清理新的缓存目录。\n";
        rrmdir($newCacheDir); // 清理失败的尝试
        return false;
    }

    // 4. 原子性切换活动缓存目录
    echo "正在执行原子性切换...\n";
    $oldActiveTarget = $currentActiveDir; // 存储旧的活动目录，以便后续清理

    // 方案A: 使用符号链接 (推荐，对于目录切换最原子化)
    $tempSymlink = ACTIVE_CACHE_POINTER . '_temp';
    if (file_exists($tempSymlink)) {
        unlink($tempSymlink); // 确保临时符号链接不存在（处理上次失败的情况）
    }

    // 创建一个临时符号链接，指向新的缓存目录
    if (!symlink($newCacheDir, $tempSymlink)) {
        echo "错误: 无法创建指向新缓存的临时符号链接。中止。\n";
        rrmdir($newCacheDir);
        return false;
    }

    // 删除旧的活动符号链接（如果存在）
    if (file_exists(ACTIVE_CACHE_POINTER)) {
        unlink(ACTIVE_CACHE_POINTER);
    }
    // 原子性地将临时符号链接重命名为活动符号链接
    if (!rename($tempSymlink, ACTIVE_CACHE_POINTER)) {
        echo "错误: 无法原子性重命名符号链接。中止。\n";
        // 如果rename失败，可能导致没有active_cache_pointer，需要根据实际情况决定是否回滚
        rrmdir($newCacheDir);
        return false;
    }
    echo "原子性切换完成。新的活动缓存: " . readlink(ACTIVE_CACHE_POINTER) . "\n";

    // 方案B: 使用配置文件 (原子性稍弱，但非常快速)
    /*
    $configFilePath = CACHE_BASE_DIR . '/config_active_path.php';
    $configContent = "<?php define('ACTIVE_CACHE_PATH', '" . addslashes($newCacheDir) . "');\n";
    if (file_put_contents($configFilePath, $configContent, LOCK_EX) === false) { // 使用LOCK_EX增加并发安全性
        echo "错误: 无法更新活动缓存路径配置。中止。\n";
        rrmdir($newCacheDir);
        return false;
    }
    echo "配置文件已更新。新的活动缓存路径: " . $newCacheDir . "\n";
    */

    // 5. 清理旧的缓存目录
    if ($oldActiveTarget && file_exists($oldActiveTarget) && is_dir($oldActiveTarget)) {
        echo "正在清理旧的缓存目录: " . $oldActiveTarget . "\n";
        if (rrmdir($oldActiveTarget)) {
            echo "旧缓存清理成功。\n";
        } else {
            echo "警告: 无法清理旧的缓存目录: " . $oldActiveTarget . "\n";
        }
    } else {
        echo "没有旧的缓存目录可清理或它不存在。\n";
    }

    echo "缓存更新过程成功完成。\n";
    return true;
}

// --- 获取活动缓存路径的示例函数 (供应用层调用) ---
function getActiveCachePath() {
    if (file_exists(ACTIVE_CACHE_POINTER)) {
        $path = readlink(ACTIVE_CACHE_POINTER);
        if ($path === false) { // 如果不是符号链接，可能是包含路径的普通文件
            $path = trim(file_get_contents(ACTIVE_CACHE_POINTER));
        }
        if ($path && is_dir($path)) {
            return $path;
        }
    }
    return null; // 或者返回一个默认的备用路径
}

// --- 模拟使用 ---
echo "--- 初始状态 ---\n";
$currentCache = getActiveCachePath();
echo "当前用户访问的缓存: " . ($currentCache ?: "无") . "\n\n";

echo "--- 运行缓存更新 ---\n";
updateCacheAtomically();
echo "\n";

echo "--- 更新后状态 ---\n";
$currentCache = getActiveCachePath();
echo "当前用户访问的缓存: " . ($currentCache ?: "无") . "\n";

// 示例：访问一个缓存文件
if ($currentCache) {
    $exampleFile = $currentCache . '/data_1.json';