分布式锁，学习笔记

**分布式锁学习笔记**

**前言**

在分布式系统中，多个进程或线程可能会同时访问共享资源，从而导致数据不一致、冲突等问题。分布式锁是一种解决此类问题的机制，它允许一个进程或线程独占某个资源，直到它释放锁为止。在本文中，我们将介绍分布式锁的基本概念、实现方式以及常见的分布式锁算法。

**分布式锁的定义**

分布式锁是一种在分布式系统中使用的锁机制，它允许一个进程或线程独占某个资源，直到它释放锁为止。分布式锁通常用于保护共享资源，防止多个进程或线程同时访问同一资源，从而导致数据不一致、冲突等问题。

**分布式锁的特点**

1. **分布式**:分布式锁是设计用于分布式系统中的锁机制，它允许一个进程或线程在多台机器上独占某个资源。
2. **可重入**:分布式锁通常支持可重入性，即同一进程或线程可以多次获得同一锁，并且每次获得的锁都是独立的。
3. **排他性**:分布式锁具有排他性，即只有一个进程或线程可以持有某个锁。

**常见的分布式锁算法**

1. **Redlock算法**

Redlock是一种简单的分布式锁算法，它使用Redis作为存储器。Redlock通过在Redis中设置一个键来实现锁，键的过期时间决定了锁的有效期。如果多个进程或线程同时尝试获得同一锁，则只有一个进程或线程能够成功获得锁。

javapublic class Redlock {
 private static final String LOCK_KEY = "my_lock";
 private static final long EXPIRE_TIME =10000; //10秒 public static boolean acquireLock() {
 Jedis jedis = new Jedis("localhost",6379);
 try {
 String lockValue = jedis.set(LOCK_KEY, "locked", "NX", EXPIRE_TIME);
 if (lockValue != null) {
 return true;
 }
 } catch (Exception e) {
 // 处理异常 } finally {
 jedis.close();
 }
 return false;
 }

 public static void releaseLock() {
 Jedis jedis = new Jedis("localhost",6379);
 try {
 jedis.del(LOCK_KEY);
 } catch (Exception e) {
 // 处理异常 } finally {
 jedis.close();
 }
 }
}

javapublic class RedissonLock {
 private static final String LOCK_KEY = "my_lock";
 private static final long EXPIRE_TIME =10000; //10秒 public static boolean acquireLock(RedissonClient redisson) {
 RLock lock = redisson.getLock(LOCK_KEY);
 try {
 return lock.tryLock();
 } catch (Exception e) {
 // 处理异常 }
 return false;
 }

 public static void releaseLock(RedissonClient redisson) {
 RLock lock = redisson.getLock(LOCK_KEY);
 try {
 lock.unlock();
 } catch (Exception e) {
 // 处理异常 }
 }
}

javapublic class ZookeeperLock {
 private static final String LOCK_PATH = "/my_lock";

 public static boolean acquireLock(ZooKeeper zk) throws Exception {
 Stat stat = zk.exists(LOCK_PATH, false);
 if (stat != null) {
 return true;
 }
 zk.create(LOCK_PATH, new byte[0], Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL);
 return true;
 }

 public static void releaseLock(ZooKeeper zk) throws Exception {
 zk.delete(LOCK_PATH, -1);
 }
}