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

参考于：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));
    }

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

反正整体来看的原理就是

• 重入性：记录线程id与重入次数
• 重试性：利用Redis的Pub/Sub 实现等待、唤醒、获取锁失败的重试机制

Redisson的解决Redis集群的主从一致性原理

Redis主从在切换时，会导致数据不一致。如果在切换异常期间就会导致解锁失败等情况。

Redisson解决办法时MuiltLock。就是向所有节点加锁，当所有节点锁加成功后，才算加锁成功！避免了数据不一致性！