redis分布式锁，setnx+lua脚本的java实现|京东物流技术团队

在现在工作中，为保障服务的高可用，应对单点故障、负载量过大等单机部署带来的问题，生产环境常用多机部署。为解决多机房部署导致的数据不一致问题，我们常会选择用分布式锁。

目前其他比较常见的实现方案我列举在下面：

1. 基于缓存实现分布式锁（本文主要使用redis实现）
2. 基于数据库实现分布式锁
3. 基于zookeeper实现分布式锁

本文是基于redis缓存实现分布式锁，其中使用了setnx命令加锁，expire命令设置过期时间并lua脚本保证事务一致性。Ja va实现部分基于JIMDB提供的接口。JIMDB是京东自主研发的基于Redis的分布式缓存与高速键值存储服务。

基本语法：SETNX KEY VALUE

SETNX 是表示 SET ifNot eXists， 即命令在指定的 key 不存在时，为 key 设置指定的值。

KEY 是表示待设置的key名

VALUE是设置key的对应值

若设置成功，则返回1；若设置失败（key存在），则返回0。

由此，我们会选择用SETNX来进行分布式锁的实现，当Key存在时，会返回加锁失败的信息。

SET 与 SETNX 区别：

SET 如果key已经存在，则会覆盖原值，且无视类型

SETNX 如果key已经存在，则会返回0，表示设置key失败

Redis 2.6.12版本前后对比：

2.6.12版本前：分布式锁并不能只用SETNX实现，需要搭配EXPIRE命令设置过期时间，否则，key将永远有效。其中，为保证SETNX和EXPIRE在同一个事务里，我们需要借助LUA脚本来完成事务实现。（由于在写这篇文章时，JIMDB还未支持SET key value [EX seconds|PX milliseconds] [NX|XX] [KEEPTTL]语法，故本文依然用lua事务）

2.6.12版本后：SET key value [EX seconds|PX milliseconds] [NX|XX] [KEEPTTL] 语法糖可用于分布式锁并支持原子操作，无需EXPIRE命令设置过期时间。

什么是LUA脚本？

Lua是一种轻量小巧的脚本语言,用标准C语言编写并以源代码形式开放,其设计目的是为了嵌入应用程序种,从而为程序提供灵活的扩展和定制功能。

为什么需要用到LUA脚本？

本文的锁实现是基于两个Redis命令 - SETNX 和 EXPIRE。 为保证命令的原子性，我们将这两个命令写入LUA脚本，并上传至Redis服务器。Redis服务器会单线程执行LUA脚本，以确保两个命令在执行期间不被其他请求打断。

LUA脚本的优势

• 减少网络开销。若干命令的多次请求，可组合成一个脚本进行一次请求
• 高复用性。脚本编辑一次后，相同代码逻辑可多处使用，只需将不同的参数传入即可。
• 原子性。若期望多个命令执行期间不被其他请求打断，或出现竞争状态，可以用LUA脚本实现，同时保证了事务的一致性。

分布式锁LUA脚本的实现

假设在同一时刻只能创建一个订单，我们可以将orderId作为key值，uuid作为value值。过期时间设置为3秒。

LUA脚本如下，通过Redis的eval/evalsha命令实现：

-- lua加锁脚本
-- KEYS[1],ARGV[1],ARGV[2]分别对应了orderId，uuid，3
-- 如果setnx成功，则继续expire命令逻辑
if redis.call('setnx',KEYS[1],ARGV[1]) == 1
    then
      -- 则给同一个key设置过期时间
       redis.call('expire',KEYS[1],ARGV[2])
       return 1
    else
      -- 如果setnx失败，则返回0
       return 0
end

-- lua解锁脚本
-- KEYS[1],ARGV[1]分别对应了orderId，uuid
-- 若无法获取orderId缓存，则认为已经解锁
if redis.call('get',KEYS[1]) == false
    then
        return 1
    -- 若获取到orderId，并value值对应了uuid，则执行删除命令
    elseif redis.call('get',KEYS[1]) == ARGV[1]
    then
        -- 删除缓存中的key
        return redis.call('del',KEYS[1])
    else
        -- 若获取到orderId，且value值与存入时不一致，则返回特殊值，方便进行后续逻辑
        return 2
end

【注】根据Redis的版本，在LUA脚本中，当使用redis.call('get',key)判定缓存key不存在时，需要注意对比值为布尔类型的false，还是null。

在RESP3中，redis cli返回的是空值时，lua会用布尔类型false来代替。

RESP3简介

