设计
实现已读功能记录的方式有多种选择
1、客户端记录,使用页面cookie或手机客户端缓存进行记录。
2、后台关系型数据库记录,使用mysql数据库创建读取记录表进行记录。
3、后台非关系型数据库记录,使用redis数据库记录。
在不同的情况况下每种选择各有优劣,redis实现的好处是可以跨平台记录并且执行效率很高。
在已读功能中主要涉及到以下几个数据,用户id,文章id,读取标志。有了这几个数据我们就可以确定那个用户读过那些文章了。
首先我们先要确定使用那个数据作为key值,其实用户id和文章id都可以作为key值。现在就要看那种数据量比较大,我们的项目目前用户量在10万左右,文章量在100篇左右。显然使用文章id作为key比较合理,否则就要创建10万条数据。
然后我们来确定一下value的存储方式。文章id作为key,那么我们就可以将用户id存储在Set中作为value,用户读取文章时就增加该用户的id。这么做也隐式的存储了读取标志。
补充说明一下为什么用Set类型存储value,list是可重复的我们每次必须先要判断是否存在才能向数据库存储,这样的操作显然很消耗性能,所以使用set只要每次都存就可以了。
代码
完整测试代码已上传码云:https://gitee.com/imlichao/Article-reading-record
此部分贴出主要实现代码以供参考
package pub.lichao.test.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;
/**
* 使用redis进行文章已读控制
*/
@Controller
public class ArticleController {
@Autowired JedisUtil jedisUtil;
public List<Article> articleList = new ArrayList<Article>();
/**
* 构造方法初始化一组文章
* 真实情况一般是从数据库中查询
*/
public ArticleController(){
for( int i = 1;i <= 20 ;i++){
Article article = new Article();
article.setId(Long.valueOf(i));
article.setTitle("测试文章" + i );
articleList.add(article);
}
}
/**
* 阅读文章
* @param articleId 文章id
* @param personId 读者id
* @param model
* @return
*/
@RequestMapping(value = "/readArticle", method = RequestMethod.GET)
public String readArticle(Long articleId,Long personId,ModelMap model){
//在redis中增加阅读用户id
jedisUtil.addSet(0,articleId.toString(),personId.toString());
return "redirect:articleList?personId="+personId;
}
/**
* 文章列表查询
* @param personId 读者id
* @param model
* @return
*/
@RequestMapping(value = "/articleList", method = RequestMethod.GET)
public String articleList(Long personId,ModelMap model){
if(personId == null){
return "article";
}
List<Article> returnArticleList = new ArrayList<Article>();
Integer unreadArticleNum = 0; //未读文章计数
for(Article article:articleList){
Article returnArticle = new Article();
returnArticle.setId(article.getId());
returnArticle.setTitle(article.getTitle());
returnArticle.setIsRead(article.getIsRead());
//获取redis存储的已读用户列表
Set<String> personSet = jedisUtil.getSet(0,article.getId().toString());
boolean b = personSet.contains(personId.toString());
if(b == true){
returnArticle.setIsRead(1); //如果存在则更改已读标志
}else{
unreadArticleNum++; //如果不存在未读计数加1
}
returnArticleList.add(returnArticle);
}
model.addAttribute("returnArticleList",returnArticleList);
model.addAttribute("unreadArticleNum",unreadArticleNum);
model.addAttribute("personId",personId);
return "article";
}
@RequestMapping(value = "/", method = RequestMethod.GET)
public String index(){
return "redirect:articleList";
}
}