SpringBoot啟動時將數(shù)據(jù)庫數(shù)據(jù)預加載到Redis緩存的幾種實現(xiàn)方案
更新時間：2025年09月29日 09:32:37 作者：塔中妖
在實際項目開發(fā)中,我們經(jīng)常需要在應用啟動時將一些固定的、頻繁訪問的數(shù)據(jù)從數(shù)據(jù)庫預加載到 Redis 緩存中,以提高系統(tǒng)性能,本文將介紹幾種實現(xiàn)方案,需要的朋友可以參考下
引言
在實際項目開發(fā)中，我們經(jīng)常需要在應用啟動時將一些固定的、頻繁訪問的數(shù)據(jù)從數(shù)據(jù)庫預加載到 Redis 緩存中，以提高系統(tǒng)性能。本文將介紹幾種實現(xiàn)方案。
方案一：使用 @PostConstruct 注解
這是最簡單直接的方式，在 Spring Bean 初始化完成后執(zhí)行預加載邏輯。
@Component
@Slf4j
public class CachePreloader {
@Autowired
private UserService userService;
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@PostConstruct
public void preloadCache() {
log.info("開始預加載緩存數(shù)據(jù)...");
try {
// 加載用戶基礎信息
List<User> users = userService.getAllActiveUsers();
for (User user : users) {
String key = "user:" + user.getId();
redisTemplate.opsForValue().set(key, user, Duration.ofHours(24));
}
// 加載系統(tǒng)配置
List<SystemConfig> configs = systemConfigService.getAllConfigs();
for (SystemConfig config : configs) {
String key = "config:" + config.getKey();
redisTemplate.opsForValue().set(key, config.getValue(), Duration.ofDays(7));
}
log.info("緩存預加載完成，共加載 {} 條用戶數(shù)據(jù)，{} 條配置數(shù)據(jù)",
users.size(), configs.size());
} catch (Exception e) {
log.error("緩存預加載失敗", e);
}
}
}
方案二：實現(xiàn) ApplicationRunner 接口
ApplicationRunner 在應用啟動完成后執(zhí)行，可以獲取命令行參數(shù)，更適合復雜的初始化邏輯。
@Component
@Order(1) // 設置執(zhí)行順序
@Slf4j
public class CacheApplicationRunner implements ApplicationRunner {
@Autowired
private DataPreloadService dataPreloadService;
@Override
public void run(ApplicationArguments args) throws Exception {
log.info("ApplicationRunner 開始執(zhí)行緩存預加載...");
// 檢查是否需要預加載
if (args.containsOption("skip-cache-preload")) {
log.info("跳過緩存預加載");
return;
}
dataPreloadService.preloadAllCache();
log.info("ApplicationRunner 緩存預加載完成");
}
}
方案三：監(jiān)聽 ApplicationReadyEvent 事件
這種方式在應用完全啟動就緒后執(zhí)行，是最安全的預加載時機。
@Component
@Slf4j
public class CacheEventListener {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Autowired
private ProductService productService;
@EventListener
public void handleApplicationReady(ApplicationReadyEvent event) {
log.info("應用啟動完成，開始預加載緩存...");
// 異步執(zhí)行預加載，避免阻塞啟動
CompletableFuture.runAsync(() -> {
try {
preloadProductCache();
preloadCategoryCache();
} catch (Exception e) {
log.error("異步預加載緩存失敗", e);
}
});
}
private void preloadProductCache() {
List<Product> hotProducts = productService.getHotProducts();
hotProducts.forEach(product -> {
String key = "hot_product:" + product.getId();
redisTemplate.opsForValue().set(key, product, Duration.ofHours(12));
});
log.info("熱門商品緩存預加載完成，共 {} 條", hotProducts.size());
}
private void preloadCategoryCache() {
List<Category> categories = productService.getAllCategories();
redisTemplate.opsForValue().set("all_categories", categories, Duration.ofDays(1));
log.info("商品分類緩存預加載完成");
}
}
方案四：創(chuàng)建專門的預加載服務
將預加載邏輯封裝成獨立的服務，便于管理和測試。
@Service
@Slf4j
public class DataPreloadService {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
@Autowired
private DictService dictService;
@Autowired
private RegionService regionService;
/**
* 預加載所有緩存數(shù)據(jù)
*/
public void preloadAllCache() {
long startTime = System.currentTimeMillis();
try {
// 并行加載多種數(shù)據(jù)
CompletableFuture<Void> dictFuture = CompletableFuture.runAsync(this::preloadDictCache);
CompletableFuture<Void> regionFuture = CompletableFuture.runAsync(this::preloadRegionCache);
// 等待所有任務完成
CompletableFuture.allOf(dictFuture, regionFuture).join();
long endTime = System.currentTimeMillis();
log.info("所有緩存預加載完成，耗時: {} ms", endTime - startTime);
} catch (Exception e) {
log.error("緩存預加載過程中發(fā)生異常", e);
}
}
/**
* 預加載數(shù)據(jù)字典
*/
private void preloadDictCache() {
try {
Map<String, List<DictItem>> dictMap = dictService.getAllDictItems();
dictMap.forEach((dictType, items) -> {
String key = "dict:" + dictType;
redisTemplate.opsForValue().set(key, items, Duration.ofDays(30));
});
log.info("數(shù)據(jù)字典緩存預加載完成，共 {} 種類型", dictMap.size());
} catch (Exception e) {
log.error("數(shù)據(jù)字典緩存預加載失敗", e);
}
}
/**
* 預加載地區(qū)數(shù)據(jù)
*/
private void preloadRegionCache() {
try {
List<Region> regions = regionService.getAllRegions();
redisTemplate.opsForValue().set("all_regions", regions, Duration.ofDays(30));
// 按層級緩存
Map<Integer, List<Region>> regionsByLevel = regions.stream()
.collect(Collectors.groupingBy(Region::getLevel));
regionsByLevel.forEach((level, levelRegions) -> {
String key = "regions_level:" + level;
redisTemplate.opsForValue().set(key, levelRegions, Duration.ofDays(30));
});
log.info("地區(qū)數(shù)據(jù)緩存預加載完成，共 {} 條記錄", regions.size());
} catch (Exception e) {
log.error("地區(qū)數(shù)據(jù)緩存預加載失敗", e);
}
}
}
配置文件控制
在 application.yml 中添加配置項，控制預加載行為：
app:
cache:
preload:
enabled: true
async: true
timeout: 30000 # 超時時間(毫秒)
batch-size: 1000 # 批處理大小
對應的配置類：
@ConfigurationProperties(prefix = "app.cache.preload")
@Data
public class CachePreloadProperties {
private boolean enabled = true;
private boolean async = true;
private long timeout = 30000;
private int batchSize = 1000;
}
最佳實踐建議
1. 異常處理
預加載過程中的異常不應該影響應用啟動：
@PostConstruct
public void preloadCache() {
try {
// 預加載邏輯
} catch (Exception e) {
log.error("緩存預加載失敗，但不影響應用啟動", e);
// 可以發(fā)送告警通知
}
}
2. 分批處理
對于大量數(shù)據(jù)，應該分批處理避免內(nèi)存溢出：
private void preloadLargeDataset() {
int pageSize = cachePreloadProperties.getBatchSize();
int pageNum = 0;
while (true) {
List<DataEntity> dataList = dataService.getDataByPage(pageNum, pageSize);
if (dataList.isEmpty()) {
break;
}
// 批量寫入 Redis
dataList.forEach(data -> {
String key = "data:" + data.getId();
redisTemplate.opsForValue().set(key, data, Duration.ofHours(6));
});
pageNum++;
log.info("已預加載第 {} 批數(shù)據(jù)，本批 {} 條", pageNum, dataList.size());
}
}
3. 監(jiān)控和告警
添加預加載狀態(tài)監(jiān)控：
@Component
public class CachePreloadMonitor {
private final MeterRegistry meterRegistry;
private final Counter preloadSuccessCounter;
private final Counter preloadFailureCounter;
public CachePreloadMonitor(MeterRegistry meterRegistry) {
this.meterRegistry = meterRegistry;
this.preloadSuccessCounter = Counter.builder("cache.preload.success").register(meterRegistry);
this.preloadFailureCounter = Counter.builder("cache.preload.failure").register(meterRegistry);
}
public void recordSuccess(String cacheType, long count) {
preloadSuccessCounter.increment();
Gauge.builder("cache.preload.count")
.tag("type", cacheType)
.register(meterRegistry, count, Number::doubleValue);
}
public void recordFailure(String cacheType) {
preloadFailureCounter.increment();
}
}
總結
選擇合適的預加載方案需要考慮以下因素：
- @PostConstruct: 適合簡單的預加載邏輯
- ApplicationRunner: 適合需要命令行參數(shù)的場景
- ApplicationReadyEvent: 最安全的預加載時機
- 專門的服務: 適合復雜的預加載需求
無論選擇哪種方案，都要注意異常處理、性能優(yōu)化和監(jiān)控告警，確保預加載過程不會影響應用的正常啟動和運行。
以上就是SpringBoot啟動時將數(shù)據(jù)庫數(shù)據(jù)預加載到Redis緩存的幾種實現(xiàn)方案的詳細內(nèi)容，更多關于SpringBoot數(shù)據(jù)加載到Redis緩存的資料請關注腳本之家其它相關文章！
相關文章
SpringBoot項目動態(tài)指定配置文件的方法示例
SpringBoot 作為 Java 開發(fā)中一個非常流行的框架,以其簡化配置和快速啟動應用而聞名,在開發(fā)過程中,我們經(jīng)常需要根據(jù)不同的環(huán)境來加載不同的配置文件,本文給大家介紹了SpringBoot項目動態(tài)指定配置文件的方法示例,需要的朋友可以參考下2024-12-12
本文將詳細介紹Spring Boot的配置管理相關內(nèi)容,包括配置優(yōu)先級、多環(huán)境管理、屬性注入、安全配置、配置校驗和熱更新等主題,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧2026-02-02
這篇文章主要介紹了JDBC編程的詳細步驟,文中有非常詳細的代碼示例,對正在學習JDBC編程的小伙伴們有很好的幫助,需要的朋友可以參考下2021-05-05
關于報錯IDEA Terminated with exit code
如果在IDEA構建項目時遇到下面這樣的報錯IDEA Terminated with exit code 1，那必然是Maven的設置參數(shù)重置了，導致下載錯誤引起的，本文給大家分享兩種解決方法，需要的朋友可以參考下2022-08-08
springboot項目實現(xiàn)定時備份數(shù)據(jù)庫導出sql文件方式
這篇文章主要介紹了springboot項目實現(xiàn)定時備份數(shù)據(jù)庫導出sql文件方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-03-03
詳解Spring Boot中整合Sharding-JDBC讀寫分離示例
這篇文章主要介紹了詳解Spring Boot中整合Sharding-JDBC讀寫分離示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-03-03
其實Map遍歷藏著多種玩法,有的優(yōu)雅簡潔,有的性能拉滿,今天咱們盤一盤這些進階偏基礎的遍歷方式,告別重復又臃腫的代碼,感興趣的小伙伴可以了解下2025-12-12
這篇文章主要介紹了Idea配置超詳細圖文教程(2020.2版本),本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-08-08
spring AOP定義AfterThrowing增加處理實例分析
這篇文章主要介紹了spring AOP定義AfterThrowing增加處理,結合實例形式分析了spring面向切面AOP定義AfterThrowing相關實現(xiàn)步驟與操作技巧,需要的朋友可以參考下2020-01-01
本文主要介紹了mybatis-plus自動填充插入更新時間有8小時時差，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-09-09