用redis实现仿新浪微博“查看会话”功能 博客分类: redis redis查看会话时间戳会话流水号
本人最近需要实现一个功能,就是类似新浪微博评论的“查看会话”的功能:一个大V发布一则微博,评论下面会有N多个fans进行评论。而当网友A评论时,网友B回复A,网友C又可能回复B,网友A还可能回复B或C,现在只考虑A,B,C(甚至会有更多的网友参与回复)……这时候,网友A,B,C之间就构成了一个“会话”了。而当你点击“查看会话”后,则会弹出一个按时间轴排序的对话框,会把会话相关的网友及其评论或回复内容组织起来。类似的情形还常见于各大社群网站,如在QQ空间发布说说,各个好友相互回复的情形等等……
下面是查看会话的情形截图:
现在我做的借鉴了查看会话的功能,最后也实现了,最主要的灵魂是“时间戳”,因为它是排列各个消息的依据;而标识会话的字段则是会话流水号,它是每条消息都会有且都相同的。
首先,我把每一条消息抽象成map的数据结构,每条消息包括消息发送者,会话流水号(每条消息都相等,在一个消息会话中唯一,消息ID,消息内容,发布时间等):
//会话的发起者 Map poster = new HashMap(); poster.put("userid", "user001"); poster.put("userName", "Lily"); poster.put("infoSeqNo", "INFO20150815"); poster.put("postTime", "2015-08-15 20:26:30"); poster.put("info", "今天很开心"); poster.put("infoId", "info001"); Map respondent1 = new HashMap(); respondent1.put("userid", "user002"); respondent1.put("userName", "Tom"); respondent1.put("infoSeqNo", "INFO20150815"); respondent1.put("answerTime", "2015-08-15 20:28:40"); respondent1.put("info", "是吗"); respondent1.put("replyTarget", "user001"); respondent1.put("infoId", "info002"); Map respondent2 = new HashMap(); respondent2.put("userid", "user003"); respondent2.put("userName", "Kay"); respondent2.put("infoSeqNo", "INFO20150815"); respondent2.put("answerTime", "2015-08-15 20:30:27"); respondent2.put("info", "她肯定很开心啦,因为……"); respondent2.put("replyTarget", "user002"); respondent2.put("infoId", "info003"); Map respondent3 = new HashMap(); respondent3.put("userid", "user001"); respondent3.put("userName", "Lily"); respondent3.put("infoSeqNo", "INFO20150815"); respondent3.put("answerTime", "2015-08-15 20:38:40"); respondent3.put("info", "恩,今天去玩了"); respondent3.put("replyTarget", "user003"); respondent3.put("infoId", "info004");
下面把他们存入redis
Jedis jedis = xxx.getRedis();//从池中得到redis实例,具体方法略。。 //以会话流水号以及消息id作为key,消息map作为value jedis.hmset((String)respondent1.get("infoSeqNo") + respondent1.get("infoId"), respondent1); jedis.hmset((String)respondent2.get("infoSeqNo") + respondent2.get("infoId"), respondent2); jedis.hmset((String)respondent3.get("infoSeqNo") + respondent3.get("infoId"), respondent3); jedis.hmset((String)poster.get("infoSeqNo") + poster.get("infoId"), poster);
接下来就是根据会话流水号来得到按时间戳排序出一个消息会话了<测试刚刚存入redis的消息,以会话流水号infoSeqNo=INFO20150815为入口:
Jedis jedis = xxx.getJedis(); String infoSeqNo = "INFO20150815"; Set<String> keys = jedis.keys(infoSeqNo + "*"); List<String> keyss = new ArrayList<String>(keys); String postTime = ""; List<String> times = new ArrayList<String>();//存放所有时间(发帖以及回复)的集合 Set<String> users = new HashSet<String>(); Map<String, Map> msg = new HashMap<String, Map>(); Map<String, String> target = new HashMap<String, String>(); List<String> routes = new ArrayList<String> (); for(String key : keys) { Map dto = jedis.hgetAll(key); if(dto.containsKey("postTime")) {//表明是会话的发起者 postTime = jedis.hget(key, "postTime"); // times.add(postTime); String userName = jedis.hget(key, "userName"); keyss.remove(key); target.put(jedis.hget(key, "userid"), jedis.hget(key, "username")); routes.add("【" + postTime + "】 " + userName + ": " + jedis.hget(key, "info")); // System.out.println("【" + postTime + "】 " + userName + ": " + msg); }else{ String answerTime = jedis.hget(key, "answerTime"); target.put(jedis.hget(key, "userid"), jedis.hget(key, "userName")); msg.put(answerTime, jedis.hgetAll(key)); times.add(answerTime); } } // System.out.println("发帖时间:" + postTime + " 所有时间的集合:" + times // + "时间map:" + msg + " target的对应关系: " + target); // int size = keyss.size(); String time = ""; for(int i=0; i<size; i++ ) { String answerTime = ""; if(i == 0) { answerTime = getCloseTime(postTime, times); }else { answerTime = getCloseTime(time, times); } time = getCloseTime(answerTime, times); Map info = msg.get(answerTime); String username = (String) info.get("userName"); String targetUser = target.get(info.get("replyTarget")); routes.add("【" + answerTime + "】 " + username + " 回复 " + targetUser + " :" + info.get("info")); times.remove(answerTime); } for(String str : routes) { System.out.println(str); }
其中,getCloseTime方法用于从一个时间集合中找到与给定时间最为接近的时间:
//此方法是用来找到距离给定时间最相近的时间 public static String getCloseTime(String time, List<String> times) { String df = "yyyy-MM-dd hh:mm:ss"; String closeTime = times.get(0); Date date = StringToDate(time, df);//具体方法略 Date dateTmp = StringToDate(times.get(0), df); double dif = Math.abs(date.getTime() - dateTmp.getTime()); for(int i=1; i<times.size(); i++) { Date d = StringToDate(times.get(i), df); double diff = Math.abs(date.getTime() - d.getTime()); if(diff <= dif) { closeTime = times.get(i); } dif = diff; } return closeTime; }
测试结果:
【2015-08-15 20:26:30】 Lily: 今天很开心
【2015-08-15 20:28:40】 Tom 回复 Lily :是吗
【2015-08-15 20:30:27】 Kay 回复 Tom :她肯定很开心啦,因为……
【2015-08-15 20:38:40】 Lily 回复 Kay :恩,今天去玩了
说明,用redis做的仿“查看会话”的功能得以实现!
可以把infoSeqNo(会话流水号)作为参数,把上述代码抽离出一个方法来。