Watch Dog是指在分布式锁的持有时间内，定期自动延长锁的持有时间，以防止锁因超时而被提前释放。这种机制适用于需要长时间持有锁的场景，确保锁不会因为意外的超时而被其他客户端获取。
自动续期机制的工作原理初始获取锁：
客户端尝试获取锁，并指定一个初始的锁持有时间（例如 30 秒）。启动 Watch Dog：
一旦成功获取锁，客户端会启动一个后台任务（通常是一个定时器或线程），定期检查锁的状态。定期续期：
定时任务每隔一段时间（例如 10 秒）检查锁是否仍然有效。如果锁仍然有效，它会自动延长锁的持有时间（例如再延长 30 秒）。释放锁：
当客户端完成需要锁定的操作后，手动释放锁。如果客户端在操作过程中发生异常或崩溃，Watch Dog 也会在锁的持有时间结束后自动释放锁。 示例代码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 DistributedLockWithWatchDog {
private static final RedissonClient redissonClient = createRedissonClient();
private static RedissonClient createRedissonClient() {
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
return Redisson.create(config);
}
public static void main(String[] args) {
String lockKey = "myLock";
RLock lock = redissonClient.getLock(lockKey);
try {
boolean lockAcquired = lock.tryLock(5, 30, TimeUnit.SECONDS);
if (lockAcquired) {
try {
System.out.println("Lock acquired, performing operations...");
Thread.sleep(40000);
} finally {
lock.unlock();
System.out.println("Lock released");
}
} else {
System.out.println("Failed to acquire lock");
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
System.out.println("Thread interrupted");
}
}
}
详细解释创建 Redisson 客户端：创建一个 Redisson 客户端，连接到 Redis 服务器。
private static final RedissonClient redissonClient = createRedissonClient();
private static RedissonClient createRedissonClient() {
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
return Redisson.create(config);
}
获取锁RLock lock = redissonClient.getLock(lockKey);
获取一个分布式锁对象 RLock。
3.尝试获取锁
boolean lockAcquired = lock.tryLock(5, 30, TimeUnit.SECONDS);
尝试在 5 秒内获取锁，锁的初始持有时间为 30 秒。
4. 执行操作：
if (lockAcquired) {
try {
System.out.println("Lock acquired, performing operations...");
Thread.sleep(40000);
} finally {
lock.unlock();
System.out.println("Lock released");
}
} else {
System.out.println("Failed to acquire lock");
}
如果成功获取锁，执行需要锁定的操作。使用 Thread.sleep(40000) 模拟一个长时间的操作。完成操作后，手动释放锁。 自动续期机制示例中，Redisson 客户端会自动启动一个 Watch Dog 机制，每隔一段时间（通常是锁持有时间的三分之一）检查锁的状态并自动续期。例如，如果锁的初始持有时间是 30 秒，Watch Dog 会每隔 10 秒检查一次锁的状态，并自动延长锁的持有时间。
优点 防止锁超时：在长时间操作中，防止锁因超时而被提前释放。自动管理：客户端无需手动管理锁的续期，由框架自动处理。可靠性：即使客户端在操作过程中发生异常或崩溃，锁也会在持有时间结束后自动释放，避免死锁。 注意事项 资源消耗：自动续期机制会增加一定的资源消耗，特别是在高并发场景下。配置合理：合理配置锁的初始持有时间和续期间隔，避免不必要的资源浪费。通过这种方式可以确保在长时间操作中，锁不会因超时而被提前释放，从而提高系统的可靠性和稳定性。
