脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 数据库 → Redis → redis分布式锁

redis分布式锁的问题与解决方法

 更新时间：2019年07月21日 10:16:14   作者：付威的网络博客  
这篇文章主要给大家介绍了关于redis分布式锁的问题与解决方法，文中通过示例代码介绍的非常详细，对大家学习或者使用redis具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧

分布式锁

在分布式环境中，为了保证业务数据的正常访问，防止出现重复请求的问题，会使用分布式锁来阻拦后续请求。我们先写一段有问题的业务代码：

public void doSomething(String userId){
  User user=getUser(userId);
  if(user==null){
   user.setUserName("xxxxx");
   user.setUserId(userId);
   insert(user);
   return;
  }
  update(user);
 }

上面的代码很简单，查询db中有没有对应的user数据，如果有的话，执行更新操作，如果没有则插入。

我们知道，上面的代码是线程不安全的，在多线程的环境中，就会出现问题。为了能够保证数据的正确性，在单机环境下，我们可以使用synchronized的方法，来保证线程安全，具体修改：

public synchronized void doSomething(String userId){
  User user=getUser(userId);
  if(user==null){
   user.setUserName("xxxxx");
   user.setUserId(userId);
   insert(user);
   return;
  }
  update(user);
 }

在单机器的环境下，能够解决线程安全的问题，那在分布式环境下呢？ 这个时候需要用到分布式锁.

分布式锁需要借助其他组件来实现，常用的有redis和zookeeper。下面我们就用redis的实现，来说明下问题，分布式锁具体的实现方法如下

public void doSomething(String userId){
  String lock=RedisUtils.get("xxxx"+userId);
  if(StringUtils.isNotEmpty(lock)){//说明当前userId已经被锁定
   return;
  }
  RedisUtils.set("xxxx"+userId,userId,1000);//锁定10s
  User user=getUser(userId);
  if(user==null){
   insert(user);
   RedisUtils.delete("xxxx"+userId);
   return;
  }
  update(user);
  RedisUtils.delete("xxxx"+userId);
  
 }

上面的代码解决了在分布式环境中的并发的问题。但同样需要考虑一个问题，如果insert操作和update操作异常了，分布式锁不会释放，后续的请求还会被拦截。

所以我们再优化，增加对异常的捕获。

public void doSomething(String userId){
  try {
    String lock=RedisUtils.get("xxxx"+userId);
    if(StringUtils.isNotEmpty(lock)){//说明当前userId已经被锁定
     return;
    }
    RedisUtils.set("xxxx"+userId,userId,1000);//锁定1s
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   RedisUtils.delete("xxxx"+userId);
  }
 }

现在即使是程序异常了，锁会自动释放。但redis的get和set也会存在并发问题，我们再继续优化，使用redis中的setnx方法

public void doSomething(String userId){
  try {
    boolean lock=RedisUtils.setnx("xxxx"+userId,userId,1000);//锁定1s
    if(!lock){//说明当前userId已经被锁定
     return;
    }
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   RedisUtils.delete("xxxx"+userId);
  }
 }

上面的代码好像没有什么问题了，但也存在很大的隐患。 我们分析下，假设第一个请求过来，执行锁定成功，程序开始运行，但是insert和update操作阻塞了1s，第二个请求过来，锁的缓存已经过期，第二个执行锁定成功，这个时候第一个请求完成了锁被释放，第二个请求的锁就被第一次请求释放了，第三次的请求就会造成线程不安全问题。

怎么再去优化呢？问题主要是出现在第一次请求误删锁的问题，所以我们在移除锁的时候要判断能否移除。

思路：我们在锁定的时候，value使用当前的时间戳，删除时判断是否过期如果不过期就不要删除，具体代码如下：

public void doSomething(String userId){
  try {
    boolean lock=RedisUtils.setnx("xxxx"+userId,LocalDateTime.now(),1000);//锁定10s
    if(!lock){//说明当前userId已经被锁定
     return;
    }
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   LocalDateTime lockTIme= RedisUtils.get("xxxx"+userId);
   if(lockTIme.compare(LocalDateTime.now())<0){
    //说明已经过期，可以删除key
    RedisUtils.delete("xxxx"+userId);
   }
  }
 }

 这样即使出现阻塞，第二次的时间戳覆盖了第一次的锁定，这样即使第一次完成了，也不会释放锁。

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对脚本之家的支持。

您可能感兴趣的文章:

相关文章

  • Redis监控工具RedisInsight安装与使用

    Redis监控工具RedisInsight安装与使用

    这篇文章主要为大家介绍了Redis监控工具RedisInsight的安装步骤与使用方法，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步
    2022-03-03
  • Redis删除过期key策略详解

    Redis删除过期key策略详解

    Redis是一款高性能的开源内存数据库,广泛应用于缓存、消息队列、实时分析等场景,在Redis中,我们经常需要删除过期的key,以释放内存空间并保持数据的有效性,本文将为您详细介绍Redis的过期key删除策略,帮助您更好地管理和优化Redis数据库
    2023-10-10
  • redis中redis-cli使用小结

    redis中redis-cli使用小结

    redis-cli 是Redis命令行界面,一个简单的程序,允许直接从终端向Redis发送命令,并读取服务器发送的回复,本文主要介绍了redis中redis-cli使用小结,感兴趣的可以了解一下
    2023-10-10
  • Redis连接错误的情况总结分析

    Redis连接错误的情况总结分析

    这篇文章主要给大家总结介绍了关于Redis连接错误的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-02-02
  • Redis中的bitmap详解

    Redis中的bitmap详解

    BitMap是通过一个bit位来表示某个元素对应的值或者状态,其中的key就是对应元素本身。我们知道8个bit可以组成一个Byte，所以bitmap本身会极大的节省储存空间，下面通过本文给大家介绍Redis中的bitmap知识，感兴趣的朋友一起看看吧
    2021-10-10
  • redis中List列表常见命令及使用场景

    redis中List列表常见命令及使用场景

    这篇文章主要给大家介绍了关于redis中List列表常见命令及使用场景的相关资料,Redis列表是简单的字符串列表,按照插入顺序排序,文中通过代码介绍的非常详细,需要的朋友可以参考下
    2024-01-01
  • Redis优雅地实现延迟队列的方法分享

    Redis优雅地实现延迟队列的方法分享

    Redisson是Redis服务器上的分布式可伸缩Java数据结构，这篇文中主要为大家介绍了Redisson实现的优雅的延迟队列的方法，需要的可以参考一下
    2023-02-02
  • 解锁redis锁的正确姿势

    解锁redis锁的正确姿势

    这篇文章主要为大家详细介绍了解锁redis锁的正确姿势，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2017-03-03
  • Redis分布式锁的10个坑总结

    Redis分布式锁的10个坑总结

    日常开发中，经常会碰到秒杀抢购等业务，为了避免并发请求造成的库存超卖等问题，我们一般会用到Redis分布式锁，但是使用Redis分布式锁，很容易踩坑哦，本文将给大家分析阐述，Redis分布式锁的10个坑,需要的朋友可以参考下
    2023-05-05
  • Redis和Lua使用过程中遇到的小问题

    Redis和Lua使用过程中遇到的小问题

    这篇文章主要给大家介绍了关于Redis和Lua使用过程中遇到的小问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2019-11-11

最新评论