利用互斥锁解决缓存击穿问题

标签：缓存 击穿 查询 互斥 线程 key stringRedisTemplate

核心思路：相较于原来从缓存中查询不到数据后直接查询数据库而言，现在的方案是 进行查询之后，如果从缓存没有查询到数据，则进行互斥锁的获取，获取互斥锁后，判断是否获得到了锁，如果没有获得到，则休眠，过一会再进行尝试，直到获取到锁为止，才能进行查询

如果获取到了锁的线程，再去进行查询，查询后将数据写入redis，再释放锁，返回数据，利用互斥锁就能保证只有一个线程去执行操作数据库的逻辑，防止缓存击穿

 

 

 

 

 

 

 

 

 

 

 

 

 

操作锁的代码：

核心思路就是利用redis的setnx方法来表示获取锁，该方法含义是redis中如果没有这个key，则插入成功，返回1，在stringRedisTemplate中返回true， 如果有这个key则插入失败，则返回0，在stringRedisTemplate返回false，我们可以通过true，或者是false，来表示是否有线程成功插入key，成功插入的key的线程我们认为他就是获得到锁的线程。

简易版： 设置过期时间防止死锁

 private boolean tryLock(String key) {
        Boolean flag = stringRedisTemplate.opsForValue().setIfAbsent(key, "1", 10, TimeUnit.SECONDS);
        return BooleanUtil.isTrue(flag);
    }

    private void unlock(String key) {
        stringRedisTemplate.delete(key);
    }

思考： 释放锁的时候，没有判断释放的是不是自己的锁，最终会导致锁失效。

如何标识是自己的锁呢？ 我们在执行相关命令时，都使用了主线程，那么主线程ID是一直跟随，将主线程ID融合进去。

   public boolean tryLock(long timeoutSec) {
       //获取主线程标识
        String threadId = ID_PREFIX + Thread.currentThread().getId();
        // 获取锁
        Boolean success = stringRedisTemplate.opsForValue()
                .setIfAbsent(KEY_PREFIX + name, threadId, timeoutSec, TimeUnit.SECONDS);
        return Boolean.TRUE.equals(success);
    }

锁释放的时候，要保证缓存已经重建完成了， 如何保证呢

 

标签：缓存,击穿,查询,互斥,线程,key,stringRedisTemplate
From： https://www.cnblogs.com/kisshappyboy/p/16929409.html