Redis分布式锁这样用,有坑?

背景

在微服务项目中,大家都会去使用到分布式锁,一般也是使用Redis去实现,使用RedisTemplate、Redisson、RedisLockRegistry都行,公司的项目中,使用的是Redisson,一般你会怎么用?看看下面的代码,是不是就是你的写法

String lockKey = "forlan_lock_" + serviceId;
RLock lock = redissonClient.getLock(lockKey);

// 方式1
try {
	lock.lock(5, TimeUnit.SECONDS);
	// 执行业务
	...
} catch (Exception e) {
	e.printStackTrace();
} finally {
	// 释放锁
	lock.unlock();
}

// 方式2
try {
	if (lock.tryLock(5, 5, TimeUnit.SECONDS)) {
		// 获得锁执行业务
		...
	}
} catch (Exception e) {
	e.printStackTrace();
} finally {
	// 释放锁
	lock.unlock();
}

分析

像上面的写法,符合我们的常规思维,一般,为了避免程序挂了的情况,没有释放锁,都会设置一个过期时间
但这个过期时间,一般设置多长?

设置过短,会导致我们的业务还没有执行完,锁就释放了,其它线程拿到锁,重复执行业务
设置过长,如果程序挂了,需要等待比较长的时间,锁才释放,占用资源

这时候,你会说,一般我们可以根据业务执行情况,设置个过期时间即可,对于部分执行久的业务,Redisson内部是有个看门狗机制,会帮我们去续期,简单来说,就是有个定时器,会去看我们的业务执行完没,没有就帮我们进行延时,看似没有问题吧,那我们来简单看下源码,无论我们使用哪种方式,最终都会进到这个方法,就是看门狗机制的核心代码

private <T> RFuture<Long> tryAcquireAsync(long leaseTime, TimeUnit unit, final long threadId) {
    if (leaseTime != -1L) {
        // 前面我们指定了过期时间,会进到这里,直接加锁
        return this.tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG);
    } else {
        // 没有指定过期时间的话,默认采用LockWatchdogTimeout,默认是30s
        RFuture<Long> ttlRemainingFuture = this.tryLockInnerAsync(this.commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_LONG);
        // ttlRemainingFuture执行完,添加一个监听器,类似netty的时间轮
        ttlRemainingFuture.addListener(new FutureListener<Long>() {
            public void operationComplete(Future<Long> future) throws Exception {
                if (future.isSuccess()) {
                    Long ttlRemaining = (Long)future.getNow();
                    if (ttlRemaining == null) {
                        RedissonLock.this.scheduleExpirationRenewal(threadId);
                    }
                }
            }
        });
        return ttlRemainingFuture;
    }

scheduleExpirationRenewal方法

private void scheduleExpirationRenewal(final long threadId) {
 if (!expirationRenewalMap.containsKey(this.getEntryName())) {
     Timeout task = this.commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
         public void run(Timeout timeout) throws Exception {
         	 // renewExpirationAsync就是执行续期的方法
             RFuture<Boolean> future = RedissonLock.this.renewExpirationAsync(threadId);
             // 什么时候触发执行?
             future.addListener(new FutureListener<Boolean>() {
                 public void operationComplete(Future<Boolean> future) throws Exception {
                     RedissonLock.expirationRenewalMap.remove(RedissonLock.this.getEntryName());
                     if (!future.isSuccess()) {
                         RedissonLock.log.error("Can't update lock " + RedissonLock.this.getName() + " expiration", future.cause());
                     } else {
                         if ((Boolean)future.getNow()) {
                             RedissonLock.this.scheduleExpirationRenewal(threadId);
                         }

                     }
                 }
             });
         }
     }, this.internalLockLeaseTime / 3L, TimeUnit.MILLISECONDS); // 当跑了LockWatchdogTimeout的1/3时间就会去执行续期
     if (expirationRenewalMap.putIfAbsent(this.getEntryName(), new RedissonLock.ExpirationEntry(threadId, task)) != null) {
         task.cancel();
     }
 }

所以,结论是啥?

// 方式1
lock.lock(5, TimeUnit.SECONDS);
// 方式2
lock.tryLock(5, 5, TimeUnit.SECONDS)

我们这两种写法都会导致看门狗机制失效,如果业务执行超过5s,就会出问题

解决

正确的写法应该是,不指定过期时间

// 方式1
lock.lock();
// 方式2
lock.tryLock(5, -1, TimeUnit.SECONDS)

