基于Redis实现分布式锁的方法（lua脚本版）

1、前言

在java中，我们通过锁来避免由于竞争而造成的数据不一致问题。通常我们使用synchronized 、lock来实现。但是java中的锁只能保证在同一个jvm进程内中可用，在跨jvm进程，例如分布式系统上则不可靠了。

2、分布式锁

分布式锁，是一种思想，它的实现方式有很多，如基于数据库实现、基于缓存（redis等）实现、基于zookeeper实现等等。为了确保分布式锁可用，我们至少要确保锁的实现同时满足以下四个条件

互斥性：在任意时刻，只有一个客户端能持有锁。
不会发生死锁：即使客户端在持有锁的期间崩溃而没有主动解锁，也能保证后续其他客户端能加锁。
具有容错性：只要大部分的redis节点正常运行，客户端就可以加锁和解锁。
解铃还须系铃人：加锁和解锁必须是同一个客户端，客户端自己不能把别人加的锁给解了。

3、基于redis实现分布式锁

以下代码实现了基于redis中间件的分布式锁。加锁的过程中为了保障setnx（设置key）和expire（设置超时时间）尽可能在一个事务中，使用到了lua脚本的方式，将需要完成的指令一并提交到redis中；

3.1、redisconfig.java

				?

									package com.demo.configuration;

									import org.springframework.context.annotation.bean;

									import org.springframework.context.annotation.configuration;

									import org.springframework.data.redis.connection.redisconnectionfactory;

									import org.springframework.data.redis.core.redistemplate;

									import org.springframework.data.redis.serializer.genericjackson2jsonredisserializer;

									import org.springframework.data.redis.serializer.stringredisserializer;

									@configuration

									public class redisconfig {

									    @bean

									    public redistemplate<string, object> redistemplate(redisconnectionfactory factory) {

									        redistemplate<string, object> template = new redistemplate<>();

									        template.setconnectionfactory(factory);

									        // key采用string的序列化方式

									        template.setkeyserializer(new stringredisserializer());

									        // value序列化方式采用jackson

									        template.setvalueserializer(new genericjackson2jsonredisserializer());

									        template.afterpropertiesset();

									        return template;

									    }

									}

3.2、redislockcontroller.java

				?

									package com.demo.controller;

									import org.springframework.beans.factory.annotation.autowired;

									import org.springframework.core.io.classpathresource;

									import org.springframework.data.redis.core.redistemplate;

									import org.springframework.data.redis.core.script.defaultredisscript;

									import org.springframework.scripting.support.resourcescriptsource;

									import org.springframework.web.bind.annotation.pathvariable;

									import org.springframework.web.bind.annotation.requestmapping;

									import org.springframework.web.bind.annotation.restcontroller;

									import java.util.arrays;

									@restcontroller

									@requestmapping("/redis")

									public class redislockcontroller {

									    @autowired

									    private redistemplate<string, object> redistemplate;

									    @requestmapping(value = "/lock/{key}/{uid}/{expire}")

									    public long lock(@pathvariable("key") string key, @pathvariable("uid") string uid, @pathvariable("expire") integer expire) {

									        long result = null;

									        try {

									            //调用lua脚本并执行

									            defaultredisscript<long> redisscript = new defaultredisscript<>();

									            redisscript.setresulttype(long.class);//返回类型是long

									            //lua文件存放在resources目录下的redis文件夹内

									            redisscript.setscriptsource(new resourcescriptsource(new classpathresource("redis/redis_lock.lua")));

									            result = redistemplate.execute(redisscript, arrays.aslist(key), uid, expire);

									            system.out.println("lock==" + result);

									        } catch (exception e) {

									            e.printstacktrace();

									        }

									        return result;

									    }

									    @requestmapping(value = "/unlock/{key}/{uid}")

									    public long unlock(@pathvariable("key") string key, @pathvariable("uid") string uid) {

									        long result = null;

									        try {

									            //调用lua脚本并执行

									            defaultredisscript<long> redisscript = new defaultredisscript<>();

									            redisscript.setresulttype(long.class);//返回类型是long

									            //lua文件存放在resources目录下的redis文件夹内

									            redisscript.setscriptsource(new resourcescriptsource(new classpathresource("redis/redis_unlock.lua")));

									            result = redistemplate.execute(redisscript, arrays.aslist(key), uid);

									            system.out.println("unlock==" + result);

									        } catch (exception e) {

									            e.printstacktrace();

									        }

									        return result;

									    }

									}

3.3、redis_lock.lua

				?

									if redis.call('setnx',keys[1],argv[1]) == 1 then

									    return redis.call('expire',keys[1],argv[2])

									else

									    return 0

									end

3.4、redis_unlock.lua

				?

									if redis.call("exists",keys[1]) == 0 then

									    return 1

									end

									if redis.call('get',keys[1]) == argv[1] then

									    return redis.call('del',keys[1])

									else

									    return 0

									end