2021-05-09 21:53  阅读(4926)
文章分类:死磕 Redis 文章标签:死磕 Java死磕 Redis
© 版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。

Redis 提供了基于“发布/订阅”模式的消息机制,发送者(publish)发布消息,订阅者(subscribe)接收消息,两者之间不需要进行直接通信,他们之间通过频道进行消息传递。发布者向指定的频道(channel)发布消息,订阅了该频道的订阅者都可以接收到该消息。

202105092153115261.png

Redis 中相关的命令如下:

  • PSUBSCRIBE pattern [pattern ...]:订阅一个或多个符合给定模式的频道。
  • PUBSUB subcommand [argument [argument ...]]:查看订阅与发布系统状态。
  • PUBLISH channel message :将信息发送到指定的频道。
  • PUNSUBSCRIBE [pattern [pattern ...]]:退订所有给定模式的频道。
  • SUBSCRIBE channel [channel ...]:订阅给定的一个或多个频道的信息。
  • UNSUBSCRIBE [channel [channel ...]]:退订给定的频道。

命令演示

开启 4 个客户端,1 个消息发布者,3 个消息订阅者。

202105092153117202.png

1、2、3 为消息订阅者,4 为消息发布者。

在 1 、2、3 消息订阅者分别执行:subscribe channel1,订阅 channel 频道:

202105092153125313.png

在 4 消息发布者执行:publish channel1 "hello,boys!!!!",向频道 channel1 发布消息:

202105092153128374.png

返回值为 3 ,表示有 3 个订阅者。同时,3 个订阅者应该都接收到了消息。

202105092153130705.png

  • message:返回值类型,message 表示消息
  • channel1:消息的频道名称
  • hello,boys!!!!!:消息的内容

其他的命令就不演示了。

程序演示

我们通过一个简单的程序来演示 Redis 的发布/订阅模式。

首先是发布者:

    public class Publisher {
    
        public static void main(String[] args) {
            Jedis jedis = new Jedis("127.0.0.1",6379);
    
            System.out.println("我是发布者....");
            jedis.publish("channel2","hello,girls.....");
    
            System.out.println("消息发布完毕....");
    
        }
    }

然后是订阅者。

    public class Subscriber extends JedisPubSub {
    
        @Override
        public void onMessage(String channel, String message) {
            System.out.println("订阅渠道:[" + channel + "],收到的消息:" + message);
        }
    
        public static void main(String[] args) {
            Jedis jedis = new Jedis("127.0.0.1",6379);
    
            Subscriber subscriber = new Subscriber();
            // 从Redis订阅
            System.out.println("我是订阅者.....");
            jedis.subscribe(subscriber, "channel2");
        }
    }

JedisPubSub 类是 Jedis 的一个抽象类,此类定义了 publish /subscribe 的回调方法,通过继承 JedisPubSub 类,重写回调方法就可以实现 Redis 的发布订阅

  • onMessage():发布者发布消息时,会执行订阅者的回调方法 onMessage(),接收发布的 消息。

先运行订阅者,然后运行发布者,就可以得到我们想要的效果,如下:

202105092153134756.png

202105092153136587.png

发布订阅是一种应用程序之间通信和传递数据的通信手段,这种模式在我们实际应用中得到广泛的使用,比如网络聊天、实时广播、提醒、微信公众号等等,它实现了应用之间的解耦。

点赞(7)
版权归原创作者所有,任何形式转载请联系作者; Java 技术驿站 >> 【死磕 Redis】—– 发布与订阅
上一篇
【死磕 Redis】—– 布隆过滤器
下一篇
【死磕 Redis】—– 如何排查 Redis 中的慢查询