Redis 订阅与发布

Redis是一个key-value的存储系统,提供的key-value类似与Memcached而数据结构又多于memcached,而且性能优异.广泛用于缓存,临时存储等，不仅如此redis pubsub还可以实现发布–订阅功能，实时推送给订阅端。

1.实现发布功能

Word!");          } finally {              pool.returnResource(jedis);          }          pool.destroy();      }  }  

2.实现发布订阅功能继续JedisPubSub类实现对订阅到消息后的处理。

[java] view%20plain copy print?package cn.slimsmart.redis.spring.data.redis.pubsub;    import redis.clients.jedis.JedisPubSub;    public class JedisPubSubListener extends JedisPubSub {      @Override      public void onMessage(String channel, String message) {          // 取得订阅的消息后的处理          System.out.println(channel + "    " + message);      }        @Override      public void onPMessage(String pattern, String channel, String message) {          // 取得按表达式的方式订阅的消息后的处理      }        @Override      public void onPSubscribe(String pattern, int subscribedChannels) {          // 初始化按表达式的方式订阅时候的处理      }        @Override      public void onPUnsubscribe(String pattern, int subscribedChannels) {          // 取消按表达式的方式订阅时候的处理      }        @Override      public void onSubscribe(String channel, int subscribedChannels) {          // 初始化订阅时候的处理      }        @Override      public void onUnsubscribe(String channel, int subscribedChannels) {          // 取消订阅时候的处理      }  }  

3.测试订阅功能

[java] view%20plain copy print?package cn.slimsmart.redis.spring.data.redis.pubsub;    import redis.clients.jedis.Jedis;  import redis.clients.jedis.JedisPool;  import redis.clients.jedis.JedisPoolConfig;    public class JedisTest {      static JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();      static {          jedisPoolConfig.setMaxTotal(10);          jedisPoolConfig.setMaxIdle(2);      }      static JedisPool pool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 5000);      public static void main(String[] args) {          Jedis jedis = pool.getResource();          try {              JedisPubSubListener pubsub = new JedisPubSubListener();              //订阅              jedis.subscribe(pubsub, "hq_xq_pubsub");          } finally {              pool.returnResource(jedis);          }          pool.destroy();      }  }  

测试的时候先启动JedisTest 类，然后再启动JedisPubSubTest类。主要运行原理就是socket。

关于spring-data-redis实现发布订阅，请参考文章：

Spring Data Redis实现一个订阅/发布系统