Spring Boot中的缓存预热机制

🏆本文收录于「滚雪球学SpringBoot」专栏，专业攻坚指数级提升持续更新中，up！up！up！！欢迎点赞&&收藏&&订阅。

@TOC

✨ 什么是缓存预热？

缓存预热 是指在应用启动或某些特定情况下，提前将常用数据加载到缓存中，以提升系统的性能和响应速度。通过缓存预热，可以避免在应用启动后，缓存为空而导致的多次数据库访问或高延迟问题。

在 Spring Boot 中，缓存预热通常结合 Spring Cache 或 Redis 等缓存技术实现，为服务提供更快的访问速度。

🌟 为什么需要缓存预热？

在实际开发中，未预热的缓存会导致以下问题：

1. 冷启动性能瓶颈：应用启动后，缓存为空，前几次用户请求直接访问数据库，性能较低。
2. 高并发场景的缓慢响应：初始缓存未命中时，多个请求直接打到数据库，可能引发数据库压力骤增。
3. 高频数据访问成本：一些高频访问的数据，如用户配置、热门商品，未提前加载到缓存会影响系统吞吐量。

通过缓存预热，提前将热点数据存入缓存中，可以显著优化应用的性能。

🧠 Spring Boot中缓存预热的常见实现方式

在 Spring Boot 中，缓存预热有多种实现方式，以下列出几种常见的实现：

1. 应用启动时加载数据

利用 Spring Boot 的事件机制，在应用启动时加载数据到缓存中。

代码实现：

import org.springframework.boot.ApplicationRunner;
import org.springframework.cache.CacheManager;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import java.util.Arrays;
import java.util.List;

@Component
public class CachePreheat {

    private final CacheManager cacheManager;

    public CachePreheat(CacheManager cacheManager) {
        this.cacheManager = cacheManager;
    }

    @Bean
    public ApplicationRunner preheatCacheRunner() {
        return args -> {
            System.out.println("开始缓存预热...");
            List<Integer> userIds = Arrays.asList(1, 2, 3, 4, 5);

            for (Integer userId : userIds) {
                // 模拟将用户数据加载到缓存
                cacheManager.getCache("userCache").put(userId, getUserFromDatabase(userId));
            }
            System.out.println("缓存预热完成!");
        };
    }

    private String getUserFromDatabase(Integer userId) {
        // 模拟数据库查询
        return "User-" + userId;
    }
}

关键点：

• 使用 ApplicationRunner 或 CommandLineRunner 接口，在 Spring 容器启动完成后触发缓存预热。
• 调用 CacheManager 的 getCache 方法，将数据手动加载到缓存中。

2. 通过@Cacheable预热缓存

结合 Spring Cache 的 @Cacheable 注解，提前触发缓存的加载。

步骤：

1. 标注需要缓存的方法。
2. 在应用启动时手动调用这些方法，触发缓存的写入。

代码实现：

import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

@Service
public class UserService {

    @Cacheable(value = "userCache", key = "#userId")
    public String getUserById(Integer userId) {
        System.out.println("从数据库加载用户数据，用户ID：" + userId);
        // 模拟数据库查询
        return "User-" + userId;
    }

    @PostConstruct
    public void preheatCache() {
        System.out.println("开始缓存预热...");
        for (int i = 1; i <= 5; i++) {
            getUserById(i); // 手动调用触发缓存
        }
        System.out.println("缓存预热完成!");
    }
}

关键点：

• 使用 @PostConstruct 注解在应用启动时调用缓存方法。
• @Cacheable 会自动将结果存入缓存中。

3. 基于定时任务的缓存预热

通过 Spring 的定时任务功能，定期触发缓存预热，适用于动态变化的数据。

代码实现：

import org.springframework.cache.CacheManager;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Arrays;
import java.util.List;

@Component
public class ScheduledCachePreheat {

    private final CacheManager cacheManager;

    public ScheduledCachePreheat(CacheManager cacheManager) {
        this.cacheManager = cacheManager;
    }

    @Scheduled(fixedRate = 60000) // 每60秒触发一次
    public void preheatCache() {
        System.out.println("定时任务 - 开始缓存预热...");
        List<Integer> productIds = Arrays.asList(101, 102, 103, 104, 105);

        for (Integer productId : productIds) {
            cacheManager.getCache("productCache").put(productId, getProductFromDatabase(productId));
        }
        System.out.println("定时任务 - 缓存预热完成!");
    }

