«

redisson特性如何实现

时间:2024-4-5 09:13     作者:韩俊     分类: Mysql


这篇文章主要介绍“redisson特性如何实现”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“redisson特性如何实现”文章能帮助大家解决问题。

    redisson的几大特性

    相信看了这个标题的同学,对这个问题以已经非常不陌生了,信手拈来redisson的几大特性:

    可重入性

    【多个业务线同一时刻n条扣款,如果用setnx,我怎么监控的加锁解锁线程?死锁不得发生呐?】

    redisson使用hash结构,业务名称作为key,uuid+线程id作为field,加锁次数作为value,这不就解决上述问题了吗

    阻塞能力

    【加锁有两个策略,一是互斥,二是阻塞。互斥比如说定时任务,同一时刻我需要只执行一次就行。阻塞的话-例如多个业务线同一时刻n条扣款,我不能互斥掉吧,那不得被喷死。我得写个while死循环【标准用语就是自旋】一段时间在获取一次,保证系统都能处理这些请求】

    续约

    加锁过期时间短-加锁逻辑还没执行完就解锁了是不是很尴尬,过长的话-宕机恢复时间又变长

    redisson默认30秒给你执行,30秒没执行完就续约30s,宕机的话恢复时间也不会太长。

    原理呢就是使用了netty的时间轮实现。简单点说就是环形数组。

    直通车:

    RedissonLock --> renewExpiration -->TimerTask
    Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
        @Override
        public void run(Timeout timeout) throws Exception {
            ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName());
            if (ent == null) {
                return;
            }
            Long threadId = ent.getFirstThreadId();
            if (threadId == null) {
                return;
            }
            RFuture<Boolean> future = renewExpirationAsync(threadId);
            future.onComplete((res, e) -> {
                if (e != null) {
                    log.error("Can't update lock " + getName() + " expiration", e);
                    return;
                }
                if (res) {
                    // reschedule itself
                    renewExpiration();
                }
            });
        }
    }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS);
    // internalLockLeaseTime默认30s,因此这里默认延迟10s后执行
    // 其中TimerTask引用的就是netty中的TimerTask

    初始化timer的代码

    protected void initTimer(MasterSlaveServersConfig config) {
        int[] timeouts = new int[]{config.getRetryInterval(), config.getTimeout()};
        Arrays.sort(timeouts);
        int minTimeout = timeouts[0];
        if (minTimeout % 100 != 0) {
            minTimeout = (minTimeout % 100) / 2;
        } else if (minTimeout == 100) {
            minTimeout = 50;
        } else {
            minTimeout = 100;
        }
        // 就是分成了1024个格子,每个格子默认100ms
        timer = new HashedWheelTimer(new DefaultThreadFactory("redisson-timer"), minTimeout, TimeUnit.MILLISECONDS, 1024, false);
        connectionWatcher = new IdleConnectionWatcher(this, config);
        subscribeService = new PublishSubscribeService(this, config);
    }

    大白话讲就是:例如将一个圆分成4等分,1,2,3,4,从1到2需要100ms,那么我需要计算延迟500ms需要走几步,下标是多少?

    既然是时间总要跳动嘛,没猜错就是sleep????

    • 红锁

    如果redis节点宕机大部分节点同意获取锁,才能获取到锁。

    • 联锁

    全部节点加锁成功才算加锁成功。

    • 加锁流程

    lua判断锁是否存在

    --> 不存在创建hash,当前业务key,uuid+线程id为field,value =1 ,设置过期时间并返回

    --> 存在检查uuid+线程id是否一致,一致递增value更新过期时间返回。存在锁检查uuid+线程id不一致,判断是否到期,没到期我就帮你续期,自己加锁也没有成功,就以当前业务key发布消息订阅pubsub,等收到解锁消息在重试

    • 解锁逻辑

    lua判断锁是否存在

    -->不存在则直接发布解锁消息并返回

    -->存在就检查uuid+线程id是否一致,不一致就报错,因为加锁线程不一致。如果一致,就递减value,判断是否大于0,如果等于0,删除key并发布解锁消息

    标签: mysql redis

    热门推荐