【死磕 Redis】—— 发布与订阅

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

Redis 中相关的命令如下：

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

命令演示

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

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

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

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

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

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(),接收发布的

消息。

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

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

Java 面试宝典是大明哥全力打造的 Java 精品面试题，它是一份靠谱、强大、详细、经典的 Java 后端面试宝典。它不仅仅只是一道道面试题，而是一套完整的 Java 知识体系，一套你 Java 知识点的扫盲贴。

它的内容包括：

大厂真题：Java 面试宝典里面的题目都是最近几年的高频的大厂面试真题。
原创内容：Java 面试宝典内容全部都是大明哥原创，内容全面且通俗易懂，回答部分可以直接作为面试回答内容。
持续更新：一次购买，永久有效。大明哥会持续更新 3+ 年，累计更新 1000+，宝典会不断迭代更新，保证最新、最全面。
覆盖全面：本宝典累计更新 1000+，从 Java 入门到 Java 架构的高频面试题，实现 360° 全覆盖。
不止面试：内容包含面试题解析、内容详解、知识扩展，它不仅仅只是一份面试题，更是一套完整的 Java 知识体系。
宝典详情：https://www.yuque.com/chenssy/sike-java/xvlo920axlp7sf4k
宝典总览：https://www.yuque.com/chenssy/sike-java/yogsehzntzgp4ly1
宝典进展：https://www.yuque.com/chenssy/sike-java/en9ned7loo47z5aw

目前 Java 面试宝典累计更新 400+ 道，总字数 42w+。大明哥还在持续更新中，下图是大明哥在 2024-12 月份的更新情况：

想了解详情的小伙伴，扫描下面二维码加大明哥微信【daming091】咨询

同时，大明哥也整理一套目前市面最常见的热点面试题。微信搜[大明哥聊 Java]或扫描下方二维码关注大明哥的原创公众号[大明哥聊 Java] ，回复【面试题】即可免费领取。

阅读全文