    private String getProductFromDatabase(Integer productId) {
        // 模拟数据库查询
        return "Product-" + productId;
    }
}

关键点：

• 使用 @Scheduled 注解实现定时任务。
• 定时任务可确保缓存长期保持热点数据的可用性。

4. 结合消息队列的动态预热

通过消息队列（如 RabbitMQ、Kafka），在数据更新时动态触发缓存预热。

实现思路：

1. 数据变更时发送消息到队列。
2. 消费者监听队列并更新缓存。

代码示例：

import org.springframework.cache.CacheManager;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class CachePreheatListener {

    private final CacheManager cacheManager;

    public CachePreheatListener(CacheManager cacheManager) {
        this.cacheManager = cacheManager;
    }

    @KafkaListener(topics = "cache-preheat-topic", groupId = "cache-preheat-group")
    public void handleCachePreheatMessage(String productId) {
        System.out.println("收到缓存预热消息，商品ID：" + productId);
        cacheManager.getCache("productCache").put(productId, getProductFromDatabase(productId));
    }

    private String getProductFromDatabase(String productId) {
        // 模拟数据库查询
        return "Product-" + productId;
    }
}

关键点：

• 消息队列触发缓存更新，适用于分布式场景。
• 监听队列时，及时更新缓存内容。

🌐 缓存预热的最佳实践

1. 选择适合的预热触发机制：
   • 数据变化不频繁：应用启动时预热。
   • 数据动态变化：结合定时任务或消息队列。
2. 只加载热点数据：避免加载过多数据到缓存，浪费内存。
3. 设置合理的过期策略：缓存数据需设置过期时间，避免数据不一致问题。
4. 结合多级缓存：如本地缓存 + 分布式缓存（Redis）。

🖥️ 完整案例：Spring Boot 整合缓存预热与 Redis

依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>

Redis 配置：application.yml

spring:
  cache:
    type: redis
  redis:
    host: localhost
    port: 6379

代码实现：

import org.springframework.cache.annotation.Cacheable;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.util.HashMap;
import java.util.Map;

@Service
public class ProductService {

    private static final Map<Integer, String> database = new HashMap<>();

    static {
        database.put(1, "Product-A");
        database.put(2, "Product-B");
        database.put(3, "Product-C");
    }

    @Cacheable(value = "productCache", key = "#productId")
    public String getProductById(Integer productId) {
        System.out.println("从数据库加载商品数据，商品ID：" + productId);
        return database.get(productId);
    }

    @Scheduled(fixedRate = 60000) // 每60秒预热一次缓存
    public void preheatCache() {
        System.out.println("开始预热商品缓存...");
        database.keySet().forEach(this::getProductById);
        System.out.println("商品缓存预热完成!");
    }
}

✨ 结语

缓存预热是提升系统性能的重要手段，尤其在高并发和热点数据场景下，通过 Spring Boot 提供的灵活机制，可以轻松实现缓存的提前加载与动态更新。根据实际需求选择合适的预热方式，既能优化响应时间，又能有效减少数据库压力。

快去尝试在你的项目中实现缓存预热吧！🎉 有问题随时交流！👋

🧧福利赠与你🧧

  无论你是计算机专业的学生，还是对编程有兴趣的小伙伴，都建议直接毫无顾忌的学习此专栏「滚雪球学SpringBoot」，bug菌郑重承诺，凡是学习此专栏的同学，均能获取到所需的知识和技能，全网最快速入门SpringBoot，就像滚雪球一样，越滚越大， 无边无际，指数级提升。

最后，如果这篇文章对你有所帮助，帮忙给作者来个一键三连，关注、点赞、收藏，您的支持就是我坚持写作最大的动力。

同时欢迎大家关注公众号:「猿圈奇妙屋」 ，以便学习更多同类型的技术文章，免费白嫖最新BAT互联网公司面试题、4000G pdf电子书籍、简历模板、技术文章Markdown文档等海量资料。

✨️ Who am I?

我是bug菌，CSDN | 掘金 | InfoQ | 51CTO | 华为云 | 阿里云 | 腾讯云 等社区博客专家，C站博客之星Top30，华为云2023年度十佳博主，掘金多年度人气作者Top40，掘金等各大社区平台签约作者，51CTO年度博主Top12，掘金/InfoQ/51CTO等社区优质创作者；全网粉丝合计 30w+；更多精彩福利点击这里；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试真题、4000G PDF电子书籍、简历模板等海量资料，你想要的我都有，关键是你不来拿。

-End-