PHP中Redis与文件双层缓存优化及连接复用合理性问询

一、static变量复用Redis连接的正确性 #

用static变量在cache_connection()中复用Redis对象是正确且合理的。PHP中函数内的static变量会在同一次请求的多次调用间保持状态，单页最多10次请求的场景下，这种方式能避免重复创建Redis连接，减少TCP握手、认证等开销，直接提升性能。

但要注意一个潜在问题：如果第一次连接Redis失败（比如服务宕机），static变量会保存一个失效的连接对象，后续调用都会复用这个失效对象，导致所有Redis缓存请求都失败。因此必须在函数内增加连接有效性检查和异常处理。

二、cache_connection()函数优化方案 #

1. 增加异常处理与连接重试 #

捕获连接异常，失败时重置static变量，避免复用失效连接：

function cache_connection() {
    if (!defined('CACHE_REDIS') || !CACHE_REDIS) {
        return null;
    }
    
    static $redis = null;
    
    // 检查连接是否有效
    if ($redis instanceof Redis && $redis->isConnected()) {
        return $redis;
    }
    
    $redis = new Redis();
    try {
        $redis->connect(REDIS_HOST, REDIS_PORT, REDIS_TIMEOUT);
        if (defined('REDIS_PASSWORD') && REDIS_PASSWORD) {
            $redis->auth(REDIS_PASSWORD);
        }
        // 可选：指定Redis数据库
        if (defined('REDIS_DB') && REDIS_DB >= 0) {
            $redis->select(REDIS_DB);
        }
        return $redis;
    } catch (RedisException $e) {
        // 记录错误日志，方便排查问题
        error_log("Redis连接失败: " . $e->getMessage());
        $redis = null;
        return null;
    }
}

2. 配置参数解耦 #

把Redis连接参数从硬编码改为配置文件常量，适配不同部署环境：

// 示例配置（可放在config.php）
define('REDIS_HOST', '127.0.0.1');
define('REDIS_PORT', 6379);
define('REDIS_TIMEOUT', 2);
define('REDIS_PASSWORD', 'your_redis_password');
define('REDIS_DB', 0);

3. 快速兼容关闭状态 #

函数开头直接判断CACHE_REDIS常量，若关闭则直接返回null，避免执行不必要的连接逻辑。

三、整体缓存机制优化方案 #

1. 缓存键生成优化 #

• 增加前缀：给Redis键和文件名加上cache_sql_前缀，避免与其他业务缓存冲突，方便批量管理。
• 加入版本号：比如cache_sql_v1_xxx，当缓存逻辑变更时，修改版本号即可让旧缓存全部失效，无需逐个清理。

function generate_cache_key($sql, $querystring = '') {
    $raw_content = $sql . '|' . $querystring;
    return 'cache_sql_v1_' . md5($raw_content);
}

2. 缓存失效策略 #

• Redis缓存设置TTL：给写入Redis的缓存添加过期时间，避免数据长期过期，示例设置1小时TTL：

function cache_write_redis($key, $data, $ttl = 3600) {
    $redis = cache_connection();
    if ($redis) {
        $redis->setex($key, $ttl, json_encode($data));
    }
}

• 文件缓存添加过期检查：写入时记录过期时间，读取时判断是否失效，过期则自动清理：

function cache_write_file($key, $data, $ttl = 7200) {
    $file_path = get_file_path($key);
    $cache_data = json_encode([
        'data' => $data,
        'expire_at' => time() + $ttl
    ]);
    file_put_contents($file_path, $cache_data);
}

function cache_read_file($key) {
    $file_path = get_file_path($key);
    if (!file_exists($file_path)) return null;
    
    $cache_data = json_decode(file_get_contents($file_path), true);
    if (time() > $cache_data['expire_at']) {
        unlink($file_path); // 清理过期缓存
        return null;
    }
    return $cache_data['data'];
}

3. 降级逻辑与日志增强 #

• 增加缓存命中/未命中日志：记录每次缓存获取情况，方便排查性能瓶颈：

function get_data($sql, $querystring = '') {
    $key = generate_cache_key($sql, $querystring);
    $data = null;
    
    if (CACHE_REDIS) {
        $data = cache_read_redis($key);
        error_log($data !== null ? "Redis缓存命中: {$key}" : "Redis缓存未命中: {$key}");
    }
    
    if ($data === null && CACHE_FILES) {
        $data = cache_read_file($key);
        error_log($data !== null ? "文件缓存命中: {$key}" : "文件缓存未命中: {$key}");
    }
    
    if ($data === null) {
        $data = fetch_from_mysql($sql, $querystring);
        error_log("从MySQL获取数据: {$key}");
        // 写入缓存（空值也缓存，设置较短TTL）
        $ttl = empty($data) ? 300 : 3600;
        cache_write_redis($key, $data, $ttl);
        cache_write_file($key, $data, $ttl);
    }
    
    return $data;
}

• Redis连接失败直接跳过：若cache_connection()返回null，直接走文件缓存或DB，避免浪费时间。

4. 文件缓存性能优化 #

• 分层存储：按缓存键的前两位创建子目录，避免单个目录文件过多导致IO性能下降：

function get_file_path($key) {
    $prefix = substr($key, 0, 2);
    $dir = CACHE_DIR . '/' . $prefix;
    if (!is_dir($dir)) mkdir($dir, 0755, true);
    return $dir . '/' . $key . '.json';
}

• 并发写入锁：用flock()避免多个请求同时写入同一文件：

function cache_write_file($key, $data, $ttl = 7200) {
    $file_path = get_file_path($key);
    $cache_data = json_encode([
        'data' => $data,
        'expire_at' => time() + $ttl
    ]);
    
    $handle = fopen($file_path, 'w');
    if ($handle) {
        flock($handle, LOCK_EX); // 排他锁
        fwrite($handle, $cache_data);
        flock($handle, LOCK_UN);
        fclose($handle);
    }
}

5. 缓存一致性保障 #

当MySQL数据更新时，主动删除对应缓存，避免脏数据：

function invalidate_cache($sql, $querystring = '') {
    $key = generate_cache_key($sql, $querystring);
    
    // 删除Redis缓存
    if (CACHE_REDIS) {
        $redis = cache_connection();
        if ($redis) $redis->del($key);
    }
    
    // 删除文件缓存
    if (CACHE_FILES) {
        $file_path = get_file_path($key);
        if (file_exists($file_path)) unlink($file_path);
    }
}

// 示例：更新数据后调用
update_mysql($update_sql);
invalidate_cache($query_sql, $querystring);

6. 空值缓存优化 #

DB查询结果为空时也缓存空值，设置较短TTL（比如5分钟），避免重复查询空数据。

7. 配置集中管理 #

把所有缓存配置集中到一个配置文件，替代硬编码常量，方便不同环境快速切换：

// config.php
return [
    'cache' => [
        'redis' => true,
        'redis_host' => '127.0.0.1',
        'redis_port' => 6379,
        'redis_password' => '',
        'redis_db' => 0,
        'redis_ttl' => 3600,
        'files' => true,
        'files_dir' => '/var/www/cache',
        'files_ttl' => 7200,
    ]
];

内容的提问来源于stack exchange，提问作者Andres SK