redis发布与订阅实例

package com.redis.test;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;


public class JedisPubSubTest {

 public static JedisPool pool;
 static {
  JedisPoolConfig jedispool_config = new JedisPoolConfig();
  jedispool_config.maxActive = 20;
  jedispool_config.maxIdle = 0;
  jedispool_config.maxWait = 1000;
  jedispool_config.testOnBorrow = true;

  pool = new JedisPool(jedispool_config, "127.0.0.1", 6379);
 }

 public static void main(String[] args) throws InterruptedException {
  Jedis redisClient1 = pool.getResource();
  Jedis redisClient2 = pool.getResource();
  MyListener listener = new MyListener();

  Publisher pub = new Publisher();
  pub.publish(redisClient2); //发布一个频道

 

  Subscriber sub = new Subscriber();
  sub.psub(redisClient1, listener); // 订阅一个频道

  
 }

}

 

 

 

 


class Subscriber {
 
 public void psub(final Jedis redisClient, final MyListener listener) {
  

  new Thread(new Runnable() {
   @Override
   public void run() {

    System.out.println("订阅：news.share");
    // 订阅得到信息在lister的onMessage(...)方法中进行处理

    // 订阅多个频道
    // redisClient.subscribe(listener, "news.share", "news.log");

    //redisClient.subscribe(listener, new String[]{"news.share","news.log"});
      redisClient.psubscribe(listener, new String[] { "news.share" });// 使用模式匹配的方式设置频道
   }
  }).start();

 }

}

 

 


class Publisher {
 
 public void publish(final Jedis redisClient) {
  
  new Thread(new Runnable() {
   @Override
   public void run() {
    try {
     Thread.currentThread().sleep(2000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    System.out.println("发布：news.share");
    redisClient.publish("news.share", "ok");
    redisClient.publish("news.share", "hello word");
   }
  }).start();

 }

}

 

 

消息监听：

 

package com.redis.test;

import redis.clients.jedis.JedisPubSub;

public class MyListener extends JedisPubSub {
 // 取得订阅的消息后的处理
 public void onMessage(String channel, String message) {
  System.out.println(channel + "=" + message);
 }

 // 初始化订阅时候的处理
 public void onSubscribe(String channel, int subscribedChannels) {
   System.out.println(channel + "=" + subscribedChannels+"&&&&&&&");
 }

 // 取消订阅时候的处理
 public void onUnsubscribe(String channel, int subscribedChannels) {
   System.out.println(channel + "=" + subscribedChannels+"#########");
 }

 // 初始化按表达式的方式订阅时候的处理
 public void onPSubscribe(String pattern, int subscribedChannels) {
   System.out.println(pattern + "=" + subscribedChannels+"!!!!!!!");
 }

 // 取消按表达式的方式订阅时候的处理
 public void onPUnsubscribe(String pattern, int subscribedChannels) {
   System.out.println(pattern + "=" + subscribedChannels+"@@@@@@@@@");
 }

 // 取得按表达式的方式订阅的消息后的处理
 public void onPMessage(String pattern, String channel, String message) {
  System.out.println(pattern + "=" + channel + "=" + message);
 }
}


结论: 经测试 sub 必须发pub 之前，否则收不到 message, 不要 pool.returnResource操作，会报异常。