# K    键空间通知，以__keyspace@<db>__为前缀
# E    键事件通知，以__keysevent@<db>__为前缀
# g    del , expipre , rename 等类型无关的通用命令的通知, ...
# $    String命令
# l    List命令
# s    Set命令
# h    Hash命令
# z    有序集合命令
# x    过期事件（每次key过期时生成）
# e    驱逐事件（当key在内存满了被清除时生成）
# A    g$lshzxe的别名，因此”AKE”意味着所有的事件

package com.sogou.baike.testimport.testSubscribe;  import redis.clients.jedis.JedisPubSub;  /**  * Created by denglinjie on 2016/6/29.  */
public class RedisMsgPubSubListener extends JedisPubSub {  @Override  public void unsubscribe() {  super.unsubscribe();  }  @Override  public void unsubscribe(String... channels) {  super.unsubscribe(channels);  }  @Override  public void subscribe(String... channels) {  super.subscribe(channels);  }  @Override  public void psubscribe(String... patterns) {  super.psubscribe(patterns);  }  @Override  public void punsubscribe() {  super.punsubscribe();  }  @Override  public void punsubscribe(String... patterns) {  super.punsubscribe(patterns);  }  @Override  public void onMessage(String channel, String message) {  System.out.println("channel:" + channel + "receives message :" + message);  this.unsubscribe();  }  @Override  public void onPMessage(String pattern, String channel, String message) {  }  @Override  public void onSubscribe(String channel, int subscribedChannels) {  System.out.println("channel:" + channel + "is been subscribed:" + subscribedChannels);  }  @Override  public void onPUnsubscribe(String pattern, int subscribedChannels) {  }  @Override  public void onPSubscribe(String pattern, int subscribedChannels) {  }  @Override  public void onUnsubscribe(String channel, int subscribedChannels) {  System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels);  }
}  

public class TestSubscribe {  @Test  public void testSubscribe() throws Exception{  Jedis jedis = new Jedis("localhost");  RedisMsgPubSubListener listener = new RedisMsgPubSubListener();  jedis.subscribe(listener, "__keyevent@0__:expired");  //other code
    }
}  

Public class TestPublish {  @Test  public void testPublish() throws Exception{  Jedis jedis = new Jedis("localhost");  jedis.publish("redisChatTest", "我是天才");  Thread.sleep(5000);  jedis.publish("redisChatTest", "我牛逼");  Thread.sleep(5000);  jedis.publish("redisChatTest", "哈哈");  }
}