0719~分布式锁

概念:在分布式环境下,保证某个资源在同一时间访问时,只有一个线程能访问到资源;

分布式锁的实现方式:

1.基于数据库实现:

innodb行锁;

排他锁:一次只允许一个线程访问,只有等一个线程执行完后才会有下个线程进入;

乐观锁:

版本号控制;在数据库中加一个Version字段;

基于数据库主键实现分布式锁;

基于数据库索引实现分布式锁;

乐观锁的缺点:常见的ABA问题;

2.基于Redis实现:

出现的问题:

原子性问题:设置超时时间


if（jedis.setnx（lock_stock，1） == 1）{	//获取锁
    expire（lock_stock，5000）		 //设置锁超时
    try {
        业务代码需要10秒执行完毕
    } finally {
        jedis.del（lock_stock）			 //释放锁
    }
}

死锁问题:(没有释放锁/没有删除锁);删除锁判断一下是不是自己的锁;把value设置uuid


//A-uuid:1    redis:123-1
//B-uuid:2    redis:123-2
String uuid = UUID.randomUUID().toString();
if（jedis.set('123', uuid,"NX","EX",5) == 1）{	//获取锁并设置超时
    try {
        //业务代码
    } finally {
        String lockValue = jedis.get("123");	//获取锁的值
        if(lockValue.equals(uuid)){			//判断是不是自己的锁
            jedis.del（"123"）			 	  //释放锁
        }
    }
}

释放锁的原子性问题:lua脚本保证原子性;


String uuid = UUID.randomUUID().toString();
if（jedis.set('123',uuid,"NX","EX",5) == 1）{	//获取锁并设置超时
    try {
        业务代码
    } finally {
        //lua脚本
        String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
        
        if 
        	redis.call('get', '123') == '1111111' 
        then 
            return redis.call('del', '123') 
        else 
            return 0 end
            
            
        //执行脚本
        jedis.eval(script, Collections.singletonList("123"),Collections.singletonList(uuid));
    }
}