从零开始搭建博客03----本周热议处理（redis 有序列表处理）

本周热议，本周发表并且评论最多的文章排行，如果直接查询数据库的话很快就可以实现，只需要限定一下文章创建时间，然后根据评论数量倒叙取前几篇即可搞定。

但这里我们使用redis来完成。之前上课时候我们说过，排行榜功能，我们可以使用redis的有序集合zset来完成。现在我们就这个数据结构来完成本周热议的功能。

在编码之前，我们需要先来回顾一下zset的几个基本命令。

zrange key start stop [WITHSCORES]
withscores代表的是否显示顺序号 start和stop代表所在的位置的索引。可以这样理解：将集合元素依照顺序值升序排序再输出，start和stop限制遍历的限制范围
zincrby key increment member
为有序集 key 的成员 member 的 score 值加上增量 increment 。
ZUNIONSTORE destination numkeys key [key …] [WEIGHTS weight [weight …]] [AGGREGATE SUM|MIN|MAX]
计算给定的一个或多个有序集的并集，其中给定 key 的数量必须以 numkeys 参数指定，并将该并集(结果集)储存到 destination 。
默认情况下，结果集中某个成员的 score 值是所有给定集下该成员 score 值之 和

实现步骤

1. 查库获取最近7天的所有评论数量大于 0文章
2. 把文章的评论数量作为有序集合的分数，文章id作为id存储到zset中
3. 缓存文章到set中，评论数量作为排行标准
4. 设置有效期为7天，因为超过了7天也就失去了时效性

具体代码实现

com.fly.service.impl.PostServiceImpl#initIndexWeekRank

 @Override public void initIndexWeekRank() {
// 查库获取最近7天的所有文章 List<Post> last7DayPosts = this.list(new QueryWrapper<Post>() .ge("created", DateUtil.offsetDay(new Date(), -7).toJdkDate()) .gt("comment_count", 0) .select("id, title, user_id, comment_count, view_count, created"));
// 然后把文章的评论数量作为有序集合的分数，文章id作为ID存储到zset中。 for (Post post : last7DayPosts) { String key = "day_rank" + DateUtil.format(post.getCreated(), DatePattern.PURE_DATE_PATTERN);
// 设置有效期,7天之内有效 long between = DateUtil.between(new Date(), post.getCreated(), DateUnit.DAY); long expireTime = (7 - between) * 24 * 60 * 60;

// 缓存文章到set中，评论数量作为排行标准 redisUtil.zSet(key, post.getId(), post.getCommentCount()); //设置有效期 redisUtil.expire(key, expireTime);
// 缓存文章基本信息（hash结构） this.hashCachePostIdAndTitle(post); }

// 7天阅读相加 this.zUnionAndStroreLast7DaysForWeekRand(); }



  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
 

因为要显示文章的标题等基本信息

  /** * hash结构缓存文章标题和id * * @param post */ private void hashCachePostIdAndTitle(Post post) { boolean isExist = redisUtil.hasKey("rank_post_" + post.getId()); if (!isExist) { long between = DateUtil.between(new Date(), post.getCreated(), DateUnit.DAY); long expireTime = (7 - between) * 24 * 60 * 60;

// 缓存文章基本信息 redisUtil.hset("rank_post_" + post.getId(), "post:id", post.getId(), expireTime); redisUtil.hset("rank_post_" + post.getId(), "post:title", post.getTitle(), expireTime); } } /** * 把最近7天的文章评论数量统计一下 * 用于首页的7天评论排行榜 */ public void zUnionAndStroreLast7DaysForWeekRand() { String prifix = "day_rank"; List<String> keys = new ArrayList<>(); String key = prifix + DateUtil.format(new Date(), DatePattern.PURE_DATE_PATTERN); for (int i = -7; i < 0; i++) { Date date = DateUtil.offsetDay(new Date(), i).toJdkDate(); keys.add(prifix + DateUtil.format(date, DatePattern.PURE_DATE_PATTERN)); } redisUtil.zUnionAndStore(key, keys, "last_week_rank"); }

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
 

我们在项目启动之时初始化，代码如下：

增加评论数量

用户发表评论之后应该要数据库中的comment_count 加1，也要让缓存中数量加1，这样才能保证数据的一致性，在com.fly.controller.PostController#commentAdd 中

 @Override public void incrZsetValueAndUnionForLastWeekRank(Long postId) { String dayRank = "day_rank" + DateUtil.format(new Date(), DatePattern.PURE_DATE_PATTERN);
// 文章阅读加一 redisUtil.zIncrementScore(dayRank, postId, 1); this.hashCachePostIdAndTitle(this.getById(postId));

// 重新union最近7天 this.zUnionAndStroreLast7DaysForWeekRand(); }

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
 

其实逻辑也和初始化差不多，首先给文章数量加一。集合名称是对应当天的。比如今天是12月21，对应的key就是day_rank:20181221。在这个上面给对应的文章id加一。这样每天都有评论这篇文章的话，我们再做交集处理，把每天的评论数量都加起来。得到的就是总的评论数量了。

前端引用的代码
common/templates.html

<!--本周热议-->
<div th:fragment="weekPopular"> <dl class="fly-panel fly-list-one" id="post-hots"> <dt class="fly-panel-title">本周热议</dt> <script id="hostDd" type="text/html"> {{#  layui.each(d.list, function(index, item){ }} <dd> <a href="/post/{{item.id}}">{{item.title}}</a> <span><i class="iconfont icon-pinglun1"></i>{{item.comment_count}}</span> </dd> {{#  }); }} {{#  if(d.list.length === 0){ }} <div class="fly-none">没有相关数据</div> {{#  } }} </script> </dl> <script> layui.use(['laytpl'], function () { var laytpl = layui.laytpl; var post_hosts = document.getElementById("post-hots"); var tpl = document.getElementById("hostDd").innerHTML; var data = {}; $.ajax({ url: "/post/hosts", async: false, success: function (res) { if (res.code == 0) { data.list = res.data; } } }); laytpl(tpl).render(data, function (html) { post_hosts.innerHTML += html; }); }); </script>
</div>


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
 

代码参考：
https://github.com/XWxiaowei/FlyBlog

文章来源: feige.blog.csdn.net，作者：码农飞哥，版权归原作者所有，如需转载，请联系作者。

原文链接：feige.blog.csdn.net/article/details/85218998