java中redis分布式锁

### Java Redis 分布式锁实现方案 #### 1. 使用`SETNX`和`EXPIRE`命令 在Java中，可以通过`Jedis`客户端使用Redis的`SETNX`和`EXPIRE`命令来实现分布式锁。这种方式需要确保加锁和设置过期时间的操作是原子性的，否则可能导致锁不一致的问题[^1]。 ```java import redis.clients.jedis.Jedis; public class RedisDistributedLock { private static final String LOCK_SUCCESS = "OK"; private static final String SET_IF_NOT_EXIST = "NX"; private static final String SET_WITH_EXPIRE_TIME = "PX"; public boolean tryGetDistributedLock(Jedis jedis, String lockKey, String requestId, int expireTime) { String result = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime); return LOCK_SUCCESS.equals(result); } } ``` #### 2. 使用Lua脚本保证原子性 为了确保`SETNX`和`EXPIRE`操作的原子性，可以使用Lua脚本来封装这两个命令。Lua脚本在Redis中是原子执行的，避免了多线程竞争时可能出现的问题[^2]。 ```lua if redis.call("setnx", KEYS[1], ARGV[1]) == 1 then redis.call("expire", KEYS[1], ARGV[2]) return 1 else return 0 end ``` 在Java代码中调用Lua脚本如下： ```java public boolean tryGetDistributedLockWithLua(Jedis jedis, String lockKey, String requestId, int expireTime) { List<String> keys = Collections.singletonList(lockKey); List<String> args = Arrays.asList(requestId, String.valueOf(expireTime)); Object result = jedis.eval(LUA_SCRIPT, keys, args); return "1".equals(String.valueOf(result)); } ``` #### 3. 使用Redisson库 Redisson是一个用于Redis的Java客户端，提供了更高级别的抽象，简化了分布式锁的实现。Redisson支持多种类型的锁，包括可重入锁、公平锁等，并且内置了自动续期机制[^2]。 ```java import org.redisson.Redisson; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.redisson.config.Config; public class RedissonDistributedLock { public void useRedissionLock(RedissonClient redisson, String lockKey) { RLock lock = redisson.getLock(lockKey); lock.lock(); try { // 执行业务逻辑 } finally { lock.unlock(); } } } ``` #### 4. 处理锁超时问题 为了避免锁因超时而被误释放，可以在加锁时设置合理的过期时间，并在业务逻辑中定期续约锁。Redisson通过看门狗机制自动延长锁的有效期，防止锁提前过期[^2]。 #### 5. 集群环境下的分布式锁 在Redis集群环境中，可以使用`Redlock`算法来实现更可靠的分布式锁。`Redlock`算法通过在多个Redis节点上尝试获取锁，确保即使某个节点宕机也不会影响锁的可用性[^2]。 ```java import org.redisson.api.RLock; import org.redisson.api.RedissonClient; public void useRedlock(RedissonClient redisson, String lockKey) { RLock lock = redisson.getLock(lockKey); boolean isLocked = lock.tryLock(10, 30, TimeUnit.SECONDS); if (isLocked) { try { // 执行业务逻辑 } finally { lock.unlock(); } } } ``` --- ###