redis解決高并發(fā)看門狗策略的實(shí)現(xiàn)

更新時(shí)間：2025年02月19日 08:27:36 作者：小湯猿人類

本文主要介紹了redis解決高并發(fā)看門狗策略的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

當(dāng)一個(gè)業(yè)務(wù)執(zhí)行時(shí)間超過(guò)自己設(shè)定的鎖釋放時(shí)間，那么會(huì)導(dǎo)致有其他線程進(jìn)入，從而搶到同一個(gè)票,所有需要使用看門狗策略，其實(shí)就是開一個(gè)守護(hù)線程，讓守護(hù)線程去監(jiān)控key，如果到時(shí)間了還未結(jié)束，就會(huì)將這個(gè)key重新set一次，重置到原來(lái)的時(shí)間，只要主線程未結(jié)束，守護(hù)線程就會(huì)一直存在，這里還是會(huì)有一些問(wèn)題，就是如果redis宕機(jī)了，導(dǎo)致第一個(gè)線程拿到了鎖，第二個(gè)線程也拿到了鎖，為了解決這個(gè)就需要引入紅鎖

1. 導(dǎo)入依賴，這里導(dǎo)入依賴可能會(huì)和原先的redis依賴沖突，所以只能留下一個(gè)，不然可能會(huì)出錯(cuò)

去除spring-boot-starter-data-redis

  <!-- 集成Redis-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

添加redisson

            <dependency>
                <groupId>org.redisson</groupId>
                <artifactId>redisson-spring-boot-starter</artifactId>
                <version>3.21.0</version>
            </dependency>

2. 修改配置文件,將之前的配置緩存redisson的

spring:
  data:
    redis: # redis配置
      url: redis://:127.0.0.1:6379

3. 開始分布式鎖-看門狗策略，找到高頻訪問(wèn)的業(yè)務(wù)添加以下代碼

在業(yè)務(wù)方法開始的頭添加

在方法末尾添加釋放鎖，別忘了添加try-catch-finally塊

這是一段完整的分布式處理,有需要直接copy后修改即可

  public void doConfirm(ConfirmOrderDoReq req) {
        String lockKey = DateUtil.formatDate(req.getDate()) + "-" + req.getTrainCode();
        RLock lock = null;
        try {
            lock = redissonClient.getLock(lockKey);

            boolean tryLock = lock.tryLock(0, TimeUnit.SECONDS);

            if (tryLock) {
                LOG.info("搶到鎖，開始處理訂單");
            } else {
                LOG.info("很遺憾，沒有搶到鎖");
                //當(dāng)前搶票人數(shù)多，請(qǐng)稍后再試
                throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);
            }
            //業(yè)務(wù)處理。。。。

        } catch (InterruptedException e) {
            LOG.error("搶票失敗", e);
            throw new BusinessException(BusinessExceptionEnum.CONFIRM_ORDER_LOCK_FAIL);
        } finally {
            LOG.info("鎖被釋放了");
            // 釋放鎖
            if (lock != null && lock.isHeldByCurrentThread()){
                lock.unlock();
            }
        }
    }

到此這篇關(guān)于redis解決高并發(fā)看門狗策略的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)redis 高并發(fā)看門狗策略內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: