JAVA 精髓面试题 · Redisson 分布式锁与 RedLock 深度解析

lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); lock.lock(10, TimeUnit.SECONDS); System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行 System.out.println(Thread.currentThread().getName()+"准备进行累加。"); Thread.sleep(2000); count++; } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } countDownLatch.countDown(); }); } countDownLatch.await(); System.out.println(count); } } System.out.println(Thread.currentThread().getName()+"准备进行累加。"); Thread.sleep(2000); count++; } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } countDownLatch.countDown(); }); } countDownLatch.await(); System.out.println(count); } } https://github.com/redisson/redisson/ https://redisson.org/ 锁过期时间不好评估怎么办？集群下的锁还安全么？基于 Redis 的实现分布式锁，前面遇到的问题，以及对应的解决方案： 1、死锁：设置过期时间 2、过期时间评估不好，锁提前过期：守护线程，自动续期 3、锁被别人释放：锁写入唯一标识，释放锁先检查标识，再释放之前分析的场景都是，锁在「单个」 Redis实例中可能产生的问题，并没有涉及到 Redis 的部署架构细节。而我们在使用 Redis 时，一般会采用主从集群 +哨兵的模式部署，这样做的好处在于，当主库异常宕机时，哨兵可以实现「故障自动切换」，把从库提升为主库，继续提供服务，以此保证可用性。但是因为主从复制是异步的，那么就不可避免会发生的锁数据丢失问题（加了锁却没来得及同步过来）。从库被哨兵提升为新主库，这个锁在新的主库上，丢失了！ Redlock真的安全吗？ Redis 作者提出的 Redlock方案，是如何解决主从切换后，锁失效问题的。 Redlock 的方案基于一个前提：不再需要部署从库和哨兵实例，只部署主库；但主库要部署多个，官方推荐至少 5 个实例。注意：不是部署 Redis Cluster，就是部署 5 个简单的 Redis 实例。它们之间没有任何关系，都是一个个孤立的实例。做完之后，我们看官网代码怎么去用的： 8. 分布式锁和同步器 · redisson/redisson Wiki · GitHub 8.4. 红锁（RedLock）

1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 1）客户端 1 请求锁定节点 A、 B、C、 D、 E 2）客户端 1 的拿到锁后，进入 GC （时间比较久） 3）所有 Redis 节点上的锁都过期了 4）客户端 2 获取到了 A、 B、C、 D、 E 上的锁 5）客户端 1 GC 结束，认为成功获取锁 6）客户端 2 也认为获取到了锁，发生「冲突」 GC 和网络延迟问题：这两点可以在红锁实现流程的第3步来解决这个问题。 GC 和网络延迟问题：这两点可以在红锁实现流程的第3步来解决这个问题。但是最核心的还是时钟漂移，因为时钟漂移，就有可能导致第3步的判断本身就是一个BUG，所以当多个 Redis 节点「时钟」发生问题时，也会导致 Redlock 锁失效。