SpringBoot 定时任务从Redis同步文章访问量

avatar 2018年12月25日09:34:42 6 6396 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此
在新开发的博客系统中，引入了大量redis，文章/文章列表/分类/标签/评论等等都先从MySQL读取，之后都是从Redis读取。而文章访问量应该怎么设计呢？，每刷新一次+1，数据库异步+1吗？还是使用cookie记录访问了哪些文章，再次刷新不重复计数？

目前采用的是可重复计数，就是页面每刷新一次，访问量+1。每次+1都是在 Redis 中加，到每天某个时刻，同步到MySQL数据库中。


一、SpringBoot 定时任务使用


1.在启动类上加 @EnableScheduling 注解





2.创建任务类
  1. package com.liuyanzhao.sens.config;
  3. import com.liuyanzhao.sens.mapper.PostMapper;
  4. import com.liuyanzhao.sens.model.dto.PostViewsDto;
  5. import com.liuyanzhao.sens.utils.RedisUtil;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.scheduling.annotation.Scheduled;
  9. import org.springframework.stereotype.Component;
  11. import java.util.ArrayList;
  12. import java.util.List;
  13. import java.util.Set;
  15. /**
  16.  * @author 言曌
  17.  * @date 2018/12/24 下午4:55
  18.  */
  19. @Component
  20. @Slf4j
  21. public class ScheduledTasks {
  23.     @Autowired
  24.     private RedisUtil redisUtil;
  26.     @Autowired(required = false)
  27.     private PostMapper postMapper;
  29.     /**
  30.      * 同步文章访问量
  31.      */
  32.     @Scheduled(cron = "0 30 4 ? * * ") //每天凌晨4:30执行
  33.     public void syncPostViews() {
  34.         log.info("======================开始 同步文章访问量======================");
  35.         Long startTime = System.nanoTime();
  36.         List<PostViewsDto> dtoList = new ArrayList<>();
  37.         //从redis取值封装List
  38.         Integer prefixLength = "posts_views::posts_views_id_".length();
  39.         Set<String> keySet = redisUtil.keys("posts_views::posts_views_id_*");
  40.         for (String key : keySet) {
  41.             dtoList.add(new PostViewsDto(Long.parseLong(key.substring(prefixLength)), Long.parseLong(redisUtil.get(key))));
  42.         }
  43.         //更新到数据库中
  44.         postMapper.batchUpdatePostViews(dtoList);
  45.         Long endTime = System.nanoTime();
  46.         log.info("本次文章访问量同步成功, 总耗时: {}", (endTime - startTime) / 1000000 + "ms");
  47.         log.info("======================结束 文章访问量结束======================");
  48.     }
  51. }

可以写多个方法，每个都需要加 @Scheduled 注解，指定相应时间就行。

下面给出一些常用的时间格式

"0 0 12 * * ?"    每天中午十二点触发

"0 15 10 ? * *"    每天早上10：15触发

"0 15 10 * * ?"    每天早上10：15触发

"0 15 10 * * ? *"    每天早上10：15触发

"0 15 10 * * ? 2005"    2005年的每天早上10：15触发

"0 * 14 * * ?"    每天从下午2点开始到2点59分每分钟一次触发

"0 0/5 14 * * ?"    每天从下午2点开始到2：55分结束每5分钟一次触发

"0 0/5 14,18 * * ?"    每天的下午2点至2：55和6点至6点55分两个时间段内每5分钟一次触发

"0 0-5 14 * * ?"    每天14:00至14:05每分钟一次触发

"0 10,44 14 ? 3 WED"    三月的每周三的14：10和14：44触发

"0 15 10 ? * MON-FRI"    每个周一、周二、周三、周四、周五的10：15触发


二、文章访问量的设计


文章表里一个 post_views 字段，即文章访问量。

当查看文章详情的时候，查询一下该文章的访问量，通常是从缓存中拿，如果没有，从文章对象的postViews属性中拿。
  1. /**
  2.      * 修改文章阅读量
  3.      * Redis增加，定时器同步
  4.      *
  5.      * @param postId 文章Id
  6.      */
  7.     @Override
  8.     public Long updatePostView(Long postId) {
  9.         Long view = this.getPostViewsByPostId(postId);
  10.         if (view == null) {
  11.             return null;
  12.         }
  13.         return redisUtil.incr("posts_views::posts_views_id_" + postId, 1);
  14.     }
  16.     /**
  17.      * 获得某篇文章的访问量
  18.      *
  19.      * @return Long
  20.      */
  21.     @Override
  22.     public Long getPostViewsByPostId(Long postId) {
  23.         String str = redisUtil.get("posts_views::posts_views_id_" + postId);
  24.         if (str == null) {
  25.             Post post = this.findByPostId(postId);
  26.             if (post == null) {
  27.                 return null;
  28.             }
  29.             redisUtil.set("posts_views::posts_views_id_" + postId, String.valueOf(post.getPostViews()));
  30.             return post.getPostViews();
  31.         }
  32.         return Long.parseLong(str);
  33.     }







历史上的今天
十二月
25日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0