浅谈Java分布式架构下如何实现分布式锁
01分布式锁运用场景
互联网秒杀,抢优惠卷,接口幂等性校验。咱们以互联网秒杀为例。
@RestController @Slf4j publicclassIndexController{ @Autowired privateRedissonredission; @Autowired privateStringRedisTemplatestringRedisTemplate; @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分布式架构 分布式锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
Spring中@RestControllerAdvice注解的使用详解
这篇文章主要介绍了Spring中@RestControllerAdvice注解的使用详解,@RestControllerAdvice是一个组合注解,由@ControllerAdvice、@ResponseBody组成,而@ControllerAdvice继承了@Component,需要的朋友可以参考下2024-01-01SpringBoot框架集成ElasticSearch实现过程示例详解
这篇文章主要为大家介绍了SpringBoot如何集成ElasticSearch的实现过程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步2021-11-11SpringBoot+Mybatis实现Mapper接口与Sql绑定几种姿势
通常我们在使用Mybatis进行开发时,会选择xml文件来写对应的sql,然后将Mapper接口与sql的xml文件建立绑定关系,然后在项目中调用mapper接口就可以执行对应的sql,感兴趣的可以学习一下2021-09-09详解Java中log4j.properties配置与加载应用
这篇文章主要介绍了 log4j.properties配置与加载应用的相关资料,需要的朋友可以参考下2018-02-02详解Maven项目Dependencies常见报错及解决方案
这篇文章主要介绍了详解Maven项目Dependencies常见报错及解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2020-11-11
最新评论