RESP3是Redis6的新特性，是RESP v2的新版本。该协议用于客户端和服务器之间的请求响应通信。由于该协议可以不对称的使用，即客户端发送一个简单的请求，服务器可以将更复杂的并扩充后的相关信息返回到客户端。升级后的协议，引入了13种数据类型，使之更适用于数据库的交互场景。

调用类实现代码

SoRedisLock soJimLock = null;
try{
    soJimLock = new SoRedisLock("orderId", jimClient);
    if (!soJimLock.lock(3)) {
        log.error("订单创建加锁失败");
        throw new BPLException("订单创建加锁失败");
    }
} catch(Exception e) {
    throw e;
} finally {
    if (null != soJimLock) {
        soJimLock.unlock();
    }
}

分布式锁实现类代码

public class SoRedisLock{

    /** 加锁标志 */
    public static final String LOCKED = "TRUE";
    /** 锁的关键词 */
    private String key;
    private Cluster jimClient;

    /**
     * lock的构造函数
     *
     * @param key
     *            key+"_lock" (key使用唯一的业务单号)
     * @param
     *
     */
    public SoRedisLock(String key, Cluster jimClient)
    {
        this.key = key + "_LOCK";
        this.jimClient = jimClient;
    }

    /**
     * 加锁
     *
     * @param expire
     *            锁的持续时间（秒），过期删除
     * @return 成功或失败标志
     */
    public boolean lock(int expire)
    {
        try
        {
            log.info("分布式事务加锁，key：{}", this.key);
            String lua_scripts = "if redis.call('setnx',KEYS[1],ARGV[1]) == 1 then " +
                    "redis.call('expire',KEYS[1],ARGV[2]) return 1 else return 0 end";
            String sha = jimClient.scriptLoad(lua_scripts);
            List keys = new ArrayList<>();
            List values = new ArrayList<>();
            keys.add(this.key);
            values.add(LOCKED);
            values.add(String.valueOf(expire));
            this.locked = jimClient.evalsha(sha, keys, values, false).equals(1L);
            return this.locked;
        } catch (Exception e){
            throw new RuntimeException("Locking error", e);
        }
    }

    /**
     * 解锁 无论是否加锁成功，都需要调用unlock 建议放在finally 方法块中
     */
    public void unlock()
    {
        if (this.jimClient == null || !this.locked) {
            return ;
        }
        try {
        String luaScript = "if redis.call('get',KEYS[1]) == false then return 1 " +
                "elseif redis.call('get',KEYS[1]) == ARGV[1] then " +
                "return redis.call('del',KEYS[1]) else return 2 end";
        String sha = jimClient.scriptLoad(luaScript);
        if(!jimClient.evalsha(sha, Collections.singletonList(this.key), Collections.singletonList(LOCKED), false).equals(1L)){
            throw new RuntimeException("解锁失败,key:"+this.key);
        }
        } catch (Exception e) {
                log.error("unLocking error, key:{}", this.key, e);
            throw new RuntimeException("unLocking error, key:"+this.key);
        }
    }
}

在这儿，我们仅以key-value进行加锁操作，其中的value并无实际意义。所以，本文给key对应的value设定了一个固定值。Jimdb提供了上传脚本的API，我们借助scriptLoad()方法将lua脚本上传至redis服务器，再利用evalsha()方法执行脚本。evalsha()的返回值，就是脚本中设置的return的返回值。

我们通过list将参数传入脚本中，并对应脚本中的标记位。例如上方的代码中：

“orderId_LOCK”对应了脚本中的KEYS[1]

“TRUE”对应了脚本中的ARGV[1]

“3”对应了脚本中的ARGV[2]

【注】要是一个脚本里有多个key，就得保证redis里的hashtag是启用的，不然分片可能会让key不在同一个分片里，从而出现“Only support single key or use same hashTag”异常。不过，启用hashtag得小心，不然分片不均匀会导致流量集中，让服务器压力过大。

实际使用中的日志截图



通过上述介绍我们了解到如何保证Redis多个命令的原子性。当然，Redis事务一致性，也可以选择Redis的事务（Transaction）操作来实现。Jimdb也有API支持事务的multi，discard，exec，watch和unwatch命令。本文之所以选择使用LUA脚本来进行实现，主要是考虑到目前Jimdb在执行事务时，流量只会打到主实例，多实例的负载均衡会失效。更多的可行方案等待大家的探索，我们下个文档见。

Redis分布式锁： https://www.cnblogs.com/niceyoo/p/13711149.html

Redis中使用Lua脚本：https://zhuanlan.zhihu.com/p/77484377

Redis Eval命令： https://www.redis.net.cn/order/3643.html

LUA API： https://redis.io/docs/interact/programmability/lua-api/