缓存预热Springboot定时任务
缓存预热
问题：第一个用户访问还是很慢（加入第一个老板），也能一定程度上保护数据库
缓存预热的优点：
- 解决上面的问题，可以让用户始终访问很快
缺点：
- 增加开发成本（你要额外的开发、设计）
- 预热的时机和时间如果错了，有可能你缓存的数据不对或者太老
- 需要占用额外空间
怎么缓存预热？
-
定时
-
模拟触发（手动触发）
实现
用定时任务，每天刷新所有用户的推荐列表
注意点：
- 缓存预热的意义（新增少、总用户多）
- 缓存的空间不能太大，要预留给其他缓存空间
- 缓存数据的周期（此处每天一次）
定时任务实现
- Spring Scheduler（spring boot 默认整合了）
- Quartz（独立于 Spring 存在的定时任务框架）
- XXL-Job 之类的分布式任务调度平台（界面 + sdk）
第一种方式：
- 主类开启 @EnableScheduling
- 给要定时执行的方法添加 @Scheduling 注解，指定 cron 表达式或者执行频率
cron 表达式
- https://cron.qqe2.com/
- https://www.matools.com/crontab/
package com.bo.partner.job;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.bo.partner.mapper.UserMapper;
import com.bo.partner.model.domain.User;
import com.bo.partner.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;
/**
* @author: bo
* @date: 2022/9/13
* @description:
*/
@Component
@Slf4j
public class PreCacheJob {
//每天执行
//重点用户
private List<Long> mainUserList = Arrays.asList(1L);
@Resource
private RedisTemplate<String, Object> redisTemplate;
@Resource
private UserService userService;
@Resource
private UserMapper userMapper;
@Scheduled(cron = "0 42,46 * * * *")
public void doCatchRecommendUser() {
for (Long userId : mainUserList) {
QueryWrapper<User> queryWrapper = new QueryWrapper<>();
Page<User> page = userService.page(new Page<>(1, 20), queryWrapper);
String redisKey = String.format("partner:user:recommed:userId", userId);
ValueOperations<String, Object> valueOperations = redisTemplate.opsForValue();
try {
valueOperations.set(redisKey, page, 10000, TimeUnit.MILLISECONDS);
} catch (Exception e) {
log.error("redis set key error", e);
}
}
}
}
