SpringBoot 缓存预热的实现

更新时间：2024年04月01日 16:20:45 作者：尼古拉斯的夜

本文主要介绍了SpringBoot 缓存预热的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

简介：

SpringBoot集合RedisUtil和 CommadnLinRunner实现缓存预热

一、新建一个缓存抽象类

在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();
    }
}

二、新建一个组件

项目启动之前，预先加载数据。比如，权限容器、特殊用户数据等。通常我们可以使用监听器、事件来操作。但是，springboot提供了一个简单的方式来实现此类需求，即，CommandLineRunner。

这是一个接口，用户可以自定义实现该接口，具体实现run方法

任何在上下文容器之内的bean都可以实现run方法

如果在上下文中，存在多个该接口实现类，可以通过@order注解，指定加载顺序

@Component
public class InitCache implements CommandLineRunner {

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

        // 获取目标接口下的所有实现类
        Map<String, AbstractCache> beanMap = applicationContext.getBeansOfType(AbstractCache.class);

        // 调用init方法
        if (beanMap.isEmpty()) {
            return;
        }

        for (Map.Entry<String, AbstractCache> entry : beanMap.entrySet()) {
            // 通过ApplicationContext的getBean方法来获取Spring容器中已初始化的bean
            AbstractCache abstractCache = (AbstractCache) SpringContextUtil.getBean(entry.getValue().getClass());
            // 缓存实现类 调用缓存初始方法
            abstractCache.initCache();
        }
    }

}

三、准备工具类

3.1 RedisUtil

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

    @Autowired
    private RedisTemplate redisTemplate;

    /**
     * 存储 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;
    }

    // 静态方法 提供Spring 上下文对象
    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }

    // 通过ApplicationContext的getBean方法来获取Spring容器中已初始化的bean
    public static Object getBean(Class type) {
        return applicationContext.getBean(type);

    }
}

四、新建缓存实现类

在用户模块新建3个实现类

4.1 ClassCache

/**
 * 班级缓存
 */
@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", "一年级一班");
    }

    @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

/**
 *  学科缓存
 */
@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("目录", "化学");
    }

    @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

/**
 * 学生缓存
 */
@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);
    }


}

五、测试

到此这篇关于SpringBoot 缓存预热的实现的文章就介绍到这了,更多相关SpringBoot 缓存预热内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

SpringBoot配置连接两个或多个数据库的实现
本文主要介绍了SpringBoot配置连接两个或多个数据库的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-05-05
Java中父类Object的常用方法总结
这篇文章给大家介绍了Java中父类Object的三个常用方法，对大家学习或使用Java具有一定的参考借鉴价值，有需要的朋友们下面来一起看看吧。
2016-09-09
java启动参数之谜的排查过程
在日常操作中,相信很多人对Java启动参数存在疑惑,下面这篇文章主要给大家介绍了关于java启动参数之谜的排查过程,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-06-06
解读java try catch 异常后还会继续执行吗
这篇文章主要介绍了解读java try catch 异常后还会不会继续执行问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-11-11
Java中使用COS实现文件上传功能
cos是O'Rrilly公司开发的一款用于HTTP上传文件的OpenSource组件。下面通过本文给大家分享使用COS实现文件上传功能，感兴趣的朋友一起看看吧
2017-08-08
Mybatis的dao层,service层的封装方式
这篇文章主要介绍了Mybatis的dao层,service层的封装方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-07-07
springboot用户数据修改的详细实现
用户管理功能作为所有的系统是必不可少的一部分,下面这篇文章主要给大家介绍了关于springboot用户数据修改的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
2022-04-04
SpringMVC核心技术
这篇文章主要介绍了SpringMVC入门实例，在springmvc入门教程里算是比较不错的，结构也比较完整，需要的朋友可以参考。希望可以帮助到你
2021-07-07
Java中CAS机制实现方法详解
传统的并发控制手段如synchronized和ReentrantLock虽有效防止资源竞争,却可能引起性能开销,相比之下,CAS（CompareAndSwap）提供一种轻量级的乐观锁策略,通过硬件级别的原子指令实现无锁并发,提高性能,需要的朋友可以参考下
2024-09-09
深入探讨Java多线程中的volatile变量
这篇文章主要为大家详细并深入的探讨Java多线程中的volatile变量，volatile用来确保将变量的更新操作通知到其他线程,保证了新值能立即同步到主内存,以及每次使用前立即从主内存刷新，感兴趣的小伙伴们可以参考一下
2016-02-02