浅谈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分布式架构  分布式锁内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • 详解Java分布式Session共享解决方案

    分布式Session一致性? 说白了就是服务器集群Session共享的问题 Session的作用? Session 是客户端与服务器通讯会话跟踪技术,服务器与客户端保持整个通讯的会话基本信息. 客户端在第一次访问服务端的时候,服务端会响应一个sessionId并且将它存入到本地cookie中,在之后的访问会将cookie中的sessionId放入到请求头中去访问服务器,如果通过这个sessionid没有找到对应的数据那么服务器会创建一个新的sessionid并且响应给客户端. 分布式Sessio

  • 通过实例解析Java分布式锁三种实现方法

    通过实例解析Java分布式锁三种实现方法

    分布式锁三种实现方式: 一, 基于数据库实现分布式锁 1. 悲观锁 利用select - where - for update 排他锁 注意: 其他附加功能与实现一基本一致,这里需要注意的是"where name=lock ",name字段必须要走索引,否则会锁表.有些情况下,比如表不大,mysql优化器会不走这个索引,导致锁表问题. 2. 乐观锁 所谓乐观锁与前边最大区别在于基于CAS思想,是不具有互斥性,不会产生锁等待而消耗资源,操作过程中认为不存在并发冲突,只有update ve

  • java实现分布式项目搭建的方法

    1 分布式 1.1 什么是分布式 分布式系统一定是由多个节点组成的系统.其中,节点指的是计算机服务器,而且这些节点一般不是孤立的,而是互通的. 这些连通的节点上部署了我们的节点,并且相互的操作会有协同.分布式系统对于用户而言,他们面对的就是一个服务器,提供用户需要的服务而已,而实际上这些服务是通过背后的众多服务器组成的一个分布式系统,因此分布式系统看起来像是一个超级计算机一样. 1.2 分布式与集群的区别 集群是同一个系统部在不同的服务器上,例如一个登陆系统部在不同的服务器上. 分布式是不同的系

  • 详解Java分布式IP限流和防止恶意IP攻击方案

    前言 限流是分布式系统设计中经常提到的概念,在某些要求不严格的场景下,使用Guava RateLimiter就可以满足.但是Guava RateLimiter只能应用于单进程,多进程间协同控制便无能为力.本文介绍一种简单的处理方式,用于分布式环境下接口调用频次管控. 如何防止恶意IP攻击某些暴露的接口呢(比如某些场景下短信验证码服务)?本文介绍一种本地缓存和分布式缓存集成方式判断远程IP是否为恶意调用接口的IP. 分布式IP限流 思路是使用redis incr命令,完成一段时间内接口请求次数的统

  • Java注解如何基于Redission实现分布式锁

    这篇文章主要介绍了Java注解如何基于Redission实现分布式锁,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 1.定义注解类 @Target({ ElementType.METHOD }) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface DistributedLock { //锁名称 String lockName() default ""; /

  • Java基于redis实现分布式锁代码实例

    为什么会有这个需求: 例如一个简单用户的操作,一个线程去修改用户状态,首先在在内存中读出用户的状态,然后在内存中进行修改,然后在存到数据库中.在单线程中,这是没有问题的.但是在多线程中由于读取,修改,写入是三个操作,不是原子操作(同时成功或失败),因此在多线程中会存在数据的安全性问题. 这个问题的话,就可以用分布式锁在限制程序的并发执行. 实现思路: 就是进来一个先占位,当别的线程进来操作的时候,发现有人占位了,就会放弃或者稍后再试. 占位的实现: 在redis中的setnx命令来实现,redi

  • Java多线程及分布式爬虫架构原理解析

    Java多线程及分布式爬虫架构原理解析

    这是 Java 爬虫系列博文的第五篇,在上一篇Java 爬虫服务器被屏蔽的解决方案中,我们简单的聊反爬虫策略和反反爬虫方法,主要针对的是 IP 被封及其对应办法.前面几篇文章我们把爬虫相关的基本知识都讲的差不多啦.这一篇我们来聊一聊爬虫架构相关的内容. 前面几章内容我们的爬虫程序都是单线程,在我们调试爬虫程序的时候,单线程爬虫没什么问题,但是当我们在线上环境使用单线程爬虫程序去采集网页时,单线程就暴露出了两个致命的问题: 采集效率特别慢,单线程之间都是串行的,下一个执行动作需要等上一个执行完才能

  • Java redisson实现分布式锁原理详解

    Redisson分布式锁 之前的基于注解的锁有一种锁是基本redis的分布式锁,锁的实现我是基于redisson组件提供的RLock,这篇来看看redisson是如何实现锁的. 不同版本实现锁的机制并不相同 引用的redisson最近发布的版本3.2.3,不同的版本可能实现锁的机制并不相同,早期版本好像是采用简单的setnx,getset等常规命令来配置完成,而后期由于redis支持了脚本Lua变更了实现原理. <dependency> <groupId>org.redisson&

  • Java分布式锁的概念与实现方式详解

    什么是分布式锁?在回答这个问题之前,我们先回答一下什么是锁. 普通的锁,即在单机多线程环境下,当多个线程需要访问同一个变量或代码片段时,被访问的变量或代码片段叫做临界区域,我们需要控制线程一个一个的顺序执行,否则会出现并发问题. 如何控制呢?就是设置一个各个线程都能看的见的标志.然后,每个线程想访问临界区域时,都要先查看标志,如果标志没有被占用,则说明目前没有线程在访问临界区域.如果标志被占用了,则说明目前有线程正在访问临界区域,则当前线程需要等待. 这个标志,就是锁. 在单机多线程的java程

  • Java使用Redisson分布式锁实现原理

    1. 基本用法 <dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.8.2</version> </dependency> Config config = new Config(); config.useClusterServers() .setScanInterval(2000) /

随机推荐