Redis的setNX分布式锁超时时间失效 -1问题及解决

目录
  • Redis setNX分布式锁超时时间失效 -1
    • 使用SETNX加锁
    • 使用 RedisTemplate 操作Redis
    • 解决死锁
  • Redis分布式锁，超时问题的处理
    • 分布式可能会出现的超时问题
  • 总结

Redis setNX分布式锁超时时间失效 -1

使用SETNX加锁

加锁的思路：

如果 key 不存在，将 key 设置为 value，如果 key 已存在，则 SETNX 不做任何动作。

使用 RedisTemplate 操作Redis

    @Autowired
    private RedisTemplate redisTemplate;
 
    @RequestMapping("/setNx")
    public String setNx() {
        String key = "redis_nx_test";
        String value = "1";
 
        boolean res = redisTemplate.getConnectionFactory().getConnection().setNX(key.getBytes(), value.getBytes());
        log.info("setNX:{}", res);
        if (res) {
            redisTemplate.getConnectionFactory().getConnection().expire(key.getBytes(), 50);
            log.info("设置过期时间");
        }
 
        return "success";
    }

解决死锁

考虑一种情况，如果进程获得锁后，断开了与 Redis 的连接（可能是进程挂掉，或者网络中断），如果没有有效的释放锁的机制，那么其他进程都会处于一直等待的状态，即出现“死锁”。

目前考虑是使用定时任务进行扫描处理超时时间为 -1的key

@Scheduled(initialDelay = 1000,fixedDelay = 1000*60*30)
    public void deleteExceptionKey(){
        String key = "redis_nx_test";
        
        //返回 -2   表示这个key已过期，已不存在
        //返回 -1   表示这个key没有设置有效期
        //返回0以上的值   表示是这个key的剩余有效时间
        Long l = redisTemplate.opsForValue().getOperations().getExpire(key);
        log.info("Expire:{}", l);
        if(l == -1){
           Boolean b =  redisTemplate.delete(key);
            log.info("删除key:{},{}", key,b);
        }
    }

Redis分布式锁，超时问题的处理

分布式锁超时问题解决方案，主要是基于redission。Redisson是架设在Redis基础上的一个Java驻内存数据网格（In-Memory Data Grid）。充分的利用了Redis键值数据库提供的一系列优势，基于Java实用工具包中常用接口，为使用者提供了一系列具有分布式特性的常用工具类。

redis实现分布式锁，主要是通过SETNX命令，设置一组 key,value。在同一时刻只能有一个线程设置成功，该线程获得了分布式锁。

分布式可能会出现的超时问题

1、误删除别人的锁

A获取锁后，事务执行超时。锁到期自动释放，B线程获取到锁。A完成事务后，释放锁时，把B的锁释放了。

解决方案：

每个线程在获取锁式，在写key-value时，将自己生成的一个独一无二的id写入value。先校验value，再删除锁。这两个操作要保证原子性，可以采用Lua脚本。

（如果没有保证原子性，会出现A校验完value,锁失效。B写入key-value。A删除B写入的锁。）

2、A到期自动释放锁后，B获得锁。出现两个锁并行的情况

A获取锁后，开启一个守护线程，定期为A刷新锁的时间。这样A就是一直保持锁的情况。在redission源码中有相应的程序。

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。

赞 (0)

