当前位置：首页 > ops >正文

XxlJob热点文章定时计算

ops 2025/6/17 11:38:50

需求分析

定时计算步骤

热文章服务实现

计算热点文章

/*** 计算热点文章*/
@Override
public void computeHotArticle() {// 查询前5天的文章数据Date dateParam = DateTime.now().minusDays(5).toDate();List<ApArticle> apArticleList = apArticleMapper.findArticleListByLast5days(dateParam);// 计算文章的分值List<HotArticleVo> hotArticleVoList = computeHotArticle(apArticleList);// 为每个频道缓存30条分值较高的文章cacheTagToRedis(hotArticleVoList);
}

为每个频道缓存30条分值较高的文章

/*** 为每个频道缓存30条分值较高的文章** @param hotArticleVoList*/
private void cacheTagToRedis(List<HotArticleVo> hotArticleVoList) {// 每个频道缓存30条分值较高的文章ResponseResult responseResult = wemediaClient.getChannels();if (responseResult.getCode().equals("200")) {String channelJson = JSON.toJSONString(responseResult.getData());List<WmChannel> wmChannels = JSON.parseArray(channelJson, WmChannel.class);// 检索出每个频道的文章if (wmChannels != null && !wmChannels.isEmpty()) {for (WmChannel wmChannel : wmChannels) {List<HotArticleVo> hotArticleVos = hotArticleVoList.stream().filter(x ->x.getChannelId().equals(wmChannel.getId())).collect(Collectors.toList());// 给文章进行排序，取30条分值较高的文章存入redis key：频道idsortAndCache(hotArticleVos, ArticleConstants.HOT_ARTICLE_FIRST_PAGE + wmChannel.getId());}}}// 设置推荐数据// 给文章进行排序，取30条分值较高的文章存入redis key：频道id value：30条分值较高的文章sortAndCache(hotArticleVoList, ArticleConstants.HOT_ARTICLE_FIRST_PAGE + ArticleConstants.DEFAULT_TAG);
}

计算文章的具体分数

/*** 计算文章的具体分数** @param apArticle* @return*/
private Integer computeScore(ApArticle apArticle) {Integer score = 0;if (apArticle.getLikes() != null) {score += apArticle.getLikes() * ArticleConstants.HOT_ARTICLE_LIKE_WEIGHT;}if (apArticle.getViews() != null) {score += apArticle.getViews();}if (apArticle.getComment() != null) {score += apArticle.getComment() * ArticleConstants.HOT_ARTICLE_COMMENT_WEIGHT;}if (apArticle.getCollection() != null) {score += apArticle.getCollection() * ArticleConstants.HOT_ARTICLE_COLLECTION_WEIGHT;}return score;
}

计算文章分值

/*** 计算文章分值** @param apArticleList* @return*/
private List<HotArticleVo> computeHotArticle(List<ApArticle> apArticleList) {List<HotArticleVo> hotArticleVoList = new ArrayList<>();if (apArticleList != null && !apArticleList.isEmpty()) {for (ApArticle apArticle : apArticleList) {HotArticleVo hot = new HotArticleVo();BeanUtils.copyProperties(apArticle, hot);Integer score = computeScore(apArticle);hot.setScore(score);hotArticleVoList.add(hot);}}return hotArticleVoList;
}

给文章进行排序，取30条分值较高的文章存入redis

/*** 给文章进行排序，取30条分值较高的文章存入redis* @param hotArticleVos* @param key*/
private void sortAndCache(List<HotArticleVo> hotArticleVos, String key) {hotArticleVos = hotArticleVos.stream().sorted(Comparator.comparing(HotArticleVo::getScore).reversed()).collect(Collectors.toList());if (hotArticleVos.size() > 30) {hotArticleVos = hotArticleVos.subList(0, 30);}cacheService.set(key, JSON.toJSONString(hotArticleVos));
}

任务

@XxlJob("computeHotArticleJob")
public void handle() {log.info("热文章分值计算调度任务开始执行...");hotArticleService.computeHotArticle();log.info("热文章分值计算调度任务结束...");
}