365bet在线体育365bet在线体育

日博体育
日博滚球

Redis构建文章聚合信息分类网站

本系列教程内容提要

Java工程师之Redis实战系列教程教程是一个学习教程,是关于Java工程师的Redis知识的实战系列教程,本系列教程均以解决特定问题为目标,使用Redis快速解决在实际生产中的相关问题,为了更方便的与大家一起探讨与学习,每个章节均提供尽可能详细的示例源码及注释,所有示例源码均可在javacourse-redis-in-action找到相关帮助!

你思考过这个问题吗?

如果你想过自己开发一个论坛网站,或者文章网站?最起码想过开发自己的博客网站吧?那么你是否考虑过这个问题--“当你数据库查询你的记录时,你考虑过这些记录应当以什么样的方式展现在网页?按发布时间?按浏览次数?

按发布时间(嗯,应当时没问题的...)按浏览次数(嗯,如果给定一个时间范围也是没问题的...)

你是否浏览过stackoverflow,如下图所示,你是否考虑过这些记录时按照什么展现的呢?唔...经过你的长久思考后,你想“应该不是最新,也不是浏览最多,应该时经过一系列的机制后算出来的....”

我们通过什么机制进行排序呢?

既然你能想到一定是经过一系列的运算过程的出来的排序过程,那么我们可否设计一个符合我们自己网站的 "运算过程" 呢? 我们规定:

文章的发布时间+A支持票乘以常量E-B反对票乘以常量E文章7天后不再支持投支持票/反对票

设计Redis表结构

表名结构
文章HASH
投票人SET
群组SET
文章评分排行ZSET
文章最新排行ZSET
群组最新文章ZSET
群组评分排行ZSET

核心源码

查询文章 (查询功能做的最多的就是拼装数据,但是在查询某个群组的文章的时候,就是涉及到了Redis的交集运算)

/** * 获得所有文章列表文章列表 * * @param page 页数 * @param order 排序 * @param model 模型 * @return */ @GetMapping(value = "/getArticleList") public String getArticle(@RequestParam(required = false, defaultValue = "1") Integer page, @RequestParam(required = false, defaultValue = "score") String order, Model model) { /*获取文章列表*/ List<Article> articleArrayList = getArticles(jedis, page, order + ":"); /*拼装分页信息*/ model.addAttribute("articleArrayList", articleArrayList); model.addAttribute("order", order); model.addAttribute("page", page); return "index"; }

/** * 获取分组文章列表 * * @return */ @GetMapping(value = "/getGroupArticleList") public String getGroupArticle(@RequestParam(required = false, defaultValue = "1") Integer page, @RequestParam(required = false, defaultValue = "score") String order, @RequestParam(required = true) String group, Model model) { List<Article> groupArticles = getGroupArticles(jedis, group, page, order + ":"); /*拼装分页信息*/ model.addAttribute("groupArticles", groupArticles); model.addAttribute("group", group); model.addAttribute("order", order); model.addAttribute("page", page); return "group"; }

发布文章 (发布文章需要注意的是根据文章的所属群组,将其添加至相关群组)

/** * 发布文章 * * @param article * @param model * @return */ @PostMapping(value = "/addArticle") public String addArticle(Article article, Model model) { /*模拟用户*/ User user = getUser(); /*从Redis获取文章的自增ID*/ String id = String.valueOf(jedis.incr("article:")); /*将文章的发帖人本人添加至投票列表*/ String voted = "voted:" + id; jedis.sadd(voted, user.getUserId().toString()); jedis.expire(voted, ONE_WEEK_IN_SECONDS); /*将文章添加至文章列表*/ long now = System.currentTimeMillis() / 1000; String articleId = "article:" + id; HashMap<String, String> articleData = new HashMap<>(); articleData.put("title", article.getTitle()); articleData.put("link", article.getLink()); articleData.put("user", user.getUserId().toString()); articleData.put("time", String.valueOf(now)); articleData.put("votes", "1"); articleData.put("group", article.getGroup()); articleData.put("opposeVotes", "0"); jedis.hmset(articleId, articleData); /*将文章添加至分值列表*/ jedis.zadd("score:", now + VOTE_SCORE, articleId); /*将文章添加至发布时间列表*/ jedis.zadd("time:", now, articleId); /*将文章加入其所属分组*/ addGroup(jedis, articleId, new String[]{article.getGroup()}); /*设置模型数据*/ model.addAttribute("page", 1); model.addAttribute("order", "score"); return "redirect:/article/getArticleList"; }

投票 (根据我们前面的规定,7天后不再提供对该文章的投票功能,所以需要在进行投票之前注意文章的发布时间)

/** * 投票 * * @param articleId * @param model * @return */ @GetMapping(value = "/articleVote") public String articleVote(Integer articleId, int tag, RedirectAttributes model) { /*模拟用户*/ User user = getUser(); String result = article_vote(jedis, user, articleId, tag); /*设置模型数据*/ model.addFlashAttribute("result", result); model.addFlashAttribute("page", 1); model.addFlashAttribute("order", "score"); return "redirect:/article/getArticleList"; }

运行效果图

各位友友可以下载本章的示例源码,运行访问 http://localhost:8080/article/getArticleList

本章源码提供完整的运行环境源码GitHub下载

欢迎阅读本文章: 周航

365bet官方网址

日博体育