redis分布式锁深入

  分布式架构中,高并发场景下,简单的线程锁无法保证线程安全,我们需要使用分布式锁来保证线程安全。在诸多的分布式锁实现中,redis分布式锁的应用应该是最为常见的,下面就让我们来看一下分布式锁实现中需要考虑到的诸多方面:

  首先使用redis实现分布式锁需要用到redis的setnx key命令,(如果key不存在才允许设置)

  下面我们来看一下redis分布式锁需要考虑的问题:

    1、设置锁之后,解锁失败,即使使用try finally也是无法解决无法解锁的问题,因为分布式锁的设置时多个后端系统在争抢,如果有一个系统出现一些原因需要被kill掉,但是此时正是这个系统持有锁,这时try finally也不会被走到,一次会造成死锁。

    2、针对1中的死锁问题,我们可以给锁设置一个过期时间,再设置过期时间时使用setnx显然是不合适的,因为setnx和设置expire过期时间显然不是原子性操作,因此就会出现设置了锁但是设置过期时间失败,因此我们需要使用较新版本的redis提供的set命令

set key value [EX seconds] [PX milliseconds] [NX|XX],这时就能保证设置锁和过期时间的原子性操作

    3、解决了1,2问题,看似redis分布式锁已经很完善了,先不要着急,我们设想一下一个加锁的业务需要10秒完成业务,但是我们设置的锁的过期时间只有5秒(这里时间只是一个假设,因为无论设置多长时间的锁都有可能因为各种原因造成枷锁业务耗时比锁过期时间长的问题),此时当业务执行到5秒时还未结束,但是锁已经被释放,另外得到锁的线程需要8秒执行完毕,很显然此时第一个持有锁的线程在5秒之后结束主动释放锁,现在第三个线程又可以持有锁去执行,如此循环往复,造成锁的持久失效,想要解决这个问题,我们可以针对key的值进行考虑,让每次加锁的值具有唯一性(如使用uuid),这样在释放锁的时候,就可以判断是否uuid相同,如果相同就主动释放锁,如果不同就表示当前线程所持有的锁已经过期,因此当前线程不需要在进一步加锁。

    4、在解决了上述1,2,3问题后,看似redis分布式锁已经相当完美,但是仔细想想加锁时间还是一个无法逃避的问题,如果锁过期时间过长,一旦有一个线程在执行过程中被kill掉未能释放锁,那么其他线程就会等待很长时间,这样可能会造成一些问题,如果加锁时间过短,虽然经过第3步之后不会永久锁失效,但是很显然两个线程会造成线程不安全,此时可以考虑使用重开一个daemon线程不断地watch这个锁(随主线程结束而结束),每次watch到这个锁,就会增加这个锁的生存时间。

    5、除了1,2,3,4,之外,我们还需要考虑到redis的部署方式,如果是redis单机部署,很显然上面的redis分布式锁近乎完美,但是现在的互联网公司追求的是高可用,稍微不错的公司都不会使用redis单机部署,很显然redis高可用集群架构(主从、哨兵、cluster),如果当一把锁上在master上,但是这把锁还未来的及同步到slave上时,master挂了,现在问题就来了,此时就会同样造成其他线程同样可以持有锁,造成线程不安全(即便这种不安全只会在master挂掉时出现一次),但是这也是我们需要考虑的问题。

原文地址:https://www.cnblogs.com/limaomao/p/11220704.html

时间: 2024-10-23 06:15:22

redis分布式锁深入的相关文章

Redis分布式锁实现

