這篇文章主要介紹“如何使用redis+SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)測(cè)試”，在日常操作中，相信很多人在如何使用Redis+SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)測(cè)試問(wèn)題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”如何使用Redis+SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)測(cè)試”的疑惑有所幫助！接下來(lái)，請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧！

網(wǎng)站的建設(shè)創(chuàng)新互聯(lián)公司專注網(wǎng)站定制,經(jīng)驗(yàn)豐富,不做模板,主營(yíng)網(wǎng)站定制開(kāi)發(fā).小程序定制開(kāi)發(fā),H5頁(yè)面制作!給你煥然一新的設(shè)計(jì)體驗(yàn)!已為成都履帶攪拌車(chē)等企業(yè)提供專業(yè)服務(wù)。

Redis實(shí)現(xiàn)定時(shí)任務(wù)是基于對(duì)RedisKey值的監(jiān)控

具體代碼實(shí)現(xiàn)：

• 建一個(gè)SpringBoot項(xiàng)目

• 引入依賴

    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.4.4
         
    
    com.example
    redistask
    0.0.1-SNAPSHOT
    redistask
    Demo project for Spring Boot
    
        1.8
    
    
        
            org.springframework.boot
            spring-boot-starter-data-redis
        
        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    

• 配置文件

spring.redis.host=127.0.0.1spring.redis.port=6379spring.redis.timeout=10000

• 新建一個(gè)配置類

package com.zhouhong.redistask.redistaskconfig;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;/**
 * description: Redis配置類
 * @author: zhouhong
 * @version: V1.0.0
 * @date: 2021年3月19日 上午10:58:24 */@Configurationpublic class RedisTaskConfig {
    @Bean
    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {

        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);return container;
    }
}

• 新建Controller，設(shè)置不同過(guò)期時(shí)間的Key值，注意這里key值最好使用當(dāng)前的業(yè)務(wù)標(biāo)識(shí)做前綴，不然可能出現(xiàn)key重復(fù)的現(xiàn)象。

package com.zhouhong.redistask.redistaskcontroller;

import java.util.Date;
import java.util.concurrent.TimeUnit;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;/**
 * description: 測(cè)試Redis定時(shí)Controller類
 * @author: zhouhong
 * @version: V1.0.0
 * @date: 2021年3月19日 上午10:59:21 */@RestControllerpublic class RedisTaskController {

    @Autowiredprivate RedisTemplate< String, String> template;
    Logger logger = LogManager.getLogger(LogManager.ROOT_LOGGER_NAME);/**
     * 設(shè)置定時(shí)key，這里key最好使用業(yè)務(wù)前綴，防止名字相同
     * @return     */@RequestMapping(value =  "putkeys", method = RequestMethod.POST)public String putRedisTaskKeys() {
        Date date = new Date();
        logger.info("業(yè)務(wù)開(kāi)始時(shí)間：" + date);
        String key10S = "business1"+"|"+"key10S"+"|"+"其他業(yè)務(wù)中需要使用到的參數(shù)";
        String key20S = "business1"+"|"+"key20S"+"|"+"其他業(yè)務(wù)中需要使用到的參數(shù)";
        template.opsForValue().set(key10S, "values", 10, TimeUnit.SECONDS);
        template.opsForValue().set(key20S, "values", 20, TimeUnit.SECONDS);return "RedisKey過(guò)期鍵設(shè)置成功";
    }
    
}

• 新建Service用來(lái)監(jiān)控過(guò)期Key，并且針對(duì)不同時(shí)間做不同的業(yè)務(wù)

package com.zhouhong.redistask.service;

import java.util.Date;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.listener.KeyExpirationEventMessageListener;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;/**
 * description: RedisKey鍵監(jiān)聽(tīng)以及業(yè)務(wù)邏輯處理
 * @author: zhouhong
 * @version: V1.0.0
 * @date: 2021年3月19日 上午10:58:52 */@Service
@Componentpublic class RedisTaskService extends KeyExpirationEventMessageListener {

    Logger logger = LogManager.getLogger(LogManager.ROOT_LOGGER_NAME);/**
     * @param listenerContainer     */public RedisTaskService(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }
    @Overridepublic void onMessage(Message message, byte[] pattern) {
        String expiredKey = message.toString();    // 將拿到的過(guò)期鍵使用之前拼接時(shí)的特殊符號(hào)分割成字符數(shù)組String[] expiredKeyArr = expiredKey.split("\|");
        String businessSign = expiredKeyArr[0].toString();
        String expiredTimeSign = expiredKeyArr[1].toString();
        String othersParm = expiredKeyArr[2].toString();
        
        logger.info(businessSign + expiredTimeSign + othersParm);
        Date date = new Date();// 只有本業(yè)務(wù)才執(zhí)行以下操作if (businessSign.equals("business1")) {if (expiredTimeSign.equals("key10S")) {// 定時(shí)十秒鐘后業(yè)務(wù)處理logger.info("十秒鐘時(shí)的時(shí)間："+ date);
                logger.info("定時(shí)任務(wù)10秒鐘已到，下面處理相關(guān)業(yè)務(wù)邏輯代碼！??！");
                logger.info("10秒鐘后的業(yè)務(wù)邏輯代碼，其他業(yè)務(wù)參數(shù)" + othersParm);
            } else if (expiredTimeSign.equals("key20S")) {// 定時(shí)十秒鐘后業(yè)務(wù)處理logger.info("二十秒鐘時(shí)的時(shí)間："+ date);
                logger.info("定時(shí)任務(wù)20秒鐘已到，下面處理相關(guān)業(yè)務(wù)邏輯代碼?。?！");
                logger.info("20秒鐘后的業(yè)務(wù)邏輯代碼，其他業(yè)務(wù)參數(shù)" + othersParm);
            }
        } else {
            logger.error("非business1業(yè)務(wù)不做處理");
        }
    }
}

• 演示：

定時(shí)成功??！

到此，關(guān)于“如何使用Redis+SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)測(cè)試”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章！