当前位置：首页 > article >正文

Redis缓存和Mysql数据一致性问题

article 2024/11/13 14:50:27

在高并发环境下，保持 Redis 缓存和 MySQL 数据库的数据一致性是一个复杂但至关重要的任务。下面是对这一问题的详细讲解，并结合 PHP 代码示例来展示如何解决这些一致性问题。

问题背景

Redis 缓存和 MySQL 数据库的主要挑战在于：

缓存和数据库之间的延迟：在缓存更新与数据库更新之间，可能存在时间差，导致数据不一致。
高并发下的缓存击穿：缓存被并发请求同时击穿，导致大量请求直接访问数据库。
缓存雪崩：大量缓存同时过期，导致瞬间对数据库的压力激增。
缓存穿透：恶意请求绕过缓存直接访问数据库，造成数据库的压力。

解决方案

1. 缓存一致性策略

Cache Aside Pattern (旁路缓存模式) 是最常用的缓存一致性策略：

读取：先从缓存读取数据，如果缓存中有数据，直接返回；如果缓存中没有数据，则从数据库中读取，并将数据写入缓存。
写入：先更新数据库，然后删除缓存，使下一次读取时重新从数据库获取数据。

示例代码：

function getFromCacheOrDb($key) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);

    // 从缓存中读取数据
    $cachedData = $redis->get($key);
    if ($cachedData !== false) {
        return $cachedData;
    }

    // 缓存未命中，从数据库中查询
    $data = getDataFromDb($key);
    if ($data) {
        $redis->setex($key, 3600, $data); // 缓存 1 小时
    }
    return $data;
}

function updateData($key, $newData) {
    $db = new PDO('mysql:host=localhost;dbname=test', 'root', '');

    // 更新数据库
    $stmt = $db->prepare("UPDATE table_name SET value = :value WHERE key = :key");
    $stmt->execute([':value' => $newData, ':key' => $key]);

    // 删除缓存
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->del($key);
}

优点：

简单易用，符合大多数场景。

缺点：

在高并发下，可能会有缓存击穿问题。

2. 延迟双删

延迟双删策略是针对 Cache Aside 模式的改进，主要用于防止缓存和数据库的更新顺序导致数据不一致问题：

更新数据库。
删除缓存。
等待一段时间（例如 500ms），然后再次删除缓存。

示例代码：

function updateDataWithDelayDelete($key, $newData) {
    $db = new PDO('mysql:host=localhost;dbname=test', 'root', '');

    // 更新数据库
    $stmt = $db->prepare("UPDATE table_name SET value = :value WHERE key = :key");
    $stmt->execute([':value' => $newData, ':key' => $key]);

    // 删除缓存
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->del($key);

    // 延迟再次删除缓存
    usleep(500 * 1000); // 延迟 500ms
    $redis->del($key);
}

优点：

有效减少了因为缓存删除延迟导致的数据不一致。

缺点：

延迟设置不当可能仍会导致短暂的不一致。

3. 分布式锁

分布式锁可以确保在高并发情况下，只有一个线程可以进行数据和缓存的更新操作。Redis 提供了实现分布式锁的能力。

示例代码：

function updateDataWithLock($key, $newData) {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);

    $lockKey = "lock:" . $key;
    if ($redis->set($lockKey, 1, ['nx', 'ex' => 5])) { // 获取锁，超时 5 秒
        try {
            // 更新数据库
            $db = new PDO('mysql:host=localhost;dbname=test', 'root', '');
            $stmt = $db->prepare("UPDATE table_name SET value = :value WHERE key = :key");
            $stmt->execute([':value' => $newData, ':key' => $key]);

            // 删除缓存
            $redis->del($key);
        } finally {
            // 释放锁
            $redis->del($lockKey);
        }
    } else {
        // 获取不到锁，稍后重试
        return false;
    }

    return true;
}

优点：