直接上代码: 1 package cn.wywk.yac.comm.redis; 2 3 import org.slf4j.Logger; 4 import org.slf4j.LoggerFactory; 5 6 import redis.clients.jedis.Jedis; 7 8 /** 9 * ClassName: redis分布式锁实现 <br/> 10 * date: 2017年2月17日 上午10:23:24 <br/> 11 * 12 * @author 134

redis分布式锁和消息队列

最近博主在看redis的时候发现了两种redis使用方式,与之前redis作为缓存不同,利用的是redis可设置key的有效时间和redis的BRPOP命令. 分布式锁 由于目前一些编程语言,如PHP等,不能在内存中使用锁,或者如Java这样的,需要一下更为简单的锁校验的时候,redis分布式锁的使用就足够满足了.redis的分布式锁其实就是基于setnx方法和redis对key可设置有效时间的功能来实现的.基本用法比较简单. public boolean tryLock(String lock

RedLock.Net - 基于Redis分布式锁的开源实现

工作中,经常会遇到分布式环境中资源访问冲突问题,比如商城的库存数量处理,或者某个事件的原子性操作,都需要确保某个时间段内只有一个线程在访问或处理资源. 因此现在网上也有很多的分布式锁的解决方案,有数据库.MemCache.ZoopKeeper等等的方式. 这次,我们要学习的是一个基于Redis分布式锁的插件,RedLock.Net. 首先必须要有一个Redis服务来支持此分布式锁,其次就当然是要获取此插件了. 可以从Nuget中获取,也可以直接去Github下载   https://github

redis分布式锁小试

一.场景 项目A监听mq中的其他项目的部署消息(包括push_seq, status, environment,timestamp等),然后将部署消息同步到数据库中(项目X在对应环境[environment]上部署的push_seq[项目X的版本]).那么问题来了,mq中加入包含了两个部署消息 dm1 和 dm2,dm2的push_seq > dm1的push_seq,在分布式的情况下,dm1 和 dm2可能会分别被消费(也就是并行),那么在同步数据库的时候可能会发生 dm1 的数据保存 后于

Memcached 和 Redis 分布式锁方案

分布式缓存,能解决单台服务器内存不能无限扩张的瓶颈.在分布式缓存的应用中,会遇到多个客户端同时争用的问题.这个时候,需要用到分布式锁,得到锁的客户端才有操作权限. Memcached 和 Redis 是常用的分布式缓存构建方案,下面列举下基于Memcached 和 Redis 分布式锁的实现方法. Memcached 分布式锁 Memcached 可以使用 add 命令,该命令只有KEY不存在时,才进行添加,或者不会处理.Memcached 所有命令都是原子性的,并发下add 同一个KEY ,只

spring boot redis分布式锁

随着现在分布式架构越来越盛行,在很多场景下需要使用到分布式锁.分布式锁的实现有很多种,比如基于数据库. zookeeper 等,本文主要介绍使用 Redis 做分布式锁的方式,并封装成spring boot starter,方便使用 一. Redis 分布式锁的实现以及存在的问题 锁是针对某个资源,保证其访问的互斥性,在实际使用当中,这个资源一般是一个字符串.使用 Redis 实现锁,主要是将资源放到 Redis 当中,利用其原子性,当其他线程访问时,如果 Redis 中已经存在这个资源,就不允

Redis分布式锁解决抢购问题

首先分享一个业务场景-抢购.一个典型的高并发问题,所需的最关键字段就是库存,在高并发的情况下每次都去数据库查询显然是不合适的,因此把库存信息存入Redis中,利用redis的锁机制来控制并发访问,是一个不错的解决方案. 首先是一段业务代码: @Transactional public void orderProductMockDiffUser(String productId){ //1.查库存 int stockNum = stock.get(productId); if(stocknum =

Redis分布式锁的try-with-resources实现

Redis分布式锁的try-with-resources实现 一.简介 在当今这个时代,单体应用(standalone)已经很少了,java提供的synchronized已经不能满足需求,大家自然 而然的想到了分布式锁.谈到分布式锁,比较流行的方法有3中: 基于数据库实现的 基于redis实现的 基于zookeeper实现的 今天我们重点说一下基于redis的分布式锁,redis分布式锁的实现我们可以参照redis的官方文档. 实现Redis分布式锁的最简单的方法就是在Redis中创建一个key

Redis分布式锁

转自:https://www.cnblogs.com/linjiqin/p/8003838.html 前言 分布式锁一般有三种实现方式:1. 数据库乐观锁:2. 基于Redis的分布式锁:3. 基于ZooKeeper的分布式锁.本篇博客将介绍第二种方式,基于Redis实现分布式锁.虽然网上已经有各种介绍Redis分布式锁实现的博客,然而他们的实现却有着各种各样的问题,为了避免误人子弟,本篇博客将详细介绍如何正确地实现Redis分布式锁. 可靠性 首先,为了确保分布式锁可用,我们至少要确保锁的实现

Redis分布式锁的正确实现方式

前言 分布式锁一般有三种实现方式:1. 数据库乐观锁:2. 基于Redis的分布式锁:3. 基于ZooKeeper的分布式锁.本篇博客将介绍第二种方式,基于Redis实现分布式锁.虽然网上已经有各种介绍Redis分布式锁实现的博客,然而他们的实现却有着各种各样的问题,为了避免误人子弟,本篇博客将详细介绍如何正确地实现Redis分布式锁. 可靠性 首先,为了确保分布式锁可用,我们至少要确保锁的实现同时满足以下四个条件: 互斥性.在任意时刻,只有一个客户端能持有锁. 不会发生死锁.即使有一个客户端在