redis实现分布式锁

1.主要命令：

setnx
setex

2.主要问题：

使用redis实现分布式锁，利用上面两个命令的特性。但是最重要的是锁要有过期时间，不然万一服务器宕机或者redis宕机，redis锁将永远得不到释放，出现死锁，其他线程一直获取不到资源。为了避免这种情况发生就必须保证这两个命令setnx与setex(设置过期时间)执行的原子性。

还有一个问题就是如果设置了过期时间，但是线程a在过期时间内没有执行完，这时可能会出现：
B执行到一半，serverA才执行完，这是serverA会释放serverB得锁，会导致无锁。
解决方法保证释放删除得锁与当前锁住得锁是同一个资源，即key，value完全一样，可通过lua脚本，getValue和delKey是一个原子性操作。

3.解决办法：

1.lua脚本实现setnx,setex两个命令的原子性：

读取lua脚本

/*** 获取lua结果* @param key* @param value* @return*/public Boolean luaExpress(String key,String value) {lockScript = new DefaultRedisScript<Boolean>();lockScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("add.lua")));lockScript.setResultType(Boolean.class);// 封装参数List<Object> keyList = new ArrayList<Object>();keyList.add(key);keyList.add(value);Boolean result = (Boolean) redisTemplate.execute(lockScript, keyList);Long expire = redisTemplate.getExpire(key);System.out.println("超时时间："+expire);return result;}

lua脚本：

local lockKey = KEYS[1]
local lockValue = KEYS[2]-- setnx info
local result_1 = redis.call('SETNX', lockKey, lockValue)
if result_1 == 1
then
local result_2= redis.call('SETEX', lockKey,3600, lockValue)
return result_1
else
return result_1
end

2. lua脚本保证释放的是当前锁：

/*** 释放锁操作* @param key* @param value* @return*/private boolean releaseLock(String key, String value) {lockScript = new DefaultRedisScript<Boolean>();lockScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("unlock.lua")));lockScript.setResultType(Boolean.class);// 封装参数List<Object> keyList = new ArrayList<Object>();keyList.add(key);keyList.add(value);Boolean result = (Boolean) redisTemplate.execute(lockScript, keyList);return result;}

unlock.lua

local lockKey = KEYS[1]
local lockValue = KEYS[2]-- get key
local result_1 = redis.call('get', lockKey)
if result_1 == lockValue
then
local result_2= redis.call('del', lockKey)
return result_2
else
return false
end

3. 采用RedisConnection获取JRedisCommand得java客户端:

https://docs.spring.io/spring-data/redis/docs/2.0.3.RELEASE/api/
搜索redisconnection
点击RedisStringCommands
搜索set方法，即可查找到

 public boolean setLock(String key, long expire) {try {Boolean result = redisTemplate.execute(new RedisCallback<Boolean>() {@Overridepublic Boolean doInRedis(RedisConnection connection) throws DataAccessException {return connection.set(key.getBytes(), getHostIp().getBytes(), Expiration.seconds(expire) ,RedisStringCommands.SetOption.ifAbsent());}});return result;} catch (Exception e) {logger.error("set redis occured an exception", e);}return false;}public String get(String key) {try {RedisCallback<String> callback = (connection) -> {JedisCommands commands = (JedisCommands) connection.getNativeConnection();return commands.get(key);};String result = redisTemplate.execute(callback);return result;} catch (Exception e) {logger.error("get redis occured an exception", e);}return "";}

redis实现setnx,setex连用实现分布式锁相关推荐

【Redis Lua 脚本可重入分布式锁】
文章目录前言一.最简单的版本:setnx key value 获取锁成功获取锁失败释放锁缺点二.升级版本:set key value [ex seconds] [nx] 获取锁成功获取锁 ...
redis mysql 解决超卖_Redis 分布式锁解决超卖问题
Redis 分布式锁解决超卖问题 1,Redis 事物介绍 1. Redis 事物是可以一次执行多个命令, 本质是一组命令的集合. 2. 一个事务中的所有命令都会序列化, 按顺序串行化的执行而不会被其 ...
视频教程- 19年录制Redis实战教程高可用秒杀分布式锁布隆过滤器实战 SpringBoot教程整合-Java
19年录制Redis实战教程高可用秒杀分布式锁布隆过滤器实战 SpringBoot教程整合 7年的开发架构经验,曾就职于国内一线互联网公司,开发工程师,现在是某创业公司技术负责人, 擅长语言有nod ...
redis 的惊群处理和分布式锁的应用例子
在并发量比较高的情况下redis有很多应用场景,提升查询效率,缓解底层DBio ,下面列举两个平时开发中应用过的两个例子,欢迎各位一起讨论改进. 1 . redis 惊群处理 1.1 方案的由来 Re ...
什么是分布式锁？redis、zookeeper、etcd实现分布式锁有什么不同之处？
目录分布式锁定义目的基于redis分布式锁基于zookeeper实现的分布式锁 edis.zookeeper.etcd实现分布式锁的比较建议选择etcd实现分布式锁分布式锁定义分布式环境 ...
多机器使用setnx 设置同一个key_Redisson分布式锁的简单使用
做一个积极的人编码.改bug.提升自己我有一个乐园,面向编程,春暖花开! 一:前言我在实际环境中遇到了这样一种问题,分布式生成id的问题!因为业务逻辑的问题,我有个生成id的方法,是根据业务标识 ...
Redis 作者 Antirez 讲如何实现分布式锁？Redis 实现分布式锁天然的缺陷分析Redis分布式锁的正确使用姿势！...
Redis分布式锁基本原理采用 redis 实现分布式锁,主要是利用其单线程命令执行的特性,一般是 setnx, 只会有一个线程会执行成功,也就是只有一个线程能成功获取锁:看着很完美. 然而-- 看 ...
面试干货10——聊一聊Redis的应用吧！(实现分布式锁、缓存、抽奖、热搜、点赞、商品筛选..)
Redis这样用一.String类型 1. 对String类型的理解 2. 常用命令如下 3. 应用场景 ① 分布式锁 ② 缓存设计 ③ 全局唯一序列号.计数器(value为Numbers类型) ④ ...
Redis高阶使用之Redisson分布式锁源码解析
一.何为分布式锁 1.锁synchronized lock 单机锁 2.我们的一些互斥资源不能并行执行需要一个东西来保证是串行执行的锁synchronized 3.分布式锁:这个锁存储一定是独立 ...

redis实现setnx,setex连用实现分布式锁