聊聊使用RedisTemplat实现简单的分布式锁的问题

不使用redisson框架实现redis分布式锁

准备工作：

导入依赖

<dependency>
     <groupid>org.springframework.boot</groupid>
     <artifactid>spring-boot-starter-data-redis</artifactid>
</dependency>

编写redisconfig类

@configuration
public class redisconfig {
    @bean
    public redistemplate<string , object> redistemplate(redisconnectionfactory redisconnectionfactory){
        redistemplate<string, object> redistemplate = new redistemplate<>();
        //string类型 key序列器
        redistemplate.setkeyserializer(new stringredisserializer());
        //string类型 value序列器
        redistemplate.setvalueserializer(new genericjackson2jsonredisserializer());
        //hash类型 key序列器
        redistemplate.sethashkeyserializer(new stringredisserializer());
        //hash类型 value序列器
        redistemplate.sethashvalueserializer(new genericjackson2jsonredisserializer());
        //将连接工厂注入
        redistemplate.setconnectionfactory(redisconnectionfactory);
        return redistemplate;
    }
 }

1.在springboottest中编写测试模块

1.1:使用占位符加锁：

占位符加锁问题：出现异常时无法释放锁，导致后继进入的线程成为死锁

@springboottest
class applicationtests {
    @autowired
    private redistemplate redistemplate;
	@test
	public void lodstest01(){
		valueoperations valueoperations = redistemplate.opsforvalue();
	        //创建一个占位符，如果key不存在才可以设置成功
	        boolean islock = valueoperations.setifabsent("k1", "v1");
	        //如果占位成功，进行正常操作
	        if (islock){
	        	//设置一个name存到redis
	            valueoperations.set("name","xxxx");
	            //从redis取出name
	            string name = (string) valueoperations.get("name");
	            system.out.println("name = " + name);
	            //手动制造异常
	            integer.parseint("xxxx");
	            //操作结束删除锁
	            redistemplate.delete("k1");
	        }else{
	            system.out.println("有线程在用，请稍后在试");
	        }
	}
}

测试
第一个线程出现异常无法释放锁：

之后所有线程都无法访问：

解决方案：为锁加一个有效时间。

1.2:使用占位符设置有效时间解决死锁问题：

占位符设置有效时间问题：即使某线程出现异常，但占位符过了有效时间，锁就会释放。但是在大量线程同时访问时，如果线程1被外界因素影响（网络波动，服务器出问题等等）,线程1的业务还没完成，但锁的有效时间到了的话，下一个线程就会进来，就会出现线程不安全的情况，出现线程互相删锁的情况。

	@test
    public void testlock02()  {
        valueoperations valueoperations = redistemplate.opsforvalue();
        //如果key不存在才可以设置成功,设置一个有效时间防止线程异常出现死锁
        boolean islock = valueoperations.setifabsent("k1", "v1",5, timeunit.seconds);
        //如果占位成功，进行正常操作
        if (islock){
        	//设置一个name存到redis
            valueoperations.set("name","xxxx");
            //从redis取出name
            string str = (string) valueoperations.get("name");
            system.out.println("name = " + str);
            //制造异常
            integer.parseint("xxxx");
            //操作结束删除锁
            redistemplate.delete("k1");
        }else{
            system.out.println("有线程在用，请稍后在试");
        }
    }

解决方案: 使用lua脚本，给每个锁的key对应的value设置一个随机数

1.3:使用lua脚本解决线程不安全问题：

lua脚本可以写在redis服务器上:
优点: 在服务器上运行速度快

缺点: 修改代码时比较麻烦

lua脚本可以通过java发送
优点: 修改代码方便

缺点: 每次发送请求时都需要占用网络资源

1.3.1:编写lua脚本

if redis.call("get",keys[1])==argv[1] then    return redis.call("del",keys[1])else    return 0end

1.3.2:修改reidsconfig类

	@bean
    public defaultredisscript<boolean> defaultredisscript(){
        defaultredisscript<boolean> redisscript = new defaultredisscript<>();
        //lock.lua脚本位置和application.yml同级目录
        redisscript.setlocation(new classpathresource("lock.lua"));
        //设置类型为boolean
        redisscript.setresulttype(boolean.class);
        return redisscript;
    }

1.3.3:编写测试模块

@test
    public void testlock03(){
        valueoperations valueoperations = redistemplate.opsforvalue();
        string value = uuid.randomuuid().tostring();
        //如果key不存在才可以设置成功,设置一个value为随机数的值，防止出现线程太多 导致线程不安全
        boolean islock = valueoperations.setifabsent("k1", value, 5, timeunit.seconds);
        //如果占位成功，进行正常操作 
        if (islock){
        	//设置一个name存到redis
            valueoperations.set("name","xxxx");
            //从redis取出name
            string name = (string) valueoperations.get("name");
            system.out.println("name = " + name);
            //为redis发送lua脚本删除锁对应的value
            boolean aboolean = (boolean) redistemplate.execute(redisscript, collections.singletonlist("k1"), value);
            system.out.println(aboolean);
        }else{
            system.out.println("有线程在用，请稍后在试");
        }
    }

测试结果:
顺利把name值存到redis中并把锁删除并返回true

锁会被正常删除只留下name:

到此这篇关于使用redistemplat实现简单的分布式锁的文章就介绍到这了,更多相关redistemplat分布式锁内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com！