背景

多個(gè)客戶端client1、client2、client3訂閱redis服務(wù)，當(dāng)redis服務(wù)有修改時(shí)，將修改內(nèi)容發(fā)布至訂閱的客戶端。

實(shí)現(xiàn)方案

1.定義實(shí)現(xiàn)抽象類JedisPubSub的RedisMsgPubSubListener

Jedis定義了抽象類JedisPubSub，在這個(gè)類中，定義publish/subsribe的回調(diào)方法。通過(guò)繼承JedisPubSub類并重新實(shí)現(xiàn)這些回調(diào)方法，當(dāng)publish/subsribe事件發(fā)生時(shí)，我們可以定制自己的處理邏輯。

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) {    }}

單元測(cè)試

訂閱測(cè)試

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

發(fā)布測(cè)試

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

輸出結(jié)果

輸出結(jié)果.png