Redis支持多人多聊天室功能

public String createChat(Jedis conn, String sender, Set recipients, String message) { 
//启动的时候redis里是没有ids:chat:这个键的 
//自增之后返回1 
    String chatId = String.valueOf(conn.incr("ids:chat:")); 
    return createChat(conn, sender, recipients, message, chatId); 
  } 
 
 
  /** 
  * 
  * @param conn 
  * @param sender 发送消息的人 
  * @param recipients 接受消息的人 
  * @param message 待发送的消息 
  * @param chatId 聊天室的编号 
  * @return 
  */ 
  public String createChat( Jedis conn, String sender,  
    Set recipients, String message, String chatId){ 
  //自己发的消息 自己也能接受到 
    recipients.add(sender); 
 
 
    Transaction trans = conn.multi(); 
    for (String recipient : recipients){ 
  //聊天室的成员 最开始时 都阅读的是0号信息 
      trans.zadd("chat:" + chatId, 0, recipient); 
  //记录每个人参加的聊天室 
      trans.zadd("seen:" + recipient, 0, chatId); 
    } 
    trans.exec(); 
 
 
    return sendMessage(conn, chatId, sender, message); 
  } 
 
 
  public String sendMessage(Jedis conn, String chatId, String sender, String message) { 
   
  //锁住聊天室 为啥? 人员变动了咋办 
  //这个acquireLock见上一章 
    String identifier = acquireLock(conn, "chat:" + chatId); 
    if (identifier == null){ 
      throw new RuntimeException("Couldn't get the lock"); 
    } 
    try { 
    //给要发布的消息设定一个最新的编号 第一次时 返回的是1 
      long messageId = conn.incr("ids:" + chatId); 
      HashMap values = new HashMap(); 
      values.put("id", messageId); 
      values.put("ts", System.currentTimeMillis()); 
      values.put("sender", sender); 
      values.put("message", message); 
      String packed = new Gson().toJson(values); 
       
      //某个聊天室的消息列表 
      //最旧的消息----消息json  
      //默认的zset是按照score的值从小到大排序 
      conn.zadd("msgs:" + chatId, messageId, packed); 
    }finally{ 
      releaseLock(conn, "chat:" + chatId, identifier); 
    } 
    return chatId; 
  } 
,object>,object>

 @SuppressWarnings("unchecked") 
  public List fetchPendingMessages(Jedis conn, String recipient) { 
   
  //获得用户在各个聊天室 已经看到的最新消息的id 
  //有几个聊天室 seenSet的size就是几 
    Set seenSet = conn.zrangeWithScores("seen:" + recipient, 0, -1); 
    List seenList = new ArrayList(seenSet); 
 
 
    Transaction trans = conn.multi(); 
    for (Tuple tuple : seenList){ 
      String chatId = tuple.getElement(); 
      int seenId = (int)tuple.getScore(); 
      //获取每个聊天室里 未读的所有消息 
      //min 和 max 可以是 -inf 和 +inf 
      trans.zrangeByScore("msgs:" + chatId, String.valueOf(seenId + 1), "inf"); 
    } 
    //我参加了几个聊天室 results的长度就是几 
    List

package redisinaction; 
 
 
import java.util.Arrays; 
import java.util.HashSet; 
import java.util.Iterator; 
import java.util.List; 
import java.util.Map; 
import java.util.Set; 
 
 
import org.junit.BeforeClass; 
import org.junit.Test; 
 
 
import jedis.redis_in_action.Chapter06; 
import jedis.redis_in_action.Chapter06.ChatMessages; 
import redis.clients.jedis.Jedis; 
import redis.clients.jedis.Tuple; 
 
 
/**  
 * This class is used for ...  
 * @author dlf(460795365@qq.com) 
 * @version 1.0, 2016年10月17日 下午10:15:58  
 */ 
public class Chapter06Test { 
  static Jedis conn = null; 
  static Chapter06 c=null; 
   
  @BeforeClass 
  public static void initConn(){ 
    System.out.println("test before"); 
    conn = new Jedis("10.150.0.80"); 
    conn.auth("dlf123123"); 
     
    c=new Chapter06(); 
  } 
   
 
 
   
  @Test 
   public void testMultiRecipientMessaging() { 
      System.out.println("\n----- testMultiRecipientMessaging -----"); 
      conn.del("ids:chat:", "msgs:1", "ids:1", "seen:joe", "seen:jeff", "seen:jenny"); 
 
 
      System.out.println("Let's create a new chat session with some recipients..."); 
      Set recipients = new HashSet(); 
      recipients.add("jeff"); 
      recipients.add("jenny"); 
      String chatId = c.createChat(conn, "joe", recipients, "message 1"); 
      System.out.println("Now let's send a few messages..."); 
      for (int i = 2; i  messageFromBase=conn.zrangeWithScores("msgs:"+chatId, 0, -1); 
      Iterator iterator=messageFromBase.iterator(); 
      while(iterator.hasNext()){ 
        Tuple tuple=iterator.next(); 
        System.out.println(tuple.getElement()+"　－－　　"+tuple.getScore()); 
      } 
      System.out.println("And let's get the messages that are waiting for jeff and jenny..."); 
       
       
      List r1 = c.fetchPendingMessages(conn, "jeff"); 
      List r2 = c.fetchPendingMessages(conn, "jenny"); 
    //当我拉取了joe的未读信息后 就会删除msgs:1里面的信息 
    //为什么?想明白了么? 
      List r3 = c.fetchPendingMessages(conn, "joe"); 
      System.out.println("They are the same? " + r1.equals(r2)); 
       
      System.out.println("Those messages are:"); 
      for(ChatMessages chat : r1){ 
        System.out.println(" chatId: " + chat.chatId); 
        System.out.println("  messages:"); 
        for(Map message : chat.messages){ 
          System.out.println("   " + message); 
        } 
      } 
 
 
      System.out.println("看看还有没"); 
      messageFromBase=conn.zrangeWithScores("msgs:"+chatId, 0, -1); 
       iterator=messageFromBase.iterator(); 
      while(iterator.hasNext()){ 
        Tuple tuple=iterator.next(); 
        System.out.println(tuple.getElement()+"　－－　　"+tuple.getScore()); 
      } 
      conn.del("ids:chat:", "msgs:1", "ids:1", "seen:joe", "seen:jeff", "seen:jenny"); 
    } 
   
} 

,object>