Redisson初级原理 & Redisson主从一致性的原理

收心

发布于 2022-08-23 17:21:49

4080

发布于 2022-08-23 17:21:49

文章被收录于专栏：Java实战博客

参考于：https://www.bilibili.com/video/BV1cr4y1671t?p=67&share_source=copy_web&vd_source=164fe0eebbe1de2dc8ea1db9b173c783

这是常规Redisson使用代码

    @Autowired
    Redisson redisson;

    @Test
    public void Redisson入门Demo() {
        String lockKey = "自定义一个key(一般是用户Id锁自己的操作)";
        RLock redissonLock = redisson.getLock(lockKey);
        boolean doLockRes = redissonLock.tryLock();
        if (doLockRes) {
            try {
                // TODO 执行业务操作
            } finally {
                if (doLockRes) {
                    redissonLock.unlock();
                }
            }
        } else {
            System.out.println("加锁失败！");
        }
    }

idea查看trylock方法其是一个接口，我们去找具体实现RedisonLock类的发现其调用

    @Override
    public boolean tryLock() {
        return get(tryLockAsync());
    }

    <T> RFuture<T> tryLockInnerAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) {
        return evalWriteAsync(getRawName(), LongCodec.INSTANCE, command,
                "if (redis.call('exists', KEYS[1]) == 0) then " +
                        "redis.call('hincrby', KEYS[1], ARGV[2], 1); " +
                        "redis.call('pexpire', KEYS[1], ARGV[1]); " +
                        "return nil; " +
                        "end; " +
                        "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +
                        "redis.call('hincrby', KEYS[1], ARGV[2], 1); " +
                        "redis.call('pexpire', KEYS[1], ARGV[1]); " +
                        "return nil; " +
                        "end; " +
                        "return redis.call('pttl', KEYS[1]);",
                Collections.singletonList(getRawName()), unit.toMillis(leaseTime), getLockName(threadId));
    }

原码讲解：

KEYS[1]：Collections.singletonList(getRawName()) 是Redis中存的键名，不是key名。来自于redisson.getLock(lockKey)时指定的名字
ARGV[1]：unit.toMillis(leaseTime) 锁的持有时间
ARGV[2]：getLockName(threadId) key的名字
hincrby Redis的Hash的键自增
pexpire 设定过期时间

整体讲解

首先判断键不存在，直接指定为1，并加入过期时间，加锁成功，返回空
如果键存在且key等于1时，加锁成功，返回空
上述条件不满足，直接返回键的过期时间

上述就是lua的加锁脚本。再去看看释放锁的源码（也再RedisonLock类中）：

    protected RFuture<Boolean> unlockInnerAsync(long threadId) {
        return evalWriteAsync(getRawName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
                "if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then " +
                        "return nil;" +
                        "end; " +
                        "local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); " +
                        "if (counter > 0) then " +
                        "redis.call('pexpire', KEYS[1], ARGV[2]); " +
                        "return 0; " +
                        "else " +
                        "redis.call('del', KEYS[1]); " +
                        "redis.call('publish', KEYS[2], ARGV[1]); " +
                        "return 1; " +
                        "end; " +
                        "return nil;",
                Arrays.asList(getRawName(), getChannelName()), LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId));
    }

大致原理太多太复杂了，不搞了！