Java实现Redis发布订阅

短命女 2021-09-22 14:18 285阅读 0赞

因为项目需求，要实现redis的发布订阅功能，百度了下，然后把自己的经验总结了下

具体的jedis配置就不再说了，可以看上一篇内容

### 简介 ###

Redis提供了基于“发布/订阅”模式的消息机制，此种模式下，消息发布者和订阅者不进行直接通信，发布者客户端向指定的频道（channel）发布消息，订阅该频道的每个客户端都可以收到该消息（频道没有”创建“的概念，可以直接订阅、亦可直接发布消息）。

下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系：

![70][]

当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端：

![70 1][]

### 实例 ###

以下实例演示了发布订阅是如何工作的。首先在我们封装的JedisUtils中加入发布和订阅操作的方法：

/**
     * 发布一个消息
     *
     * @param channel
     * @param message
     */
    public void publishMsg(String channel, String message) {
        try {
            jedis.publish(channel, message);
        } catch (Exception e) {
        }
    }

参数channel是消息的频道，message是消息的内容。在Junit测试或者其他的地方，使用工具类的此方法即可发布一个消息。

接收消息代码稍微复杂一些。首先定义一个类继承JedisPubSub，然后实现其中未实现的方法，最后在工具类JedisUtils中定义一个操作的方法即可。代码如下：

public class RedisMsgSubListener 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);
        }
    
    }

在工具类JedisUtils中定义一个操作的方法

/**
     * 接收消息。在main方法调用后，会一直执行下去。当有发布对应消息时，就会在jedisPubSub中接收到！
     *
     * @param jedisPubSub
     * @param channels
     */
    public void subscribeMsg(JedisPubSub jedisPubSub, String channels) {
        try {
            jedis.subscribe(jedisPubSub, channels);
        } catch (Exception e) {
        }
    }

下面写个方法测试下吧：

public class PubTest {
        JedisUtil4 jedisUtil;
        public void  publishMsg(){
            jedisUtil= JedisUtil4.getInstance();
            jedisUtil.publishMsg("test","hello world!");
        }
    
        public static void main(String[] args) {
            PubTest pubTest=new PubTest();
            pubTest.publishMsg();
        }
    }
    public class SubTest {
        JedisUtil4 jedisUtil;
        public void subscribeMsg(){
            jedisUtil=JedisUtil4.getInstance();
            RedisMsgSubListener pubsub = new RedisMsgSubListener();
            jedisUtil.subscribeMsg(pubsub, "test");
    
        }
    
        public static void main(String[] args) {
            new SubTest().subscribeMsg();
        }
    }

建议测试时，分开方法进行测试。其中publishMsg()方法是用来测试发布消息的,subscribeMsg()是用来测试接收订阅消息的。这里只是使用了普通订阅，大家还可以使用模式订阅。执行subscribeMsg()方法后，客户端会一直开启着，不会关闭。另外，在其他的redis客户端中发布一条消息，控制台就会立刻输出该消息。

参考：

[http://blog.csdn.net/abcd898989/article/details/51697596][http_blog.csdn.net_abcd898989_article_details_51697596]

[http://www.runoob.com/redis/redis-pub-sub.html][http_www.runoob.com_redis_redis-pub-sub.html]

[https://my.oschina.net/u/1444945/blog/648797][https_my.oschina.net_u_1444945_blog_648797]

[http://kingxss.iteye.com/blog/1420264][http_kingxss.iteye.com_blog_1420264]

[https://my.oschina.net/coderknock/blog/983545][https_my.oschina.net_coderknock_blog_983545]

[70]: /images/20210920/64dd619c593b40058e8fabd96fd3939e.png
[70 1]: /images/20210920/1ff7e58bcc0347098db0279412db243c.png
[http_blog.csdn.net_abcd898989_article_details_51697596]: http://blog.csdn.net/abcd898989/article/details/51697596
[http_www.runoob.com_redis_redis-pub-sub.html]: http://www.runoob.com/redis/redis-pub-sub.html
[https_my.oschina.net_u_1444945_blog_648797]: https://my.oschina.net/u/1444945/blog/648797
[http_kingxss.iteye.com_blog_1420264]: http://kingxss.iteye.com/blog/1420264
[https_my.oschina.net_coderknock_blog_983545]: https://my.oschina.net/coderknock/blog/983545