本地測試redis的pub/sub功能，本地主要是redis的缺陷，服務重啟時會丟失資訊的問題。發現redis的pub/sub功能還是比較薄弱，對於大量訊息佇列來說，不太合適，捨棄掉

import redis.clients.jedis.JedisPubSub;


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) {
    	 System.out.println("onPMessage==="+"channel:" + channel + "   pub message :" + message+"  pattern:"+pattern);
    }

    @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) {
    	System.out.println("pattern:" + pattern + "is been unPSubscribeed:" + subscribedChannels);
    }

    @Override
    public void onPSubscribe(String pattern, int subscribedChannels) {
    	System.out.println("pattern:" + pattern + "is been PSubscribeed:" + subscribedChannels);
    }

    @Override
    public void onUnsubscribe(String channel, int subscribedChannels) {
        System.out.println("channel:" + channel + "is been unsubscribed:" + subscribedChannels);
    }
}

 

import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestPublish {
	
	@Test
    public void testPublish() throws Exception{
        Jedis jedis = new Jedis("api.dev.lexue.com",16479);
        jedis.auth("[email protected]");
        jedis.publish("redisChatTest", "我是天才");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "我牛逼");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "哈哈");
    }
}
 

import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestSubscribe {
	
    public static void main(String args[]) throws Exception{
		Jedis jedis = new Jedis("api.dev.lexue.com",16479);
        jedis.auth("[email protected]");
        RedisMsgPubSubListener listener = new RedisMsgPubSubListener();
        jedis.subscribe(listener, "redisChatTest");
        System.out.println("test sub");
        //other code
       
    }
}
 

    @RequestMapping(value = "/testPublish")
    public void testPublish(HttpServletRequest request, HttpServletResponse response)throws Exception{
        response.setContentType("text/javascript");
        Jedis jedis = new Jedis("api.dev.lexue.com",16479);
        jedis.auth("[email protected]");
        jedis.publish("redisChatTest", "1111111");
        jedis.publish("redisChatTest1", "咦咦咦咦咦");
        LOG.info("testPublish  1");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "2222222");
        jedis.publish("redisChatTest1", "鵝鵝鵝鵝鵝鵝");
        LOG.info("testPublish  2");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "33333333");
        jedis.publish("redisChatTest1", "哈哈哈哈哈哈");
        LOG.info("testPublish  3");
    } 
    
    @RequestMapping(value = "/testSubscribe1")
    public void testSubscribe1(HttpServletRequest request, HttpServletResponse response)throws Exception{
        response.setContentType("text/javascript");
        Jedis jedis = new Jedis("api.dev.lexue.com",16479);
        jedis.auth("[email protected]");
        RedisMsgPubSubListener listener = new RedisMsgPubSubListener();
        jedis.psubscribe(listener, "redisChatTest*");
//        jedis.subscribe(listener, "redisChatTest1");
        LOG.info("testSubscribe1");
    }
    
    @RequestMapping(value = "/testSubscribe2")
    public void testSubscribe2(HttpServletRequest request, HttpServletResponse response)throws Exception{
        response.setContentType("text/javascript");
        Jedis jedis = new Jedis("api.dev.lexue.com",16479);
        jedis.auth("[email protected]");
        RedisMsgPubSubListener listener = new RedisMsgPubSubListener();
        jedis.subscribe(listener, "redisChatTest1");
        LOG.info("testSubscribe2");
    }