Spring Boot 实现Redis分布式锁原理
更新时间：2022年08月04日 09:37:42 作者：剑圣无痕
这篇文章主要介绍了Spring Boot实现Redis分布式锁原理，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的朋友可以参考一下
分布式锁实现
引入jar包
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
<exclusions>
<exclusion>
<groupId>io.lettuce</groupId>
<artifactId>lettuce-core</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
</dependency>说明：本文采用jedis来实现分布式锁。
封装工具类
@Component
public class RedisLockUtil
{
private static final Logger logger = LoggerFactory.getLogger(RedisLockUtil.class);
private static final Long RELEASE_SUCCESS = 1L;
private static final String LOCK_SUCCESS = "OK";
private static final String RELEASE_LOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
@Resource
private RedisTemplate<String, Object> redisTemplate;
/**
* 加锁方法仅针对单实例 Redis,哨兵、集群模式无法使用
*
* @param lockKey 加锁键
* @param clientId 加锁客户端唯一标识(采用UUID)
* @param seconds 锁过期时间
* @return true标识加锁成功、false代表加锁失败
*/
public Boolean tryLock(String lockKey, String clientId, long seconds)
{
try
{
return redisTemplate
.execute((RedisCallback<Boolean>) redisConnection -> {
Jedis jedis = (Jedis) redisConnection.getNativeConnection();
SetParams params =new SetParams();
params.nx();
params.px(seconds);
String result = jedis.set(lockKey, clientId, params);
if (LOCK_SUCCESS.equals(result))
{
return Boolean.TRUE;
}
return Boolean.FALSE;
});
}
catch (Exception e)
{
logger.error("tryLock error",e);
}
return false;
}
/**
*释放锁，保持原子性操作，采用了lua脚本
*
* @param lockKey
* @param clientId
* @return
*/
public Boolean unLock(String lockKey, String clientId)
{
try
{
return redisTemplate
.execute((RedisCallback<Boolean>) redisConnection -> {
Jedis jedis = (Jedis) redisConnection.getNativeConnection();
Object result = jedis.eval(RELEASE_LOCK_SCRIPT,
Collections.singletonList(lockKey),
Collections.singletonList(clientId));
if (RELEASE_SUCCESS.equals(result))
{
return Boolean.TRUE;
}
return Boolean.FALSE;
});
}
catch (Exception e)
{
logger.error("unlock error",e);
}
return Boolean.FALSE;
}
}说明：加锁的原理是基于Redis的NX、PX命令，而解锁采用的是lua脚本实现。
模拟秒杀扣减库存
public int lockStock()
{
String lockKey="lock:stock";
String clientId = UUID.randomUUID().toString();
long seconds =1000l;
try
{
//加锁
boolean flag=redisLockUtil.tryLock(lockKey, clientId, seconds);
//加锁成功
if(flag)
{
logger.info("加锁成功 clientId：{}",clientId);
int stockNum= Integer.valueOf((String)redisUtil.get("seckill:goods:stock"));
if(stockNum>0)
{
stockNum--;
redisUtil.set("seckill:goods:stock",String.valueOf(stockNum));
logger.info("秒杀成功,剩余库存:{}",stockNum);
}
else
{
logger.error("秒杀失败,剩余库存:{}", stockNum);
}
//获取库存数量
return stockNum;
}
else
{
logger.error("加锁失败：clientId：{}",clientId);
}
}
catch (Exception e)
{
logger.error("decry stock eror",e);
}
finally
{
redisLockUtil.unLock(lockKey, clientId);
}
return 0;
}测试代码
@RequestMapping("/redisLockTest")
public void redisLockTest()
{
// 初始化秒杀库存数量
redisUtil.set("seckill:goods:stock", "10");
List<Future> futureList = new ArrayList<>();
//多线程异步执行
ExecutorService executors = Executors.newScheduledThreadPool(10);
//
for (int i = 0; i < 30; i++)
{
futureList.add(executors.submit(this::lockStock));
try
{
Thread.sleep(100);
}
catch (InterruptedException e)
{
logger.error("redisLockTest error",e);
}
}
// 等待结果，防止主线程退出
futureList.forEach(t -> {
try
{
int stockNum =(int) t.get();
logger.info("库存剩余数量:{}",stockNum);
}
catch (Exception e)
{
logger.error("get stock num error",e);
}
});
}执行结果如下：
方案优化
上述分布式锁实现库存扣减是否存在相关问题呢？
问题1：扣减库存逻辑无法保证原子性，
具体的代码如下：
int stockNum= Integer.valueOf((String)redisUtil.get("seckill:goods:stock"));
if(stockNum>0)
{
stockNum--;
redisUtil.set("seckill:goods:stock",String.valueOf(stockNum));
}这是典型的RMW模型，前面章节已经介绍了具体的实现方案，可以采用lua脚本和Redis的incry原子性命令实现，这里采用lua脚本来实现原子性的库存扣减。
具体实现如下：
public long surplusStock(String key ,int num)
{
StringBuilder lua_surplusStock = new StringBuilder();
lua_surplusStock.append(" local key = KEYS[1];");
lua_surplusStock.append(" local subNum = tonumber(ARGV[1]);");
lua_surplusStock.append(" local surplusStock=tonumber(redis.call('get',key));");
lua_surplusStock.append(" if (surplusStock- subNum>= -1) then");
lua_surplusStock.append(" return redis.call('incrby', KEYS[1], 0-subNum);");
lua_surplusStock.append(" else ");
lua_surplusStock.append(" return -1;");
lua_surplusStock.append(" end");
List<String> keys = new ArrayList<>();
keys.add(key);
// 脚本里的ARGV参数
List<String> args = new ArrayList<>();
args.add(Integer.toString(num));
long result = redisTemplate.execute(new RedisCallback<Long>() {
@Override
public Long doInRedis(RedisConnection connection) throws DataAccessException {
Object nativeConnection = connection.getNativeConnection();
// 单机模式
if (nativeConnection instanceof Jedis)
{
return (Long) ((Jedis) nativeConnection).eval(lua_surplusStock.toString(), keys, args);
}
return -1l;
}
});
return result;
}问题2:如果加锁失败，则会直接访问，无法重入锁
因为单机版本的锁是无法重入锁，所以加锁失败就直接返回，此问题的解决方案，可以采用Redisson来实现，关于Redisson实现分布式锁，将在后续的文章中进行详细的讲解。
总结
本文主要讲解了Spring Boot集成Redis实现单机版本分布式锁，虽然单机版分布式锁存在锁的续期、锁的重入问题，但是我们还是需要掌握其原理和实现方法
到此这篇关于Spring Boot 实现Redis分布式锁原理的文章就介绍到这了,更多相关Spring Boot Redis分布式锁内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了使用idea自动生成序列化ID全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-09-09
所谓整合，即在Spring的框架下进行扩展，让框架能无缝的与Spring工程配合使用。Spring设计了良好的扩展的机制，本文将对Spring的扩展方法及原理进行简单介绍。2021-05-05
本文对java Thread中join()方法进行介绍，join()的作用是让“主线程”等待“子线程”结束之后才能继续运行，大家参考使用吧2014-01-01
小编最近的工作中遇到了一些知识图谱的工作，自然就用到了图数据库，这一NoSQL 数据库可以很好的展示节点之间的关联关系，对于一些图谱的关系操作是很好的选择，下面来介绍下 Springboot 配置Neo4J的问题2021-12-12
Java Api实现Elasticsearch的滚动查询功能
这篇文章主要介绍了Java Api实现Elasticsearch的滚动查询,解决ES每次只能查询一万条数据的问题,本文通过实例代码给大家介绍的非常详细,需要的朋友可以参考下2023-08-08
Spring Security 在 Spring Boot 中的使用详解【集中式】
这篇文章主要介绍了Spring Security 在 Spring Boot 中的使用【集中式】,本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2020-10-10
这篇文章主要介绍了初识Spark入门,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-06-06
这篇文章主要介绍了 java 实现微信服务器下载图片到自己服务器的相关资料,需要的朋友可以参考下2017-05-05
本文介绍如何使用java代码将自动生成的二维码放入背景模板中，对于java学习者或许有帮助，一起来看看。2016-07-07
详述IntelliJ IDEA提交代码前的 Code Analysis 机制(小结)
本篇文章主要介绍了详述IntelliJ IDEA提交代码前的 Code Analysis 机制(小结)，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。2017-11-11
最新评论