简介

Redisson是一个用于Redis的Java客户端，它提供了许多超越标准Redis功能的高级特性。Redisson旨在简化分布式环境中对Redis的操作，使得开发者能够更加专注于业务逻辑而不是底层细节。以下是Redisson的一些关键特性和简介：

主要特性

丰富的集合类型：Redisson提供了对多种数据结构的支持，包括映射(Map)、列表(List)、集合(Set)、有序集合(SortedSet)等，以及它们的分布式版本。
分布式对象和服务：除了基本的数据结构外，Redisson还支持分布式锁(Distributed Locks)、信号量(Semaphores)、闭锁(CountDownLatch)等同步工具，有助于实现复杂的分布式系统架构。
异步和响应式编程模型：Redisson支持基于Netty的完全非阻塞异步执行模式和Reactive Streams规范，允许以响应式的方式进行编程。
集群和主从支持：Redisson可以无缝地与Redis的单机、主从、哨兵(sentinel)及集群(cluster)配置协同工作。
灵活的序列化方式：支持JDK序列化、JSON、Avro、Amazon Ion、Kryo、FST、 Smile、LZ4、Snappy等多种序列化方法，方便用户根据需求选择合适的序列化策略。
Spring框架集成：Redisson与Spring框架有很好的集成，可以作为Spring缓存提供者使用，并支持Spring Boot Starter自动配置。
Tomcat会话管理器：Redisson提供了Tomcat Web Session Manager，可以在多个Tomcat实例之间共享HTTP会话。
易于使用：通过提供直观且一致的API，Redisson大大降低了开发人员在分布式环境中操作Redis的复杂度。

总之，Redisson为Java应用提供了一个强大的工具包来与Redis进行交互，无论是简单的键值存储还是复杂的分布式应用程序，都可以从中受益。它不仅提升了Redis的功能，同时也极大地简化了其使用难度。

使用

添加依赖

xml
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.17.6</version> <!-- 确保选择适合你项目的版本 -->
</dependency>

配置

yml
spring:
  redis:
    timeout: 3000
    single:
      server: "redis://127.0.0.1:6379"

使用Redisson

java
import org.redisson.api.RMap;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class MyService {

    @Autowired
    private RedissonClient redissonClient;

    public void perform() {
        RMap<String, String> map = redissonClient.getMap("myMap");
        map.put("key1", "value1");

        System.out.println(map.get("key1"));
    }
}

RLatch

RLatch，也称为CountDownLatch，在Redisson中实现了类似Java并发包中java.util.concurrent.CountDownLatch的功能。它允许一个或多个线程等待，直到其他地方的一组操作完成。换句话说，RLatch是一种同步辅助类，允许一个或多个线程等待，直到一组在其他线程中执行的操作完成。

用途：主要用于协调多个线程之间的操作顺序，特别是当一个线程需要等待其他线程完成一系列操作后才能继续进行的情况下。

主要操作： await()：使当前线程等待，直到countDown()方法的调用次数达到构造RLatch时设定的计数。

countDown()：递减计数器，表示有一个操作已经完成。当计数达到零时，所有因调用await()而在等待的线程将被释放。

getCount()：返回当前计数。

示例场景：如果你的应用程序需要等待N个不同的数据源加载完毕后才能开始处理这些数据，可以使用RLatch来确保所有的数据源都已准备好。

总结 RLock 主要用于保证在任何时刻只有一个线程能够访问某些关键代码段或资源，提供了一种互斥机制。 RLatch 则是为了让一个或多个线程等待，直到另一组线程完成了它们的工作，提供了基于计数的同步机制。理解这两种机制的区别以及各自的适用场景对于正确设计并发和分布式系统非常重要。

java

@Autowired
private RedissonClient redissonClient;

public void performWithLock() {
    RLatch latch = redissonClient.getLatch("myLock");
    try {
        // 尝试获取锁
        if (latch.trySetCount(1)) {
            // 执行业务逻辑
            System.out.println("Performing with lock...");
        }
    } finally {
        // 释放锁
        latch.countDown();
    }
}

