欢迎你们加我微信itsoku一块儿交流java、算法、数据库相关技术。javascript
数据存储在数据库中,为了加快业务访问的速度,咱们将数据库中的一些数据放在缓存中,那么问题来了,如何确保db和缓存中数据的一致性呢?咱们列出了5种方法,你们都了解一下,而后根据业务本身选择。java
使用过定时器,定时刷新redis中的缓存。redis
更新数据不用考虑缓存中的数据,直接更新数据就能够了算法
缓存中数据和db中数据一致性可能没有那么及时,不过最终在某个时间点,数据是一致的。sql
c1:根据key在redis中获取对应的value数据库
u1:开始db事务缓存
上面u3成功,u4失败,会致使删除缓存失败,致使缓存中数据和db数据会不一致。微信
若是同时有不少线程到达c2发现缓存不存在,同时请求c3访问db,会对db形成很大的压力多线程
c1:根据key在redis中获取对应的valueapp
u1:删除redis中当前数据的缓存
更新数据的线程执行u1成功以后,u2还未执行时,此时获取缓存的线程恰好执行了c1到c3的逻辑,此时会将旧的数据放入redis,致使redis和db数据不一致
一样存在方案2中说到的问题:若是同时有不少线程到达c2发现缓存不存在,同时请求c3访问db,会对db形成很大的压力
对方案2作改进,确保db更新成功以后,删除缓存操做必定会执行,咱们能够经过可靠消息来实现,可靠消息能够确保更新db操做和删除redis中缓存最终要么都成功要么都失败,依靠的是最终一致性来实现的。
改进以后过程以下。
c1:根据key在redis中获取对应的value
u1:开始db事务
接受到清理redis缓存的消息以后,将redis中对应的缓存清除。
更新db和清理redis中的缓存之间存在必定的时间延迟,这段时间内,redis缓存的数据是旧的,也就是说这段时间内db和缓存数据是不一致的,可是最终会一致,这个不一致的时间可能比较小(这个须要看消息消费的效率了)
一样存在方案2中说到的问题:若是同时有不少线程到达c2发现缓存不存在,同时请求c3访问db,会对db形成很大的压力
咱们先了解一些知识。
获取key的值,若是存在,则返回;若是不存在,则返回nil
setnx的含义就是SET if Not Exists,该方法是原子的,若是key不存在,则设置当前key成功,返回1;若是当前key已经存在,则设置当前key失败,返回0
将key对应的值从redis中删除
select v from t where t.key = #key# for update;
update t set v = #v# where t.key = #key#;
上面两个sql会相互阻塞,直到其中一个提交以后,另一个才能够继续执行。
下面咱们就经过上面的知识来实现db和缓存强一致性。
1.打开db事务 2.update t set v = #v# where t.key = #key#; 3.根据key删除redis中的缓存:RedisUti.del(key); 4.提交db事务
/*公众号:路人甲Java * 工做10年的前阿里P7分享Java、算法、数据库方面的技术干货! * 坚信用技术改变命运,让家人过上更体面的生活。*/ public class CacheUtil { //根据key获取缓存中对应的value public static String getCache(String key) throws InterruptedException { String value = RedisUtils.get(key); if (value != null) { return value; } //过时时间为当前时间+5秒 String expireTimeKey = key + "ExpireTime"; long expireTimeValue = System.currentTimeMillis() + 5000; //setnx是原子操做,因此只有一个会成功 int setnx = RedisUtils.setnx(expireTimeKey, expireTimeValue + ""); if (setnx == 0) { expireTimeValue = Long.valueOf(RedisUtils.get(expireTimeKey)); //若是expireTimeValue小于当前时间,说明expireTimeKey过时了,将其删除 if (System.currentTimeMillis() > expireTimeValue) { //将expireTimeKey对应的删除 RedisUtils.del(expireTimeKey); } else { //休眠1秒继续获取 TimeUnit.SECONDS.sleep(1); } //重试 return getCache(key); } else { //1. 开启db事务 start transaction; //2. 执行update t set v = #v# where t.key = #key# for update; 将v的值赋值给value select v from t# where t.key = #key# for update; RedisUtils.set(key, value); //3.提交db事务 commit transaction; } return value; } //redis工具类,内部方法为伪代码 public static class RedisUtils { //根据key获取value public static String get(String key) { return null; } //设置key对应的value public static void set(String key, String value) { } //删除redis中一个key对应的值 public static void del(String key) { } //setnx的含义就是SET if Not Exists,该方法是原子的,若是key不存在, //则设置当前key成功,返回1;若是当前key已经存在,则设置当前key失败,返回0 public static int setnx(String key, String value) { return 1; } } }
这种方式能够确保db和redis中缓存同一时间强一致,有问题的能够留言交流!
路人甲java
▲长按图片识别二维码关注
路人甲java:工做10年的前阿里P7分享Java、算法、数据库方面的技术干货!坚信用技术改变命运,让家人过上更体面的生活!