Redis分布式锁【简单版】

文章目录

- 概要
- 例子1【SETNX + EXPIRE】
- 例子2【 Redisson 】

概要

redis分布式锁六种方案

SETNX + EXPIRE 方案：
- 描述：使用Redis的SETNX命令来尝试设置一个键值对，如果该键不存在，则设置成功并设置过期时间，实现锁的功能。
SETNX + value值方案：
- 描述：通过SETNX命令尝试设置键值对，并将值设置为当前系统时间加上锁的过期时间，锁的释放可以通过比较值来判断是否过期。
Lua脚本方案：
- 描述：使用Lua脚本结合SETNX和EXPIRE两条指令，通过保证原子性来实现分布式锁。
SET的扩展命令（SET EX PX NX）方案：
- 描述：利用Redis的SET命令的扩展参数，结合EX、PX和NX参数，可以一步完成锁的设置。
开源框架 Redisson 方案：
- 描述：Redisson是一个基于Redis的Java框架，提供了分布式锁等多种分布式功能的实现，简化了开发者的工作。
多机实现的分布式锁 Redlock 方案：
- 描述：Redlock通过在多个Redis节点上获取锁，并使用时钟同步算法确保锁的可靠性和一致性。

例子1【SETNX + EXPIRE】

public class Test {private static final String LOCK_KEY = "my_lock";public static void main(String[] args) {// 连接到Redis服务器Jedis jedis = new Jedis("122.51.159.21", 6379);// 获取锁if (acquireLock(jedis, LOCK_KEY)) {try {// 执行需要加锁的业务逻辑System.out.println("锁已获取。正在执行关键部分...");// 模拟业务处理时间Thread.sleep(5000);} catch (InterruptedException e) {e.printStackTrace();} finally {// 保证释放锁releaseLock(jedis, LOCK_KEY);}} else {System.out.println("无法获取锁。另一个进程持有该锁。");}// 关闭连接jedis.close();}private static boolean acquireLock(Jedis jedis, String lockKey) {// 尝试设置锁，如果成功返回1，否则返回0Long result = jedis.setnx(lockKey, "locked");if (result == 1) {// 设置锁的过期时间jedis.expire(lockKey, 30);// 过期时间 30sreturn true;}return false;}private static void releaseLock(Jedis jedis, String lockKey) {// 释放锁jedis.del(lockKey);}
}

此方案缺点：

在高并发情况下，多个客户端可能同时执行 SETNX 命令并都成功获取锁，导致竞争条件发生
加锁与与设置过期时间是非原子操作
如果业务逻辑执行时间超过了过期时间，锁可能会在业务逻辑执行完之前被自动释放

例子2【 Redisson 】

public class Test {public static void main(String[] args) {// 创建 Redisson 客户端连接Config config = new Config();config.useSingleServer().setAddress("redis://122.51.159.21:6379");RedissonClient redisson = Redisson.create(config);// 获取分布式锁RLock lock = redisson.getLock("my_lock");try {// 尝试加锁，最多等待 10 秒，锁的持有时间为 20 秒boolean isLocked = lock.tryLock(10, 20, java.util.concurrent.TimeUnit.SECONDS);if (isLocked) {// 成功获取到锁System.out.println("成功获取到锁，执行业务逻辑...");// 在这里执行你的业务逻辑} else {// 获取锁失败System.out.println("获取锁超时，未能执行业务逻辑...");}} catch (InterruptedException e) {Thread.currentThread().interrupt();} finally {// 释放锁lock.unlock();}// 关闭 Redisson 客户端连接redisson.shutdown();}
}