RLock

RLock是Redisson提供的一个分布式锁实现，它模拟了Java并发包中java.util.concurrent.locks.Lock接口的行为。通过使用RLock，你可以在分布式环境中安全地管理对共享资源的访问。这确保了在同一时间只有一个客户端可以执行特定的代码块，从而避免了竞争条件。

用途：用于控制对共享资源的互斥访问。

主要操作：

lock()：获取锁。如果锁已经被其他客户端持有，则当前线程会等待直到获得锁。

tryLock(long waitTime, long leaseTime, TimeUnit unit)：尝试在指定的等待时间内获取锁，并设置锁的最大持有时间。如果在waitTime内无法获取锁，则返回失败。

unlock()：释放锁。

示例场景：当你需要确保在一个分布式系统中某个任务只会被一个节点处理时，可以使用RLock。

java
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;

import java.util.concurrent.TimeUnit;

public class RedissonLockExample {

    private final RedissonClient redissonClient;

    public RedissonLockExample(RedissonClient redissonClient) {
        this.redissonClient = redissonClient;
    }

    public void performWithLock() throws InterruptedException {
        RLock lock = redissonClient.getLock("myLock");

        try {
            // 尝试获取锁，最多等待10秒，持有锁的时间为60秒
            boolean isLocked = lock.tryLock(10, 60, TimeUnit.SECONDS);
            if (isLocked) {
                try {
                    // 执行业务逻辑
                    System.out.println("Performing with lock...");
                } finally {
                    // 确保在完成后释放锁
                    lock.unlock();
                }
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt(); // 恢复中断状态
            throw e;
        }
    }
}

1. 基于Redis的原子操作
Redis本身提供了许多原子操作，比如SETNX（SET if Not eXists），它可以用于尝试设置一个键值对，并且只有在键不存在时才会成功执行。这个特性非常适合用来实现分布式锁的基础：尝试获取锁的操作必须是原子性的，以避免竞态条件。

2. 锁的自动过期
为了防止死锁（例如，持有锁的客户端崩溃或网络故障导致无法释放锁），Redisson为每个锁设置了自动过期时间。当客户端请求获取锁时，它会指定一个锁的有效期（lease time）。如果在这个时间段内锁没有被显式释放，Redis将自动删除该锁，允许其他客户端可以获取它。

3. Watch Dog机制
Redisson还引入了一个叫做“看门狗”（Watch Dog）的机制。默认情况下，如果线程仍然需要保持锁定状态，Redisson会在锁即将到期前自动延长锁的生存时间。这对于那些不能确定执行时间的任务特别有用。当然，如果你知道任务的确切运行时间，也可以禁用此功能并手动设置合适的锁有效期。

4. 可重入性
Redisson的分布式锁支持可重入性，这意味着同一个线程可以多次获取相同的锁而不造成死锁。每次获取锁时，计数器加一；每次释放锁时，计数器减一；当计数器归零时，锁才真正被释放。

5. 发布/订阅模式用于锁的竞争
当一个客户端尝试获取已被另一个客户端持有的锁时，Redisson使用Redis的发布/订阅（Pub/Sub）功能来通知等待中的客户端锁的状态变化。一旦锁被释放，所有等待的客户端都会收到通知，然后它们可以再次尝试获取锁。这提高了锁的竞争效率，减少了不必要的轮询。

6. 多Redis实例的支持
除了单个Redis实例外，Redisson还支持通过Redlock算法在多Redis实例上实现分布式锁。Redlock算法要求至少三个独立的主从复制的Redis实例，以此增加锁的可靠性和可用性。

总结来说，Redisson分布式锁利用了Redis的高效性和灵活性，结合了一系列高级特性如自动过期、看门狗机制、可重入性以及发布/订阅模式等，提供了一种强大而易于使用的解决方案来处理分布式环境下的并发控制问题。

目录

简介

主要特性

使用

添加依赖

配置

使用Redisson

RLatch

RLock