背景

多个客户端client1、client2、client3订阅redis服务，当redis服务有修改时，将修改内容发布至订阅的客户端。

实现方案

1.定义实现抽象类JedisPubSub的RedisMsgPubSubListener

Jedis定义了抽象类JedisPubSub，在这个类中，定义publish/subsribe的回调方法。通过继承JedisPubSub类并重新实现这些回调方法，当publish/subsribe事件发生时，我们可以定制自己的处理逻辑。

public class RedisMsgPubSubListener extends JedisPubSub {    
public RedisMsgPubSubListener() {        super();    }    
@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 boolean isSubscribed() {        return super.isSubscribed();    }    
@Override    
public void proceedWithPatterns(Client client, String... patterns) {        super.proceedWithPatterns(client, patterns);    }    
@Override    
public void proceed(Client client, String... channels) {        super.proceed(client, channels);    }    
@Override    
public int getSubscribedChannels() {        return super.getSubscribedChannels();    }    
@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 onUnsubscribe(String channel, int subscribedChannels) {        System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels);    }   
@Override    
public void onPUnsubscribe(String pattern, int subscribedChannels) {    }    
@Override    
public void onPSubscribe(String pattern, int subscribedChannels) {    }}

单元测试

订阅测试

@Testpublic void sub1Test(){    
Jedis jedis = new Jedis("localhost");    
RedisMsgPubSubListener listener = new RedisMsgPubSubListener();    
listener.subscribe("redisChatTest");   
 jedis.subscribe(listener, "redisChatTest");
}

发布测试

@Test
public void pubTest() throws Exception{    
Jedis jedis = new Jedis("localhost");    
jedis.publish("redisChatTest", "我是天才");   
 jedis.publish("redisChatTest", "我牛逼");    
jedis.publish("redisChatTest", "哈哈");
}

输出结果

输出结果.png