当用户点击新闻查看详情后，数据库新闻的浏览量字段要加一，当在高并发场景下，很多人查看新闻详情直接操作数据库使浏览量字段加一对数据库压力过大，并且容易造成脏数据，这里结合redis实现浏览量加一。

业务逻辑：

①、项目初始化，缓存所有新闻的浏览量Map

②、点击详情后，相应新闻的浏览量自增加一

③、定时器使redis数据写入数据库

④、查询文章浏览量以redis为准

新闻entity：

@Data
@TableName(value ="app_news")
public class AppNews {
    @TableId
    private String newsId;

    private String newsTitle;

    private String newsContent;

    private Integer viewNum;

}

先来第一步，项目启动初始化把新闻浏览量存入redis：

在新闻业务实现类添加一个方法，使用@PostConstruct注解表示项目启动后自动执行该方法

@Resource
private RedisCache redisCache;

@PostConstruct
public void init() {
    log.info("新闻浏览量写入缓存开始==>");
    List<AppNews> appNewsList = list();
    Map<String, Integer> newsViewMap = appNewsList.stream().collect(Collectors.toMap(AppNews::getNewsId, AppNews::getViewNum));
    redisCache.setCacheMap(CacheConstants.NEWS_VIEW_NUM_KEY, newsViewMap);
    log.info("<==新闻浏览量写入缓存成功");
}

写入Map成功：新闻id对应浏览量

下面是新闻查看详情接口，新增业务新闻阅读量加一（ps：当然如果你想优雅也可以使用AOP）：

@Transactional
@GetMapping("/{newsId}")
public AjaxResult getDetails(@PathVariable(value = "newsId") String newsId) {
    AppNews appNews = appNewsService.getNewsDetails(newsId);
    // 新闻阅读量加一
    appNewsService.viewNumIncrease(newsId);
    return AjaxResult.success(appNews);
}

appNewsService.viewNumIncrease(newsId);方法具体实现：

@Override
public void viewNumIncrease(String newsId) {
    // 缓存中阅读量自增一
    redisCache.incrementCacheMapValue(CacheConstants.NEWS_VIEW_NUM_KEY, newsId, 1);
}

redisCache中封装对应方法：

public void incrementCacheMapValue(String key, String hKey, long v) {
    redisTemplate.boundHashOps(key).increment(hKey, v);
}

此时阅读量在缓存中自增一了，接下来查看新闻详情需要把redis的浏览量查出来返回而不是数据库

查询新闻详情方法修改：

@Override
public AppNews getNewsDetails(String newsId) {
    LambdaQueryWrapper<AppNews> queryWrapper = new LambdaQueryWrapper<>();
    queryWrapper.eq(StringUtil.isNotEmpty(newsId), AppNews::getNewsId, newsId);
    AppNews one = getOne(queryWrapper);
    this.getNewsViewNumFromRedis(one);
    return one;
}
private void getNewsViewNumFromRedis(AppNews appNews) {
    appNews.setViewNum(redisCache.getCacheMapValue(CacheConstants.NEWS_VIEW_NUM_KEY, appNews.getNewsId()));
}

再写一个定时器定时同步浏览量即可：

@Component
public class updateNewsViewNumTask {

    private static final Logger log = LoggerFactory.getLogger(updateNewsViewNumTask.class);

    @Resource
    private RedisCache redisCache;

    @Resource
    private AppNewsService appNewsService;

    @Scheduled(cron = "0/10 * * * * ?")
    public void updateViewCount() {
        log.info("开始从redis更新新闻浏览量==>");
        //获取redis中的浏览量
        Map<String, Integer> viewNumMap = redisCache.getCacheMap(CacheConstants.NEWS_VIEW_NUM_KEY);
        List<AppNews> newsList = viewNumMap.entrySet().stream().map(entry -> {
            AppNews an = new AppNews();
            an.setNewsId(entry.getKey());
            an.setViewNum(entry.getValue());
            return an;
        }).collect(Collectors.toList());
        //更新数据库
        appNewsService.updateBatchById(newsList);
        log.info("<==新闻浏览量数据库与redis同步成功");
    }
}