初始Redis分布式锁

在分布式应用中经常出现并发的问题,比如对用户的状态做一个修改 ,那么就涉及到先取出数据再进行修改,但是这样常常会引发问题,因为读和写是两个操作,不是原子性(不可分割的)的操作。当同时进行该操作时往往会引发并发问题。

这时就要用到分布式锁。

在Reids中的分布式锁实际上就相当于一个占坑,当坑上有人的时候别人必须再外面等待,同时只允许一个人占坑。而在Redis中提供了一个setnx的指令来对key进行加锁:

setnx mylock true

...do something... //做一些业务逻辑

del mylock //释放锁

好像这样就完事大吉了。不,这有问题。如果我在做一些业务逻辑的时候出了问题执行不到del指令释放锁的时候岂不是进入了死循环,锁得不到释放,别人得不到锁。

这就尴尬了,但是我们不是有一个设置过期时间的指令吗?对啊 就是expire指令:

setnx mylock true

expire mylock 5 //设置过期时间为5s

...do something... //做一些业务逻辑

del mylock //释放锁

这样不就解决了吗?别高兴的太早了,万一我在setnx和expire之间出了问题呢,那还是一样的啊,问题依旧,依然出现了死锁。那我们可不可以用事务来解决呢?答案是不行的,因为事务是要不都执行要不都不执行,而我们需要的是if/else的操作,expire指令是依赖于setnx指令的结果的,如果setnx没有抢到锁,那么expire是不用执行的。

现在我们来分析一下为什么会出现这样的问题,其实就是因为setnx和expire是两个操作不是原子性的,所以这样是会出现问题的。那么我们可不可以把这两个指令合并一下呢?答案是可以的。Redis为我们提供了set指令:

set mylock true expire 5 nx //setnx和expire的结合

...do something... //做一些业务逻辑

del mylock //释放锁

这个set指令就是分布式锁的奥义所在。

但是上面的操作还是存在问题的,因为设置了过期时间。万一我的业务逻辑执行时长超过过期时间的化,那么我就释放掉了锁,我都没执行完呢就没了,难受啊。这就是超时问题。所以分布式锁还是不要用来去执行时间比较长的任务。

原文地址:https://www.cnblogs.com/lgxblog/p/11102072.html

时间: 2024-10-17 04:38:22

初始Redis分布式锁的相关文章

Redis专题(3):锁的基本概念到Redis分布式锁实现

拓展阅读:Redis闲谈(1):构建知识图谱 Redis专题(2):Redis数据结构底层探秘 近来,分布式的问题被广泛提及,比如分布式事务.分布式框架.ZooKeeper.SpringCloud等等.本文先回顾锁的概念,再介绍分布式锁,以及如何用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