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

在高并发环境下，保持 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;
}

优点：