redisson实现分布式锁

🕗 发布于 2024-09-22 04:18 分布式 java redis

什么是redisson?

Redisson 是一个高性能的基于 Redis 的 Java 客户端库，它不仅提供了一个简单的 Redis 连接封装，而且还实现了多种高级功能，使得开发人员可以更容易地在应用程序中集成 Redis 的能力。以下是关于 Redisson 的详细介绍：

主要特点

高级功能支持：除了基本的 Redis 客户端功能外，Redisson 还提供了诸如分布式锁、信号量、队列、集合等多种高级数据结构和功能的支持，非常适合构建复杂的分布式系统。
易用性：Redisson 提供了一个简洁的 API，使得开发者可以方便地使用 Redis 的高级功能，而无需直接编写复杂的 Redis 命令序列。
性能优化：Redisson 设计时考虑了性能因素，使用了异步非阻塞的编程模型，可以显著提高应用程序的吞吐量。
容错性：Redisson 具有良好的容错机制，可以在 Redis 节点发生故障时自动恢复连接，并继续提供服务。
集群支持：Redisson 支持 Redis 单机、主从架构、哨兵架构以及 Redis Cluster 架构，可以适应不同的部署环境。

主要功能

分布式锁：实现可重入锁、公平锁、读写锁等，可以有效防止分布式环境下的并发冲突。
分布式集合：提供 Set、List、Map、BitSet 等常用数据结构的分布式实现。
分布式队列：包括阻塞队列、优先级队列等。
信号量：用于控制访问资源的数量上限。
发布/订阅：支持消息的发布和订阅机制。
原子操作：提供了类似 AtomicLong 的原子变量，支持跨节点的原子操作。
计数器：支持分布式环境下的计数器，可以用于统计等场景。
监听器：支持监听 Redis 键的变化，方便实现事件驱动的应用程序。

使用场景

分布式缓存：利用 Redisson 的缓存特性加速数据访问。
分布式协调服务：例如使用分布式锁来协调多实例之间的访问顺序。
消息传递：使用 Redisson 的发布/订阅功能来实现消息传递。
限流：使用信号量等功能限制访问频率或并发数量。

开发者友好

Redisson 的设计注重开发者体验，通过 Java 注解等方式简化了开发者的编码工作，同时还提供了详细的文档和示例代码，帮助开发者快速上手。

总结

Redisson 是一个非常强大的工具，可以帮助开发人员更容易地在 Java 应用程序中集成 Redis 的功能，尤其是在构建需要高性能、高可用性的分布式系统时非常有用。通过 Redisson，开发者可以专注于业务逻辑的实现，而不必担心底层的分布式协调和同步问题。

redisson实现分布式锁

Redisson 是一个基于 Redis 的 Java 客户端库，它提供了一种简便的方式来使用 Redis 的高级功能，包括分布式锁。使用 Redisson 可以简化分布式锁的实现，并且提供了更多的特性和灵活性。

下面是如何使用 Redisson 来实现分布式锁的一个简单示例：

1. 添加依赖

首先，你需要在你的项目中添加 Redisson 的依赖。如果你使用的是 Maven，可以在 pom.xml 文件中添加如下依赖：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson</artifactId>
    <version>3.16.1</version>
</dependency>

请根据实际版本选择合适的版本号。

2. 配置 RedissonClient

接下来配置一个 RedissonClient 实例，该实例将用于创建锁和其他 Redisson 对象。

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;

public class RedissonDistributedLockExample {
    private static RedissonClient redisson;

    public static void init() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        // 根据实际情况配置Redis服务器地址等信息

        redisson = Redisson.create(config);
    }
}

3. 获取并使用锁

然后，使用 RLock 接口来获取和释放锁。

public class RedissonDistributedLockExample {
    private static final String LOCK_NAME = "myLock";
    private static RLock lock = redisson.getLock(LOCK_NAME);

    public static void main(String[] args) {
        init();

        try {
            // 尝试获取锁，如果锁不可获得，则等待直到获取到锁
            lock.lock();
            
            System.out.println("Lock acquired, performing critical section...");
            // 执行临界区代码
            Thread.sleep(5000); // 模拟长时间运行的任务
            
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
                System.out.println("Lock released.");
            }
        }
        
        // 关闭 Redisson 客户端
        redisson.shutdown();
    }
}

注意事项

