使用Redis实现分布式锁的原理
2017-12-22 10:16
696 查看
使用场景:
在tomcat集群环境下,有任务调度,也就是定时任务
同一时间多个tomcat执行同一个任务,如定时关单.
如果有大量订单需要关闭,则每个tomcat都会执行相同数量的关单sql,
这样是非常浪费资源的,如果还有相应的记录的话 则会导致重复记录的出现.
这个时候redis分布式锁就派上用场了,通过这个锁,可以随机的让单个tomcat去执行关单操作,而其余的tomcat则不会执行关单操作.
原理:
主要是使用这几个redis命令来实现:
1.setnx : 不能设置重复key
2.getset : 获取旧的值,设置新的值
3.expire : 设置key的有效期
4.del : 删除key
首先使用setnx命令保存一个key,value
如果设置成功,也就是返回1,给这个key设置有效期
接着执行业务,如调用关单的sql
最后删除key,也就是释放锁
如果设置失败,也就是返回0,代表当前有tomcat正在使用锁,还没有释放
那就获取当前锁
如果
代表这个key已经超时了,
这个时候获取到这个锁的tomcat有权重新设置超时时间,也就是重新设置value
执行完后 返回valueB,如果
那么便是成功的获取到锁,执行获取到锁的流程
否则便结束这次定时任务
在tomcat集群环境下,有任务调度,也就是定时任务
同一时间多个tomcat执行同一个任务,如定时关单.
如果有大量订单需要关闭,则每个tomcat都会执行相同数量的关单sql,
这样是非常浪费资源的,如果还有相应的记录的话 则会导致重复记录的出现.
这个时候redis分布式锁就派上用场了,通过这个锁,可以随机的让单个tomcat去执行关单操作,而其余的tomcat则不会执行关单操作.
原理:
主要是使用这几个redis命令来实现:
1.setnx : 不能设置重复key
2.getset : 获取旧的值,设置新的值
3.expire : 设置key的有效期
4.del : 删除key
首先使用setnx命令保存一个key,value
setnx(lockkey,currentTime+timeout)
lockkey : 就是key的名称 currentTime : 时间戳(System.currentTimeMillis()) timeout : 这个锁被动释放的时间,定义在配置文件中,方便修改
如果设置成功,也就是返回1,给这个key设置有效期
expire(lockkey,timeout)
接着执行业务,如调用关单的sql
最后删除key,也就是释放锁
del(lockkey)
如果设置失败,也就是返回0,代表当前有tomcat正在使用锁,还没有释放
那就获取当前锁
get(lockkey) 得到valueA
如果
valueA!=null && currentTime (当前时间毫秒数)>valueA
代表这个key已经超时了,
这个时候获取到这个锁的tomcat有权重新设置超时时间,也就是重新设置value
getset(lockkey,currentTime+timeout) 得到valueB
执行完后 返回valueB,如果
valueB ==null || valueA(之前get得到的值) == valueB
那么便是成功的获取到锁,执行获取到锁的流程
否则便结束这次定时任务
相关文章推荐
- (转)分布式中使用Redis实现Session共享(二)
- 使用scrapy,redis, mongodb实现的一个分布式网络爬虫
- 分布式中使用 Redis 实现 Session 共享(中)
- 分布式中使用Redis实现Session共享(一)
- 使用 Redis 实现分布式系统轻量级协调技术
- redis中使用java脚本实现分布式锁
- 使用 Redis 实现分布式锁
- 基于Redis实现分布式锁,Redisson使用及源码分析
- 分布式缓存技术redis学习系列(五)——spring-data-redis与JedisPool的区别、使用ShardedJedisPool与spring集成的实现及一致性哈希分析
- 使用 Redis 实现分布式锁
- 使用redis实现分布式锁
- 使用redis实现分布式锁,可以解决集群中需要单例的情况
- 基于Redis实现分布式锁,Redisson使用及源码分析
- API接口非幂等性问题及使用redis实现简单的分布式锁
- 深入理解Spring Redis的使用 (九)、通过Redis 实现 分布式锁 的 BUG,以及和数据库加锁的性能测试
- 使用 Redis 实现分布式系统轻量级协调技术
- (转)分布式中使用Redis实现Session共享(一)
- 分布式中使用Redis实现Session共享
- 使用 Redis 实现分布式系统轻量级协调技术
- 分布式中使用 Redis 实现 Session 共享(下)