浅谈Java分布式架构下如何实现分布式锁

01分布式锁运用场景

互联网秒杀，抢优惠卷，接口幂等性校验。咱们以互联网秒杀为例。

　@RestController@Slf4jpublicclassIndexController{@AutowiredprivateRedissonredission;@AutowiredprivateStringRedisTemplatestringRedisTemplate;@RequestMapping('/deduct_stock')publicStringdeductStock()throwsInterruptedException{intstock=Integer.parseInt(stringRedisTemplate.opsForValue().get('stock'));if(stock>0){intrealStock=stock-1;stringRedisTemplate.opsForValue().set('stock',realStock+'');log.info('扣减成功，剩下库存+'+realStock);}else{return'库存不足';}return'end';}}

上面代码假定多个线程一起进来，读到胡成果相同，写入的成果也相同。造成多个减库存操作，只减少了一次。

　好多人想到的处理方式是加synchronized，但是假如是集群项目呢？搭建的是负载均衡项目。打开了两个jvm进程，jvm进程锁失效。

用nginx做负载均衡，启用两个服务。进行下压测。成果和咱们想的相同，用suynchronized关键字加锁，两台服务器打印的剩下库存有相同的。所以这种方法并没有完成线程安全。

02根据redisson完成分布式锁

咱们redis中有一个SETNXKEYVALUE,这个指令的时刻复杂度为O(1),只在键key不存在的情况下，将键key的值设置为value，若键key现已存在，则setnx指令不做任何操作，指令在设置成功时返回一，失利时分返回0.

那么咱们能够简单用这个指令，完成一个十分简单的分布式锁。Springboot结构中咱们运用这个：

stringRedisTemplate.opsForValue().setIfAbsent()，它底层是对setnx的封装。

这样完成有什么问题?

假如第一个线程抛了异常中断了，其它线程就永远不能处理了，所以咱们加上trycatch，finally。在finally里面delete咱们存的key值。

假如程序宕机怎么办？不是可捕获异常怎么办？

这时分程序履行到没有释放锁，即key值一向存在，在发动web服务的时分其它线程也一向不等待。这时分会一向存在死锁，咱们是不是参加锁的超时时刻是否能够，即stringRedisTemplate.expire()

程序迭代的过程是逐步的优化，假定我还没来的及给锁设置时长，服务就宕掉了，这时分该怎么办。

用两行指令履行咱们能够换成一行的指令，及设置key值的时分，一起设置时长，stringRedisTemplate.opsForValue().setIfAbsent()。合并成一个原子操作。

这样写的化问题还是有的，假如你设置超时时刻为10秒，而我履行事务代码为小于10秒，还没履行完，就把锁释放掉了。高并发场景下你不能决议履行顺序.

能够不能够自己加的锁，自己删去，别的线程不能进行操作？咱们给每个线程设置一个uuid，唯一id。这样轻轻松松解决了。商场上面现已有许多许多成熟的结构，咱们能够不需要去手写分布式结构来完成。

到此这篇关于浅谈Java分布式架构下如何实现分布式锁的文章就介绍到这了,更多相关Java分布式架构 分布式锁内容请搜索好吧啦网以前的文章或继续浏览下面的相关文章希望大家以后多多支持好吧啦网！