线程安全：确保在 finally 块中释放锁，以防锁没有被正确释放导致死锁。
锁超时：虽然上面的例子中没有设置锁的超时时间，但在生产环境中建议为锁设置一个合理的超时时间，以防某个线程无限期持有锁。
异常处理：在实际应用中，应该处理可能出现的各种异常情况，比如网络中断等。

锁超时处理

在使用 Redisson 实现分布式锁时，处理锁的超时是非常重要的，因为它可以防止因持有锁的客户端崩溃而导致的死锁问题。以下是一些处理锁超时的方法：

1. 自动超时设置

Redisson 默认为锁设置了自动过期时间，这个时间可以通过构造函数来指定。例如：

RLock lock = redisson.getLock("myLock", new LockOptions(Duration.ofSeconds(30)));

这里设置锁的超时时间为 30 秒。如果在这个时间内锁没有被显式地解锁，那么它会在 30 秒后自动释放。这有助于防止因客户端崩溃而无法释放锁的情况。

2. 动态设置超时时间

也可以在每次获取锁的时候动态设置超时时间：

lock.tryLock(10, 30, TimeUnit.SECONDS);

这里第一个参数是等待获取锁的最大时间（10秒），第二个参数是锁的有效时间（30秒）。

3. 监控锁的状态

对于长时间运行的任务，可以周期性地检查锁的状态，并尝试续期锁的有效时间。这可以通过定时任务来实现：

ScheduledExecutorService scheduledExecutor = Executors.newSingleThreadScheduledExecutor();
scheduledExecutor.scheduleAtFixedRate(() -> {
    if (lock.isHeldByCurrentThread()) {
        lock.extend(Duration.ofSeconds(30));
    }
}, 0, 10, TimeUnit.SECONDS);

这里我们每隔 10 秒检查一次是否还持有锁，如果持有，则将锁的有效时间延长 30 秒。

4. 使用可重入锁

Redisson 支持可重入锁，这意味着同一个线程可以多次获取同一把锁而不会造成死锁。这在某些场景下是有用的，特别是当需要在临界区内再次获取相同的锁时：

lock.lock(); // 第一次获取锁
// 执行一些操作
lock.lock(); // 再次获取锁，不会造成死锁
// 执行更多操作
lock.unlock(); // 解锁一次
lock.unlock(); // 再解锁一次，完全释放锁

注意事项

超时时间的选择：选择一个合适的超时时间很重要，太短可能导致正常运行中的任务因超时而被中断，太长则可能在客户端出现问题时无法及时释放锁。
续期策略：如果采用续期策略，需要注意续期逻辑的健壮性，避免续期线程本身出现故障。
资源管理：确保在不再需要锁时正确释放它，并且在程序结束时关闭所有相关资源（如 ScheduledExecutorService 和 RedissonClient）。

看门狗机制

Redisson 的分布式锁实现中包含了一个叫做“看门狗”（watchdog）的机制，用来自动延长锁的过期时间。这一机制是为了防止锁的持有者在执行业务逻辑期间意外崩溃，导致锁不能被正常释放，从而引起死锁的问题。

如何工作？

当一个客户端获取了一个锁之后，Redisson 会在 Redis 中为这个锁设置一个过期时间。同时，Redisson 会在本地启动一个定时任务（即看门狗），定期检查这个锁是否仍然由当前客户端持有。如果是的话，看门狗就会自动延长锁在 Redis 中的过期时间。如果锁的持有者在执行过程中崩溃了，那么看门狗也会停止工作，锁会在原有的过期时间到达后自动释放。

实现细节

初始化锁: 当客户端第一次获取锁时，Redisson 会为锁设置一个过期时间（例如 30 秒）。
启动看门狗: Redisson 同时会在本地启动一个定时任务（例如每 10 秒执行一次），该任务负责检查锁的状态。
检查锁状态: 如果锁仍然由当前客户端持有，看门狗会将锁的过期时间重置（例如再增加 30 秒）。
锁的释放: 如果持有锁的客户端正常完成了业务逻辑，它会释放锁；如果客户端崩溃，看门狗也会停止工作，锁将在原始设置的过期时间后自动释放。

示例代码

下面是一个使用 Redisson 实现的带有看门狗机制的分布式锁的简单示例：

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;

public class RedissonWatchdogExample {
    private static final String LOCK_NAME = "myLock";
    private static RLock lock;
    private static RedissonClient redisson;