你可以会觉得不妥,不指定的话,就默认按照30s续期时间,然后每10s去看看有没有执行完,没有就续期,
我们也可以指定续期时间,比如指定为15s

config.setLockWatchdogTimeout(15000L);

总结

  • 在使用Redisson实现分布式锁,不应该设置过期时间
  • 看门狗默认续期时间是30s,可以通过setLockWatchdogTimeout指定
  • 看门狗会每internalLockLeaseTime / 3L去续期
  • 看门狗底层实际就是类似Netty的时间轮

原文链接:https://www.cnblogs.com/huozhonghun/p/17323627.html

本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:Redis分布式锁这样用,有坑? - Python技术站

(0)
上一篇 2023年4月17日
下一篇 2023年4月17日

相关文章

  • 详解springmvc之json数据交互controller方法返回值为简单类型

    下面是详解springmvc之json数据交互controller方法返回值为简单类型的攻略。 什么是Spring MVC? Spring MVC是一个基于Java的Web框架,用于开发Web应用程序。它使用Java Servlet API和为其定义的JavaServer Pages(JSP)规范来实现Web组件。 什么是JSON? JSON(JavaScr…

    Java 2023年5月26日
    00
  • 关于Java下奇怪的Base64详解

    关于Java下奇怪的Base64详解,我将分为以下几个部分进行讲解: 1. 什么是Base64 Base64是一种编码方式,它可以将二进制数据编码成可打印的ASCII字符,因此可以在网络上以文本的形式进行传输。它常常被用于传输图片、音频等二进制文件。Base64编码的原理是将3个字节的二进制编码为4个字符的可打印字符。 2. Java中Base64的使用 J…

    Java 2023年5月20日
    00
  • Java WebService 简单实例(附实例代码)

    Java WebService 是一种基于 Web 的远程调用技术,允许不同的应用程序通过互联网相互通信以完成特定的业务功能。本文将介绍如何快速入门 Java WebService,并提供一个简单的实例程序。 准备工作 在开始编写 WebService 之前,需要先准备好以下环境和工具: JDK:Java 开发环境 Eclipse:Java 开发工具 Tom…

    Java 2023年5月23日
    00
  • 详解Java多线程tryLock()方法使用

    详解Java多线程tryLock()方法使用 什么是tryLock()方法 tryLock方法是Java多线程中使用的一种同步锁机制。它尝试获取锁,如果锁可用则获取锁并返回true,如果锁不可用则直接返回false,而不会阻塞等待锁。 tryLock方法的定义为: public boolean tryLock() tryLock方法会试图去获取锁,如果锁已经…

    Java 2023年5月19日
    00
  • jsp页面中插入css样式的三种方法总结

    下面将详细讲解jsp页面中插入css样式的三种方法总结。 方法一:直接在jsp页面中使用style标签 在jsp页面的标签中添加 标签,然后直接在其中编写CSS样式即可。 示例: <%@ page contentType="text/html;charset=UTF-8" language="java" %&gt…

    Java 2023年6月15日
    00
  • Java 设计模式中的策略模式详情

    Java 设计模式中的策略模式 策略模式基础概念 策略模式是一种行为型设计模式,它能让你定义一些算法并将其封装到具有公共接口的独立类中。由于所有策略类都实现了相同的接口,因此它们可以自由地相互替换。 策略模式的结构 策略模式的核心在于定义一个策略接口(Istrategy),所有的算法都实现这个接口;然后定义一个上下文类(Context),这个上下文类有一个策…

    Java 2023年5月19日
    00
  • Hibernate框架数据分页技术实例分析

    Hibernate框架数据分页技术实例分析 简介 Hibernate框架是一个开源的Java持久层框架,具有高级对象/关系映射(ORM)功能,可实现Java类与数据库表的映射。在实际开发中,为了提高系统的性能和用户体验,常需要使用分页技术来处理大量数据的展示。本文将介绍如何使用Hibernate框架实现数据分页功能。 实现分页的步骤 步骤一:配置Hibern…

    Java 2023年5月19日
    00
  • java使用JWT的方法

    当Java应用需要进行用户验证和授权时,常用的方案之一是使用JWT(JSON Web Token)。JWT是一种基于JSON格式的安全传输令牌,通过使用JWT能够实现用户身份认证和授权信息的传递。 以下是Java使用JWT的方法的完整攻略。 1. 导入相关依赖 为了使用JWT,我们需要在Java应用中导入相关依赖。可以通过在maven的pom.xml文件中添…

    Java 2023年5月20日
    00
合作推广
合作推广
分享本页
返回顶部