快捷導(dǎo)航

Java分布式鎖實現(xiàn)方式詳解

更新時間：2025年11月11日 10:18:03 作者：MadeInSQL

本文詳細介紹了Java分布式鎖的概念、實現(xiàn)方式、關(guān)鍵問題、最佳實踐及常見問題與解決方案,感興趣的朋友跟隨小編一起看看吧

Java分布式鎖詳解

1. 分布式鎖的概念

分布式鎖是一種在分布式系統(tǒng)中協(xié)調(diào)多個進程/服務(wù)對共享資源進行互斥訪問的機制。在單機系統(tǒng)中，我們可以使用Java內(nèi)置的鎖機制（如synchronized、ReentrantLock）來實現(xiàn)線程同步，但在分布式環(huán)境下，這些本地鎖機制無法跨JVM工作，因此需要分布式鎖。

典型應(yīng)用場景包括：

防止重復(fù)訂單提交
秒殺系統(tǒng)中的庫存扣減
定時任務(wù)的分布式調(diào)度
分布式環(huán)境下的緩存更新

2. 分布式鎖的實現(xiàn)方式

2.1 基于數(shù)據(jù)庫的實現(xiàn)

實現(xiàn)原理：利用數(shù)據(jù)庫的唯一性約束或行鎖特性實現(xiàn)分布式鎖。常見方式包括：

創(chuàng)建鎖表，利用唯一索引防止重復(fù)獲取鎖
使用SELECT ... FOR UPDATE語句鎖定記錄

示例代碼：

// 基于MySQL實現(xiàn)的分布式鎖
public class DatabaseDistributedLock {
    private DataSource dataSource;
    public boolean tryLock(String lockName, long timeout) {
        try (Connection conn = dataSource.getConnection()) {
            conn.setAutoCommit(false);
            // 使用FOR UPDATE加行鎖
            PreparedStatement stmt = conn.prepareStatement(
                "SELECT * FROM distributed_lock WHERE lock_name = ? FOR UPDATE");
            stmt.setString(1, lockName);
            ResultSet rs = stmt.executeQuery();
            if (!rs.next()) {
                // 鎖不存在則插入
                PreparedStatement insertStmt = conn.prepareStatement(
                    "INSERT INTO distributed_lock(lock_name, owner, create_time) VALUES (?, ?, ?)");
                insertStmt.setString(1, lockName);
                insertStmt.setString(2, Thread.currentThread().getName());
                insertStmt.setTimestamp(3, new Timestamp(System.currentTimeMillis()));
                insertStmt.executeUpdate();
            }
            conn.commit();
            return true;
        } catch (SQLException e) {
            return false;
        }
    }
}

優(yōu)缺點：

優(yōu)點：實現(xiàn)簡單，無需額外中間件
缺點：性能較差（數(shù)據(jù)庫I/O開銷大），非阻塞鎖實現(xiàn)復(fù)雜，存在單點故障風(fēng)險

2.2 基于Redis的實現(xiàn)

實現(xiàn)原理：利用Redis的SETNX（SET if Not eXists）命令實現(xiàn)互斥性，通過設(shè)置過期時間防止死鎖。

RedLock算法（Redis官方推薦的分布式鎖實現(xiàn)）：

獲取當(dāng)前時間（毫秒）
依次嘗試從N個獨立的Redis節(jié)點獲取鎖
計算獲取鎖消耗的總時間（小于鎖超時時間）且獲取到大多數(shù)節(jié)點（N/2+1）的鎖才算成功
鎖的實際有效時間 = 初始有效時間 - 獲取鎖消耗的時間
如果獲取鎖失敗，則向所有節(jié)點發(fā)送釋放鎖命令

示例代碼（使用Redisson客戶端）：

// 使用Redisson實現(xiàn)分布式鎖
public class RedisDistributedLockExample {
    public void doWithLock() {
        Config config = new Config();
        config.useSingleServer().setAddress("redis://127.0.0.1:6379");
        RedissonClient redisson = Redisson.create(config);
        RLock lock = redisson.getLock("myLock");
        try {
            // 嘗試獲取鎖，最多等待100秒，鎖定后10秒自動釋放
            boolean isLocked = lock.tryLock(100, 10, TimeUnit.SECONDS);
            if (isLocked) {
                // 執(zhí)行業(yè)務(wù)邏輯
                System.out.println("Lock acquired, doing business logic...");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            lock.unlock();
            redisson.shutdown();
        }
    }
}

Redis分布式鎖的關(guān)鍵問題：

原子性：使用Lua腳本確保SETNX和EXPIRE操作的原子性
鎖續(xù)期：通過守護線程定期檢查并延長鎖的有效期
鎖釋放：確保只有鎖的持有者才能釋放鎖（value中存儲唯一標識）
集群容錯：主從切換可能導(dǎo)致鎖丟失，RedLock算法提供了一定解決方案

2.3 基于Zookeeper的實現(xiàn)

實現(xiàn)原理：利用Zookeeper的臨時順序節(jié)點和Watch機制實現(xiàn)分布式鎖。

實現(xiàn)步驟：

在指定路徑下創(chuàng)建臨時順序節(jié)點
獲取父節(jié)點下的所有子節(jié)點并排序
判斷當(dāng)前節(jié)點是否為序號最小的節(jié)點：
- 是則獲取鎖成功
- 否則對前一個節(jié)點注冊Watcher
鎖釋放后，Zookeeper會通知下一個等待的節(jié)點

示例代碼（使用Curator框架）：

public class ZookeeperDistributedLock {
    private CuratorFramework client;
    private InterProcessMutex lock;
    public ZookeeperDistributedLock(String connectString, String lockPath) {
        RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
        client = CuratorFrameworkFactory.newClient(connectString, retryPolicy);
        client.start();
        lock = new InterProcessMutex(client, lockPath);
    }
    public void doWithLock(Runnable task) throws Exception {
        try {
            // 獲取鎖，最多等待5秒
            if (lock.acquire(5, TimeUnit.SECONDS)) {
                task.run();
            }
        } finally {
            if (lock.isAcquiredInThisProcess()) {
                lock.release();
            }
        }
    }
}

Zookeeper鎖的特點：