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

所属分类: 软件编程 / java 阅读数: 73
收藏 0 赞 0 分享

  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。这样轻轻松松解决了。
  商场上面现已有许多许多成熟的结构,咱们能够不需要去手写分布式结构来完成。

更多精彩内容其他人还在看

SpringBoot中使用Ehcache的详细教程

EhCache 是一个纯 Java 的进程内缓存框架,具有快速、精干等特点,是 Hibernate 中默认的 CacheProvider。这篇文章主要介绍了SpringBoot中使用Ehcache的相关知识,需要的朋友可以参考下
收藏 0 赞 0 分享

在idea 中添加和删除模块Module操作

这篇文章主要介绍了在idea 中添加和删除模块Module操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
收藏 0 赞 0 分享

java spring整合junit操作(有详细的分析过程)

这篇文章主要介绍了java spring整合junit操作(有详细的分析过程),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
收藏 0 赞 0 分享

详解JAVA 弱引用

这篇文章主要介绍了 JAVA 弱引用的相关资料,帮助大家更好的理解和学习java引用对象,感兴趣的朋友可以了解下
收藏 0 赞 0 分享

深入了解JAVA 虚引用

这篇文章主要介绍了JAVA 虚引用的相关资料,帮助大家更好的理解和学习JAVA,感兴趣的朋友可以了解下
收藏 0 赞 0 分享

详解JAVA 强引用

这篇文章主要介绍了JAVA 强引用的相关资料,帮助大家更好的理解和学习,感兴趣的朋友可以了解下
收藏 0 赞 0 分享

java中的按位与(&)用法说明

这篇文章主要介绍了java中的按位与(&)用法说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
收藏 0 赞 0 分享

深入了解JAVA 软引用

这篇文章主要介绍了JAVA 软引用的相关资料,帮助大家更好的理解和学习,感兴趣的朋友可以了解下
收藏 0 赞 0 分享

利用MyBatis实现条件查询的方法汇总

这篇文章主要给大家介绍了关于利用MyBatis实现条件查询的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者使用MyBatis具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
收藏 0 赞 0 分享

Intellij IDEA 与maven 版本不符 Unable to import maven project See logs for details: No implementation for org.apache.maven.model.path.PathTranslator was bound

这篇文章主要介绍了Intellij IDEA 与maven 版本不符 Unable to import maven project See logs for details: No implementation for org.apache.maven.model.path.Pa
收藏 0 赞 0 分享
查看更多