Redis中的锁SETNX详解

Redis中的锁SETNX详解

引用

CSDN

1.

https://blog.csdn.net/qq_51447496/article/details/138203263

Redis提供了多种方式来实现锁操作，这些操作可以帮助开发者在多线程或分布式环境中同步访问共享资源。

基本锁命令

1. SETNX（Set if Not eXists）:

• 命令：SETNX key value
• 功能：如果键key不存在，则创建并设置键的值，返回1；如果键已存在，则不做任何操作，返回0。

2. EXPIRE:

• 命令：EXPIRE key seconds
• 功能：为键key设置过期时间，单位为秒。

3. DEL:

• 命令：DEL key
• 功能：删除指定的键。

锁操作示例

1. 尝试获取锁：

   redis-cli SETNX lock_key my_value
   

• 如果返回1，则表示成功获取锁；如果返回0，则锁已被其他客户端持有。

2. 设置锁的过期时间（如果需要）：

   redis-cli EXPIRE lock_key 10
   

• 这将锁的过期时间设置为10秒，防止在锁被持有期间持有者崩溃。

3. 释放锁：

   redis-cli DEL lock_key
   

分布式环境下的锁

在分布式环境中，可以使用Redis的这些基本命令来实现分布式锁。以下是一些额外的考虑：

1. 锁的原子性：

• 使用SETNX命令来确保锁的原子性，避免在分布式环境中同时有多个客户端获取到锁。

2. 锁的超时：

• 使用EXPIRE命令设置锁的过期时间，以避免死锁。

3. 锁的重试：

• 在获取锁失败时，可以实现重试机制。

4. 锁的安全性：

• 通过合理的过期时间和重试策略来提高锁的安全性。

5. 分布式锁的实现：

• 在分布式环境中，可以使用Redis的哨兵（Sentinel）或集群（Cluster）功能来保证锁的高可用性。

封装好的方法

1. RedLock：

• RedLock是一种Redis分布式锁的实现，它通过尝试在多个Redis节点上获取锁来提高锁的安全性。

2. 框架封装：

• 许多框架提供了对Redis锁的封装，例如：
• Spring Boot：使用StringRedisTemplate或Lettuce客户端。
• Java：使用Jedis或Lettuce客户端。

3. 使用Lua脚本：

• 为了提高锁操作的原子性，可以使用Lua脚本来封装SETNX和EXPIRE命令。

Lua脚本示例

local key = KEYS[1]
local value = ARGV[1]
local ttl = tonumber(ARGV[2])
if redis.call("SETNX", key, value) == 1 then
    redis.call("EXPIRE", key, ttl)
    return 1
else
    return 0
end

对比表：传统锁与Redis锁

Redission用法

Redission是一个在Java中使用Redis客户端的库，它提供了多种分布式锁和同步器的实现。以下是Redission的一些关键特性和用法：

1. 可重入锁（FairLock）:

   RLock lock = redisson.getFairLock("lock");
   lock.lock();
   try {
       // 处理业务逻辑
   } finally {
       lock.unlock();
   }
   

2. 红锁（RedLock）:
   Redission实现了RedLock算法，提供了一种安全的分布式锁机制。

   RedLock redLock = new RedLock(
       new RedissonClientConfig("path/to/config.json"));
   boolean isLocked = redLock.tryLock("myLock", 10000);
   if (isLocked) {
       try {
           // 处理业务逻辑
       } finally {
           redLock.unlock();
       }
   }
   

3. 读写锁（ReadWriteLock）:

   RReadWriteLock lock = redisson.getReadWriteLock("rwLock");
   RLock rLock = lock.readLock();
   rLock.lock();
   try {
       // 读操作
   } finally {
       rLock.unlock();
   }
   

4. 信号量（Semaphore）:

   RSemaphore semaphore = redisson.getSemaphore("semaphore");
   boolean acquired = semaphore.tryAcquire(); // 尝试获取一个许可
   if (acquired) {
       try {
           // 处理业务逻辑
       } finally {
           semaphore.release(); // 释放许可
       }
   }
   

5. 分布式环境下的用法:
   在分布式环境下，Redission通过Redis服务器来实现锁和其他同步器。需要配置Redisson以连接到Redis集群或哨兵系统，以确保高可用性和故障转移。

分布式条件下的Redission用法

在分布式系统中，使用Redission可以提供以下优势：

• 跨JVM锁：Redission提供的锁是跨JVM的，可以在不同的实例和服务器之间同步。
• 高可用性：通过连接到Redis Sentinel或Cluster，Redission可以提供高可用性的锁。
• 灵活的配置：Redission允许你通过配置文件或代码来配置连接池、线程池、事件监听器等。
• 丰富的同步器：除了锁，Redission还提供了原子变量、计数器、布隆过滤器等多种同步器。