Redis實現(xiàn)分布式鎖全過程

更新時間：2025年08月18日 10:50:15 作者：胡英俊俊俊

文章介紹Redis實現(xiàn)分布式鎖的方法,包括使用SETNX和EXPIRE命令確保互斥性與防死鎖,Redisson客戶端提供的便捷接口,以及Redlock算法通過多節(jié)點共識提高容錯性,同時強調需合理設置鎖過期時間、唯一標識,并注意網絡分區(qū)問題

Redis實現(xiàn)分布式鎖

在分布式系統(tǒng)中，為了避免多個進程同時對共享資源進行修改，需要使用分布式鎖來確保只有一個進程能夠訪問某個關鍵代碼塊。

Redis 由于其高性能和簡單的 API，常被用來實現(xiàn)分布式鎖。

本文將詳細講解如何使用 Redis 實現(xiàn)分布式鎖，并涵蓋一些常見的注意事項。

1. 分布式鎖的基本原理

分布式鎖需要具備以下特性：

互斥性：在同一時刻，只有一個客戶端可以獲得鎖。
防死鎖：即使持有鎖的客戶端崩潰或未正常釋放鎖，鎖也能被其他客戶端獲取。
容錯性：在部分 Redis 節(jié)點故障時，仍能保證鎖的可用性。

Redis 的分布式鎖基于 SETNX 命令（SET IF Not EXISTS），并結合 EXPIRE 命令設置超時時間以防止死鎖。

2. 使用 Redis 實現(xiàn)分布式鎖

以下是一個基于 Redis 實現(xiàn)分布式鎖的典型示例。

2.1 獲取鎖

使用 SETNX (SET IF Not EXISTS) 和 EXPIRE 組合可以保證鎖的唯一性和超時性。

import redis.clients.jedis.Jedis;

public class RedisLock {
    private Jedis jedis;
    private String lockKey;
    private int expireTime; // 過期時間（秒）

    public RedisLock(Jedis jedis, String lockKey, int expireTime) {
        this.jedis = jedis;
        this.lockKey = lockKey;
        this.expireTime = expireTime;
    }

    public boolean acquireLock(String requestId) {
        String result = jedis.set(lockKey, requestId, "NX", "EX", expireTime);
        return "OK".equals(result);
    }
}

2.2 釋放鎖

在釋放鎖時，需要確保只有加鎖的客戶端才能解鎖。這可以通過判斷鎖的值是否匹配來實現(xiàn)?？梢允褂?Lua 腳本確保操作的原子性。

public boolean releaseLock(String requestId) {
    String script = "if redis.call('get', KEYS[1]) == ARGV[1] then " +
                    "return redis.call('del', KEYS[1]) " +
                    "else return 0 end";
    Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(requestId));
    return "1".equals(result.toString());
}

2.3 代碼說明

acquireLock 方法：

通過 SET 命令實現(xiàn)鎖的獲取。
SET lockKey requestId NX EX expireTime 的意思是：如果lockKey 不存在，則將其設置為 requestId 并設置過期時間 expireTime。
返回值為 OK 表示加鎖成功，否則表示加鎖失敗。

releaseLock 方法：

使用 Lua 腳本來保證原子性，首先檢查鎖的值是否與請求的 requestId 匹配，只有匹配時才會刪除該鎖。

3. Redisson 實現(xiàn)分布式鎖

除了直接使用 Redis 命令外，還可以使用 Redisson，它是一個 Redis 的 Java 客戶端，提供了許多高級功能。

Redisson 提供了分布式鎖的便捷實現(xiàn)。

3.1 使用 Redisson 獲取鎖

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

import java.util.concurrent.TimeUnit;

public class RedissonLockExample {
    public static void main(String[] args) {
        // 創(chuàng)建 Redisson 客戶端
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);

        // 獲取分布式鎖
        RLock lock = redisson.getLock("myLock");

        try {
            // 嘗試加鎖，等待時間 100ms，持有鎖的時間 10 秒
            boolean isLocked = lock.tryLock(100, 10, TimeUnit.SECONDS);
            if (isLocked) {
                // 執(zhí)行加鎖后的業(yè)務邏輯
                System.out.println("Lock acquired, executing business logic...");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            // 釋放鎖
            lock.unlock();
            System.out.println("Lock released");
        }

        // 關閉客戶端
        redisson.shutdown();
    }
}