Redission 实现的分布式锁

Question

Redission 实现的分布式锁中org.redisson.RedissonLock#tryLock(long, long, java.util.concurrent.TimeUnit)方法中有发布订阅的相关功能，调试的时候无法进入。想知道什么场景才会进入订阅的监听逻辑，该如何调试？

Answer 1

以下回复参考：皆我百晓生、券券喵儿等免费微信小程序作答:

Redission 实现的分布式锁中的 tryLock 方法确实包含了发布订阅的功能，但只有在使用 RLock 或 ReentrantReadWriteLock 时才会触发。当你调用 tryLock 方法并传入一个非零的等待时间和时间单位时，Redission 会尝试获取锁。如果锁被其他线程持有，它会进入等待状态，并在等待时间结束后自动解锁。在这个过程中，Redission 会订阅一个特定的频道，以便在锁被释放时收到通知。

要调试进入订阅监听逻辑的场景，你需要确保以下几点：

1. 使用 RLock 或 ReentrantReadWriteLock 而不是其他类型的锁。
2. 调用 tryLock 方法时，传入一个非零的等待时间和时间单位。
3. 确保有其他线程持有锁，以便触发订阅逻辑。

要调试订阅监听逻辑，你可以使用以下方法：

1. 在你的代码中添加日志记录，以便在订阅和取消订阅事件发生时输出相关信息。例如：

import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class RedissonLockDemo {
    private static final Logger logger = LoggerFactory.getLogger(RedissonLockDemo.class);

    public static void main(String[] args) {
        RedissonClient redisson = ...; // 初始化 RedissonClient
        RLock lock = redisson.getLock("myLock");

        try {
            // 尝试获取锁，等待时间为5秒
            if (lock.tryLock(5, TimeUnit.SECONDS)) {
                try {
                    // 执行业务逻辑
                } finally {
                    lock.unlock();
                }
            } else {
                logger.info("Failed to acquire lock");
            }
        } catch (InterruptedException e) {
            logger.error("Interrupted while trying to acquire lock", e);
        } finally {
            redisson.shutdown();
        }
    }
}

1. 使用 Redisson 提供的监控功能，如 org.redisson.monitor.MonitorService，来查看订阅和发布的情况。你可以在 Redisson 配置中启用监控服务，然后通过 Web UI 或其他方式查看锁的状态和订阅信息。

2. 使用 Redis 客户端工具（如 Redis CLI、RedisDesktopManager 等）手动订阅和发布消息，以验证订阅和发布是否正常工作。例如，你可以在另一个终端中使用以下命令订阅锁的通知：

redis-cli --subscribe "lock:myLock"

当锁被释放时，你应该能看到类似以下的输出：

Message "lock:myLock" published to channel "lock:myLock" by connection from 127.0.0.1:6379