AI专业者开发社区 1 号成员
  •  0 回帖  •  0 浏览  •  4 个月前
 

Java实现Redis的消息订阅和发布

1.  首先需要一个消息监听器类

package com.sogou.baike.testimport.testSubscribe;

import redis.clients.jedis.JedisPubSub;


/**


    

  • 

    Created by denglinjie on 2016/6/29.
    */
    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) {
    

    }
    

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

    }
    

    @Override
    public void onPSubscribe(String pattern, int subscribedChannels) {
    

    }
    

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

该类需要继承 JedisPubSub ，并实现其抽象方法，通过方法的名称很清楚的看出来，这个监听器是用来订阅一个频道，在订阅该频道，取消订阅，收到消息等状态会对应调用相关的方法

2.  订阅测试类

public class TestSubscribe {
    @Test
    public void testSubscribe() throws Exception{
        Jedis jedis = new Jedis("localhost");
        RedisMsgPubSubListener listener = new RedisMsgPubSubListener();
        jedis.subscribe(listener, "redisChatTest");
        //other code
    }
}

该类实现对频道 redisChatTest 的订阅监听，频道的订阅，取消订阅，收到消息都会调用 listener 对象的对应方法

如果对 Spring，MyBatis，Netty 源码分析，高并发、高性能、分布式、微服务架构的原理，JVM 性能优化、分布式架构。感兴趣可以 747981058，群内会有不定期的发放免费的资料链接，这些资料都是从各个技术网站搜集、整理出来的，如果你有好的学习资料可以私聊发我，我会注明出处之后分享给大家。

注意：subscribe 是一个阻塞的方法，在取消订阅该频道前，会一直阻塞在这，只有当取消了订阅才会执行下面的 other code，参考上面代码，我在 onMessage 里面收到消息后，调用了 this.unsubscribe(); 来取消订阅，这样才会执行后面的 other code

3.  发布消息测试类

Public class TestPublish {
    @Test
    public void testPublish() throws Exception{
        Jedis jedis = new Jedis("localhost");
        jedis.publish("redisChatTest", "Java 架构技术交流");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "加入");
        Thread.sleep(5000);
        jedis.publish("redisChatTest", "747981058");}
}

这个类向频道 redisChatTest 发布消息，第二步因为订阅了该频道，所以会收到该消息。