Redis分布式锁

为什么需要分布式锁

在多线程环境中，如果多个线程同时访问共享资源（例如商品库存等秒杀场景下），会发生数据竞争，可能会导致出现脏数据或者系统问题，威胁到程序的正常运行。

我的项目中为了保证共享资源被安全的访问，使用了互斥锁对资源进行了保护，即同一时刻只有一个线程访问并修改资源，其他线程需要等到该线程释放才能去访问。

我们传统的单机多线程情况下：

Synchronized锁是锁本地的，属于JVM级别的（只能解决同一个jvm下多线程间的互斥），如果多个 JVM 进程共享同一份资源的话，使用本地锁就没办法实现资源的互斥访问了。因此我们引进了分布式锁。

分布式锁的定义

满足分布式系统下多进程可见并且互斥的锁。多个服务器（tomcat）之间可见的锁。

使用场景：同一个数据只能被修改一次，或者秒杀【数据的变化是需要被感知】

分布式锁的核心思想就是让大家都使用同一把锁，只要大家使用的是同一把锁，那么我们就能锁住线程，不让线程一起进行，让程序串行执行。

分布式锁底层主要用了redis的setnx命令：由于Redis是单线程的，用了setnx命令之后，只有一个客户端对某一个key设置值，在没有过期或删除key的时候其他客户端是不能设置这个key的。

setnx

Java代码中为setIfAbsent。这个命令在Redis中用于仅在指定的键不存在的时候设置键的值。如果键已存在，则不会执行任何操作，并且返回0表示设置失败。如果键不存在，则会设置新的值，并返回1表示设置成功。，

①防止误删其他锁，需要加个判断的逻辑，同时为了保证原子性

为了防止误删到其他的锁，这里我们建议使用 Lua 脚本通过 key 对应的 value（唯一值）来判断。

选用 Lua 脚本是为了保证解锁操作的原子性。因为 Redis 在执行 Lua 脚本时，可以以原子性的方式执行，从而保证了锁释放操作的原子性。

②为了防止在删除锁的时候，服务器突然宕机，导致锁一直不存在，我们需要加个过期时间

具体怎么实现的？

我们通过UUID来区分不同JVM发来的请求，这样将来在删除锁之前进行判断的时候就不会误删

private static final String ID_PREFIX = UUID.randomUUID().toString(true) + "-";
@Override
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);
}

删除锁

public void unlock() {// 获取线程标示String threadId = ID_PREFIX + Thread.currentThread().getId();// 获取锁中的标示String id = stringRedisTemplate.opsForValue().get(KEY_PREFIX + name);// 判断标示是否一致if(threadId.equals(id)) {// 释放锁stringRedisTemplate.delete(KEY_PREFIX + name);}
}