    public static void init() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        redisson = Redisson.create(config);
        lock = redisson.getLock(LOCK_NAME);
    }

    public static void main(String[] args) {
        init();

        try {
            // 尝试获取锁，如果锁不可获得，则等待直到获取到锁
            lock.lock();
            
            System.out.println("Lock acquired, performing critical section...");
            // 执行临界区代码
            Thread.sleep(5000); // 模拟长时间运行的任务
            
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.err.println("Interrupted while waiting for the lock.");
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
                System.out.println("Lock released.");
            }
        }
        
        // 关闭 Redisson 客户端
        redisson.shutdown();
    }
}

注意事项

过期时间设置: 确保设置一个合理的过期时间，这个时间应该比最长时间的业务逻辑执行时间稍长一点，以避免正常执行过程中的误释放。
看门狗间隔: 一般情况下，看门狗的检查间隔应该小于锁的过期时间，以保证锁在长时间运行任务中的安全性。
资源释放: 在使用完毕后，记得释放锁以及关闭 Redisson 客户端，以避免资源泄露。

通过使用 Redisson 的看门狗机制，可以有效地避免因客户端异常退出而导致的死锁问题，从而提高分布式系统的稳定性和可靠性。

原文地址：https://blog.csdn.net/wendao76/article/details/142292324

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：特殊类的设计与类型转换
下一篇：ModuleNotFoundError: No module named ‘datasets‘

react 中 useCallback Hook 作用
在 React 函数组件中，每次组件重新渲染时，内部的函数都会被重新创建。
阅读更多2024-11-16
如何在项目中用elementui实现分页器功能
5.在需要用到分页器的组件像服务器发请求（实现按钮和页面跳转的绑定）这是 Element UI 库中的一个组件，用于创建分页器。3.在分页器组件接收参数。
阅读更多2024-11-16
命名空间（namespace）详解（一）
经查可知，头文件stdlib.h中包含了名为atof的函数，此时我们再定义atof的变量就会报错，那么如何解决这个问题呢？就有了命名空间的用法。
阅读更多2024-11-16
ssm102“魅力”繁峙宣传网站的设计与实现+vue(论文+源码)_kaic
目录摘要ABSTRACT第1章绪论1.1背景及意义1.2 国内外研究概况1.3 研究的内容第2章相关技术2.1 JSP技术介绍2.2 JAVA简介2.3 MyEclipse开发环境2.4 T
阅读更多2024-11-16
深度学习--卷积神经网络
一般认为，人对外界的认知是从局部到全局的，而图像的空间联系也是局部的像素联系较为紧密，而距离较远的像素相关性则较弱。用一个或者多个卷积核扫描照片，卷积核自带的参数就是权重，在同一个卷积核扫描的图层当中
阅读更多2024-11-16
go反射深入学习
reflect.ValueOf(&x) 将 x 的地址传递给 reflect.Value，这使得我们能够通过反射修改 x 的值。传递给 reflect.ValueOf() 的是 x 的值，而不
阅读更多2024-11-16
Git如何简单使用
GitGitlabGitLab和GitHub有什么区别？Gitlab简单使用Gitlab常用指令
阅读更多2024-11-16
动态规划-背包问题——[模版]完全背包问题
与01背包相同，这里的完全背包也是需要一个二维dp表来表示最大价值，具体如下。返回最后一个位置dp表的值。从上至下，每一行从左到右。
阅读更多2024-11-16
hhdb数据库介绍(9-14)
介绍hhdb的sql语法支持
阅读更多2024-11-16
初识算法 · 位运算(end)
面试题 17.19. 消失的两个数字 - 力扣（LeetCode）还是和前文一样，通过三个部分介绍，题目解析，算法原理，算法编写来介绍。那么话不多说，进入主题吧！题目解析题目的要求十分简单，是让我们在
阅读更多2024-11-16

redisson实现分布式锁

文章目录

什么是redisson?

主要特点

主要功能

使用场景

开发者友好

总结

redisson实现分布式锁

1. 添加依赖

2. 配置 RedissonClient

3. 获取并使用锁

注意事项

锁超时处理

1. 自动超时设置

2. 动态设置超时时间

3. 监控锁的状态

4. 使用可重入锁

注意事项

看门狗机制

如何工作？

实现细节

示例代码

注意事项

相关文章