快捷導(dǎo)航

SpringBoot?緩存預(yù)熱的實(shí)現(xiàn)

更新時(shí)間：2024年04月01日 16:20:45 作者：尼古拉斯的夜

本文主要介紹了SpringBoot?緩存預(yù)熱的實(shí)現(xiàn)，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

簡(jiǎn)介：

SpringBoot集合RedisUtil和 CommadnLinRunner實(shí)現(xiàn)緩存預(yù)熱

一、新建一個(gè)緩存抽象類

在redis模塊里面新建

/**
 * 緩存抽象類
 */
@Component
public abstract class AbstractCache {

    // 初始化緩存
    public void initCache() {

    }

    public <T> T getCache(String key) {
        return null;
    }

    // 清除緩存
    public void clearCache() {

    }

    // 加載緩存
    public void reloadCache() {
        clearCache();
        initCache();
    }
}

二、新建一個(gè)組件

項(xiàng)目啟動(dòng)之前，預(yù)先加載數(shù)據(jù)。比如，權(quán)限容器、特殊用戶數(shù)據(jù)等。通常我們可以使用監(jiān)聽器、事件來(lái)操作。但是，springboot提供了一個(gè)簡(jiǎn)單的方式來(lái)實(shí)現(xiàn)此類需求，即，CommandLineRunner。

這是一個(gè)接口，用戶可以自定義實(shí)現(xiàn)該接口，具體實(shí)現(xiàn)run方法

任何在上下文容器之內(nèi)的bean都可以實(shí)現(xiàn)run方法

如果在上下文中，存在多個(gè)該接口實(shí)現(xiàn)類，可以通過@order注解，指定加載順序

@Component
public class InitCache implements CommandLineRunner {

    @Override
    public void run(String... args) throws Exception {
        // 獲取Springshang上下文對(duì)象
        ApplicationContext applicationContext = SpringContextUtil.getApplicationContext();

        // 獲取目標(biāo)接口下的所有實(shí)現(xiàn)類
        Map<String, AbstractCache> beanMap = applicationContext.getBeansOfType(AbstractCache.class);

        // 調(diào)用init方法
        if (beanMap.isEmpty()) {
            return;
        }

        for (Map.Entry<String, AbstractCache> entry : beanMap.entrySet()) {
            // 通過ApplicationContext的getBean方法來(lái)獲取Spring容器中已初始化的bean
            AbstractCache abstractCache = (AbstractCache) SpringContextUtil.getBean(entry.getValue().getClass());
            // 緩存實(shí)現(xiàn)類 調(diào)用緩存初始方法
            abstractCache.initCache();
        }
    }

}

三、準(zhǔn)備工具類

3.1 RedisUtil

/**
 *  Redis工具類
 */
@Component
public class RedisUtil {

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * 存儲(chǔ) key value
     * @param key
     * @param value
     */
    public void set(String key, String value) {
        redisTemplate.opsForValue().set(key, value);
    }

    /**
     * 判斷是否存在 key
     * @param key
     * @return
     */
    public Boolean hasKey(String key){
        return redisTemplate.hasKey(key);
    }
}

3.2 SpringContextUtil

/**
 *  Spring 容器工具類
 */
@Component
public class SpringContextUtil implements ApplicationContextAware {

    private static ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }

    // 靜態(tài)方法 提供Spring 上下文對(duì)象
    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }

    // 通過ApplicationContext的getBean方法來(lái)獲取Spring容器中已初始化的bean
    public static Object getBean(Class type) {
        return applicationContext.getBean(type);

    }
}

四、新建緩存實(shí)現(xiàn)類

在用戶模塊新建3個(gè)實(shí)現(xiàn)類

4.1 ClassCache

/**
 * 班級(jí)緩存
 */
@Component
public class ClassCache extends AbstractCache {

    @Autowired
    private RedisUtil redisUtil;

    private static final String CLASS_CACHE_KEY = "CLASS";

    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void initCache() {
        redisUtil.set("classId", "一年級(jí)一班");
    }

    @Override
    public <T> T getCache(String key) {
        if (!redisTemplate.hasKey(key).booleanValue()) {
            reloadCache();
        }
        return (T) redisTemplate.opsForValue().get(key);
    }

    @Override
    public void clearCache() {
        redisTemplate.delete(CLASS_CACHE_KEY);
    }


}

4.2 SubjectCache

/**
 *  學(xué)科緩存
 */
@Component
public class SubjectCache extends AbstractCache {

    @Autowired
    private RedisUtil redisUtil;

    private static final String SUBJECT_CACHE_KEY = "SUBJECT";

    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void initCache() {
        redisUtil.set("目錄", "化學(xué)");
    }

    @Override
    public <T> T getCache(String key) {
        if (!redisTemplate.hasKey(key).booleanValue()) {
            reloadCache();
        }
        return (T) redisTemplate.opsForValue().get(key);
    }

    @Override
    public void clearCache() {
        redisTemplate.delete(SUBJECT_CACHE_KEY);
    }

}

4.3 SysUserCache

/**
 * 學(xué)生緩存
 */
@Component
public class SysUserCache extends AbstractCache {

    @Autowired
    private RedisUtil redisUtil;

    private static final String SYS_USER_CACHE_KEY = "SYS_USER";

    @Autowired
    private RedisTemplate redisTemplate;

    @Override
    public void initCache() {
        redisUtil.set("name", "杰克");
    }

    @Override
    public <T> T getCache(String key) {
        if (!redisTemplate.hasKey(key).booleanValue()) {
            reloadCache();
        }
        return (T) redisTemplate.opsForValue().get(key);
    }

    @Override
    public void clearCache() {
        redisTemplate.delete(SYS_USER_CACHE_KEY);
    }


}