相关推荐

  • Redis实现分布式锁(setnx、getset、incr)以及如何处理超时情况

    目录 一.通过setnx实现 1.setnx key value 2.get key 3.getset key value 小明提出了方案一: 小宏说:小明的思想不严谨 网上看还有一种方式(B): 二.通过incr抢占资源实现 1.incr 如果你通过网络搜索分布式锁,最多的就是基于redis的了.基于redis的分布式锁得益于redis的单线程执行机制,单线程在执行上就保证了指令的顺序化,所以很大程度上降低了开发人员的思考设计成本. 一.通过setnx实现 1.setnx key value

  • 详解使用Redis SETNX 命令实现分布式锁

    使用Redis的 SETNX 命令可以实现分布式锁,下文介绍其实现方法. SETNX命令简介 命令格式 SETNX key value 将 key 的值设为 value,当且仅当 key 不存在. 若给定的 key 已经存在,则 SETNX 不做任何动作. SETNX 是SET if Not eXists的简写. 返回值 返回整数,具体为 - 1,当 key 的值被设置 - 0,当 key 的值没被设置 例子 redis> SETNX mykey "hello" (integer

  • Redis实现分布式锁的几种方法总结

    Redis实现分布式锁的几种方法总结 分布式锁是控制分布式系统之间同步访问共享资源的一种方式.在分布式系统中,常常需要协调他们的动作.如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥来防止彼此干扰来保证一致性,在这种情况下,便需要使用到分布式锁. 我们来假设一个最简单的秒杀场景:数据库里有一张表,column分别是商品ID,和商品ID对应的库存量,秒杀成功就将此商品库存量-1.现在假设有1000个线程来秒杀两件商品,500个线程秒杀第一个商品,

  • Redis的setNX分布式锁超时时间失效 -1问题及解决

    目录 Redis setNX分布式锁超时时间失效 -1 使用SETNX加锁 使用 RedisTemplate 操作Redis 解决死锁 Redis分布式锁,超时问题的处理 分布式可能会出现的超时问题 总结 Redis setNX分布式锁超时时间失效 -1 使用SETNX加锁 加锁的思路: 如果 key 不存在,将 key 设置为 value,如果 key 已存在,则 SETNX 不做任何动作. 使用 RedisTemplate 操作Redis     @Autowired     private

  • php redis setnx分布式锁简单原理解析

    我就废话不多说了,大家还是直接看代码吧~ <?php //高并发分布式锁 header("Content-type:text/html;charset=utf-8"); $redis = new Redis(); $redis->connect('127.0.0.1', 6379); echo "Connection to server sucessfully"; //echo $redis->get("name");exit;

  • Redis上实现分布式锁以提高性能的方案研究

    背景: 在很多互联网产品应用中,有些场景需要加锁处理,比如:秒杀,全局递增ID,楼层生成等等.大部分是解决方案基于DB实现的,Redis为单进程单线程模式,采用队列模式将并发访问变成串行访问,且多客户端对Redis的连接并不存在竞争关系. 项目实践 任务队列用到分布式锁的情况比较多,在将业务逻辑中可以异步处理的操作放入队列,在其他线程中处理后出队,此时队列中使用了分布式锁,保证入队和出队的一致性.关于redis队列这块的逻辑分析,我将在下一次对其进行总结,此处先略过. 接下来对redis实现的分

  • Redis如何实现分布式锁详解

    一.前言 在Java的并发编程中,我们通过锁,来避免由于竞争而造成的数据不一致问题.通常,我们以synchronized .Lock来使用它. 但是Java中的锁,只能保证在同一个JVM进程内中执行.如果在分布式集群环境下,就需要分布式锁了. 通常的分布式锁的实现方式有redis,zookeeper,但是一般我们的程序中都会用到redis,用redis做分布式锁,也能够降低成本. 二.实现原理 2.1 加锁 加锁实际上就是在redis中,给Key键设置一个值,为避免死锁,并给定一个过期时间. 在

  • Redis Template实现分布式锁的实例代码

    前言 分布式锁一般有三种实现方式:1. 数据库乐观锁:2. 基于Redis的分布式锁:3. 基于ZooKeeper的分布式锁.本篇博客将介绍第二种方式,基于Redis实现分布式锁.虽然网上已经有各种介绍Redis分布式锁实现的博客,然而他们的实现却有着各种各样的问题,为了避免误人子弟,本篇博客将详细介绍如何正确地实现Redis分布式锁. 可靠性 首先,为了确保分布式锁可用,我们至少要确保锁的实现同时满足以下四个条件: 1.互斥性.在任意时刻,只有一个客户端能持有锁. 2.不会发生死锁.即使有一个

  • Redis如何实现分布式锁

    Redis如何实现分布式锁

    目录 一.前言 二.正文 今天我们来聊一聊分布式锁的那些事. 相信大家对锁已经不陌生了,我们在多线程环境中,如果需要对同一个资源进行操作,为了避免数据不一致,我们需要在操作共享资源之前进行加锁操作.在计算机科学中,锁(lock)或互斥(mutex)是一种同步机制,用于在有许多执行线程的环境中强制对资源的访问限制. 比如你去相亲,发现你和一大哥同时和一个女的相亲,那怎么行呢...,搞不好还要被揍一顿. 那什么是分布式锁呢.当多个客户端需要争抢锁时,我们就需要分布式锁.这把锁不能是某个客户端本地的锁

  • Redisson如何解决redis分布式锁过期时间到了业务没执行完问题

    目录 面试问题 问题分析 如何回答 一.写在前面 二.Redisson实现Redis分布式锁的底层原理 (1)加锁机制 (2)锁互斥机制 (3)watch dog自动延期机制 (4)可重入加锁机制 (5)释放锁机制 (6)上述Redis分布式锁的缺点 总结 面试问题 Redis锁的过期时间小于业务的执行时间该如何续期? 问题分析 首先如果你之前用Redis的分布式锁的姿势正确,并且看过相应的官方文档的话,这个问题So easy.我们来看 很多同学在用分布式锁时,都是直接百度搜索找一个Redis分

  • Feign Client 超时时间配置不生效的解决

    Feign Client 超时时间配置不生效的解决

    目录 Feign Client 超时时间配置不生效 解决方案 问题描述 Feign Client的各种超时时间设置 1. Feign Client Configuration 2. Hystrix Configuration 3. Ribbon Configuration 4. OkHttp Client Configuration 5. 小结一下吧 Feign Client 超时时间配置不生效 解决方案 Feign Client 的 connectTimeout 和 readTimeout 需

  • java基于jedisLock—redis分布式锁实现示例代码

    java基于jedisLock—redis分布式锁实现示例代码

    分布式锁是啥? 单机锁的概念:我们正常跑的单机项目(也就是在tomcat下跑一个项目不配置集群)想要在高并发的时候加锁很容易就可以搞定,java提供了很多的机制例如:synchronized.volatile.ReentrantLock等锁的机制. 为啥需要分布式锁:当我们的项目比较庞大的时候,单机版的项目已经不能满足吞吐量的需求了,需要对项目做负载均衡,有可能还需要对项目进行解耦拆分成不同的服务,那么肯定是做成分布式的项目,分布式的项目因为是不同的程序控制,所以使用java提供的锁并不能完全保

  • Redis分布式锁升级版RedLock及SpringBoot实现方法

    Redis分布式锁升级版RedLock及SpringBoot实现方法

    分布式锁概览 在多线程的环境下,为了保证一个代码块在同一时间只能由一个线程访问,Java中我们一般可以使用synchronized语法和ReetrantLock去保证,这实际上是本地锁的方式.但是现在公司都是流行分布式架构,在分布式环境下,如何保证不同节点的线程同步执行呢?因此就引出了分布式锁,它是控制分布式系统之间互斥访问共享资源的一种方式. 在一个分布式系统中,多台机器上部署了多个服务,当客户端一个用户发起一个数据插入请求时,如果没有分布式锁机制保证,那么那多台机器上的多个服务可能进行并发插

随机推荐