redission YYDS

每天分享一个架构知识

Redission 是一个基于 Redis 的分布式 Java 锁框架，它提供了各种锁实现，包括可重入锁、公平锁、读写锁等。使用 Redission 可以方便地实现分布式锁。

redisson 实现公平锁 和读写锁的代码

1. 公平锁：

javaCopy codeimport org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
public class FairLockExample {
    public static void main(String[] args) {
        // 创建 Redisson 客户端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redissonClient = Redisson.create(config);
        // 获取公平锁实例
        RLock fairLock = redissonClient.getFairLock("myFairLock");
        try {
            // 加锁
            fairLock.lock();
            // 在这里执行需要保护的代码块
        } finally {
            // 释放锁
            fairLock.unlock();
        }
        // 关闭 Redisson 客户端
        redissonClient.shutdown();
    }
}

在上面的示例中，我们使用
redissonClient.getFairLock("myFairLock") 方法获取一个公平锁实例。然后，在 try 块中使用 fairLock.lock() 方法对锁进行加锁操作，然后在需要保护的代码块中执行相应的逻辑。最后，在 finally 块中使用 fairLock.unlock() 方法释放锁。

2. 读写锁：

javaCopy codeimport org.redisson.Redisson;
import org.redisson.api.RReadWriteLock;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
public class ReadWriteLockExample {
    public static void main(String[] args) {
        // 创建 Redisson 客户端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redissonClient = Redisson.create(config);
        // 获取读写锁实例
        RReadWriteLock readWriteLock = redissonClient.getReadWriteLock("myReadWriteLock");
        try {
            // 获取读锁
            RLock readLock = readWriteLock.readLock();
            readLock.lock();
            // 在这里执行需要保护的读操作
            // 获取写锁
            RLock writeLock = readWriteLock.writeLock();
            writeLock.lock();
            // 在这里执行需要保护的写操作
        } finally {
            // 释放读锁
            readLock.unlock();
            // 释放写锁
            writeLock.unlock();
        }
        // 关闭 Redisson 客户端
        redissonClient.shutdown();
    }
}

在上面的示例中，我们使用
redissonClient.getReadWriteLock("myReadWriteLock") 方法获取一个读写锁实例。然后，在 try 块中首先获取读锁，并使用 readLock.lock() 方法对读锁进行加锁操作，在需要保护的读操作代码块中执行相应的逻辑。然后，获取写锁，并使用 writeLock.lock() 方法对写锁进行加锁操作，在需要保护的写操作代码块中执行相应的逻辑。最后，在 finally 块中分别使用 readLock.unlock() 和 writeLock.unlock() 方法释放读锁和写锁。

但是他们是如何实现的呢？

1. 公平锁原理：
2. Redisson 的公平锁实现是基于 Redis 的单线程特性。当多个线程尝试获取公平锁时，它们将按照请求的顺序排队。
3. Redisson 使用 Redis 的命令 SETNX 来实现公平锁。每个请求都会尝试在 Redis 中设置一个键，如果设置成功，则表示获取到了锁；如果设置失败，则表示锁已被其他请求占用。
4. 当一个线程成功获取到公平锁后，它将持有该锁直到释放。
5. 读写锁原理：
6. Redisson 的读写锁是通过 Redis 的单线程特性和 Redis 的 WATCH、MULTI、EXEC 命令实现的。
7. Redisson 使用一个 Redis 键来表示读写锁，该键存储了读锁和写锁的状态。
8. 当一个线程尝试获取读锁时，它会检查写锁是否已被占用，如果没有写锁，则该线程可以获取到读锁；如果有写锁，则需要等待写锁被释放。
9. 当一个线程尝试获取写锁时，它会先检查是否有任何线程持有读锁或写锁，如果有，则需要等待锁被释放；如果没有，则可以获取到写锁。
10. Redisson 使用 WATCH 命令来监视读写锁的状态，在获取锁之前，通过 WATCH 命令来监视读写锁的变化，如果读写锁的状态在获取锁期间发生了变化，则事务将自动失败。

总的来说，Redisson 实现公平锁和读写锁的原理都是基于 Redis 提供的原子性操作和分布式锁机制。它使用 Redis 的命令和特性来确保锁的正确获取和释放，并通过 Redisson 的客户端实现封装了这些操作，使得开发者可以更方便地使用公平锁和读写锁来进行并发控制。

Redisson 公平锁和读写锁的使用场景

公平锁的使用场景：

1. 任务调度：当多个线程或多个节点需要按照请求的顺序依次执行任务时，可以使用公平锁来确保任务按照请求的顺序进行处理，避免出现并发冲突或数据不一致的问题。
2. 资源竞争：当多个线程或多个节点需要竞争有限的资源时，可以使用公平锁来实现公平的资源分配，确保每个请求都有机会获取到资源，避免某些请求长时间占用资源而导致其他请求等待过久。
3. 排他操作：当某个操作需要在多个线程或多个节点之间进行排他性操作时，可以使用公平锁来确保每次只有一个线程或一个节点能够执行该操作，避免并发冲突和数据不一致的问题。

读写锁的使用场景：

1. 缓存更新：当多个线程或多个节点需要读取缓存数据，并在数据更新时进行写操作时，可以使用读写锁来保证在写操作期间其他线程或节点无法读取数据，避免读取到过期或不一致的数据。
2. 数据库访问：当多个线程或多个节点需要对数据库进行读写操作时，可以使用读写锁来实现读写分离，读操作可以并发进行，写操作则需要互斥执行，避免读写冲突和数据不一致的问题。
3. 文件操作：当多个线程或多个节点需要对文件进行读写操作时，可以使用读写锁来实现读写分离，多个线程可以并发读取文件内容，写操作则需要互斥执行，确保文件数据的一致性。

这些场景只是公平锁和读写锁的一部分应用示例，实际上，公平锁和读写锁在许多需要并发控制的场景中都可以发挥作用。具体使用哪种锁取决于业务需求和并发访问模式。

我创建了一个知识星球，专门讨论架构内容，有任何架构方面的问题都可以直接向我提问。