项目实践缓存预热方案之CommandLineRunner和ApplicationRunner

本文主要是介绍项目实践缓存预热方案之CommandLineRunner和ApplicationRunner，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

众所周知，在项目的开发中，合理使用缓存是提高服务性能的一大利器，本篇文章就来介绍一下我所在项目中如何使用缓存的一个案例。

背景

我们的项目是由多个微服务所组成，业务是保险，我所负责的模块是出单，在压测的过程中，发现当所有服务启动好之后，第一次出单的时间存在耗时较长的情况，通过sleuth分析了一下各个服务之间的调用链，针对第一单，发现出单接口中存在调用其他接口做查询和逻辑处理，在第一次调用后会将结果缓存，那么以后的调用基本是直接走缓存，不会去和数据库交互，减少了数据库创建和关闭连接之类的耗时。此时，我发现针对首单慢的问题，主要是因为一些接口返回固定的值，第一次没有通过缓存获取而导致的耗时较长的问题。

解决方案

为了解决首单耗时较长的问题，我采用了缓存预热的方案，那就是在服务启动的时候进行缓存预热，这样首单中一些接口的调用也是会通过缓存来取值，肯定是可以减少耗时，提高接口的性能，缩短出单的时间。

缓存预热

不是所有的接口都需要进行缓存预热，应该按照自己的业务所需对缓存预热谨慎使用
对缓存预热应该是同步还是异步进行，这个需要考虑
- 缓存预热同步，那么服务启动好之后缓存预热也结束了，正常的业务就可以开始进行
- 缓存预热异步，服务虽然启动好了，但是缓存预热可能还在进行中，是否会影响到自己的业务需要考虑一下
- 相对比较而言，同步预热会拉长服务的启动时间，异步预热不会拉长服务的启动时间

项目实践

具体的相关代码如下所示：

package com.xxx.xxx.xx.xxx.service.inner.impl;import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;import java.util.List;import static java.util.stream.Collectors.toList;/*** xxx 服务启动时 加载缓存  缓存项为vvv的内容* @author xxx*/
@Order(4)
@Component
@Slf4j
public class InitMarketCacheService implements CommandLineRunner {@Value("#{'${zz.xx.goodsId}'.split(',')}")private List<String> aaaArray;@Value("#{'${zz.xx.planId}'.split(',')}")private List<String>  bbbArray;@Value("#{'${zz.xx.productId}'.split(',')}")private List<String>  cccArray;@Autowiredprivate AxxService axxShareService;@Autowiredprivate BxxShareService bxxShareService;@Overridepublic void run(String... args) throws Exception {List<Long> goodsIdList = goodsIdArray.stream().map(Long::valueOf).collect(toList());List<Long> goodsPlanIdList = planIdArray.stream().map(Long::valueOf).collect(toList());List<Long> productIdList = productIdArray.stream().map(Long::valueOf).collect(toList());log.warn("begin init xxservice cache");try {for (Long goodsId:goodsIdList){AxxService.queryGoods(goodsId);}for (Long planId:goodsPlanIdList){AxxService.queryPlanAndPackage(planId);}for (Long productId:productIdList){BxxShareService.detail(productId);}}catch (Exception e){log.error("cache warm up failed",e);}finally {log.warn("end init xxx service cache");}}
}