Redis中消息队列/发布和订阅的介绍及代码实现

柔情只为你懂 2023-07-14 10:44 14阅读 0赞

# 一、概念 #

**发布订阅是一种应用程序(系统)之间的通讯 传递数据的技术手段**  
特别是在异构(不同语言)的系统之间作用非常明显

发布订阅可以实现**应用(系统)之间的解耦合**  
类似于微信中关注公众号/订阅号 那么订阅者能及时获取到最新的内容 或者微博的订阅也是类似  
日常生活中听广播 看电视 都需要有信息的发布者 **收听的人需要先订阅**

发布和订阅是**一对多**的关系

*  **订阅**：对某个内容感兴趣 需要实时获取新的内容  
    那么当关注的内容一旦有变化就能立即得到通知  
    这是"**多**"的一方
 *  **发布**：提供某个内容 将内容信息发送给多个对此内容感兴趣的订阅者  
    是有主动权的一方  
    是"**一**"的一方  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70]  
    发布订阅应用在**即时通信**应用中较多  
    例如网络聊天室 实时广播 实时提醒等  
    滴滴打车的抢单 外卖的抢单 微信群发红包 抢红包都可以用发布订阅来实现

--------------------

# 二、Redis的发布和订阅 #

Redis的发布订阅(pub/sub)是一种消息通信模式  
**发送者(publish)发送消息 订阅者(subscribe)接收消息**  
发布订阅也叫生产者-消费者模式 是实现消息队列的一种方式

**订阅者先订阅频道 然后发布者向频道发送消息 所有订阅者都能接收到  
订阅者订阅一个频道后会一直监听 直到手动退出**

#### 订阅示意图： ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 1]

#### 发布示意图： ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 2]

--------------------

## 1、操作命令 ##

**①**、**订阅**一个或多个**符合给定模式**的频道  
每个模式以 \* 作为匹配符 比如 it\* 匹配所有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等)  
news.\* 匹配所有以 news. 开头的频道( news.it 、 news.global.today 等等)，诸如此类

subscribe pattern [pattern ...]

--------------------

**②**、**订阅给定的**一个或多个频道的信息

subscribe channel [channel ...]

--------------------

**③**、将信息**发送**到指定的频道

publish channel message

--------------------

**④**、**查看**订阅与发布系统的**状态**

pubsub subcommand [argument [argument ...]]

--------------------

**⑤**、**退订**所有**给定模式**的频道

punsubscribe [pattern [pattern ...]]

--------------------

**⑥**、**退订给定的**频道

unsubscribe [channel [channel ...]]

--------------------

## 2、命令行方式实现 ##

本例中有一个发布者和三个订阅者  
切记：先订阅再发布

**订阅：**  
![在这里插入图片描述][20200314142244814.png]  
**发布：**  
返回的3代表有三个订阅者收到了消息  
![在这里插入图片描述][20200314142303763.png]  
**三个订阅者同时收到消息：**  
格式：  
1) 返回值类型  
2) 该消息的频道名称  
3) 该消息的内容  
![在这里插入图片描述][20200314142354744.png]  
**查看当前的活跃频道：**  
![在这里插入图片描述][20200314142424485.png]  
**退订：**  
![在这里插入图片描述][20200314142447115.png]

--------------------

## 3、Java代码方式实现 ##

**JedisPubSub类**：Jedis中的`JedisPubSub`类是Jedis的一个抽象类 该类**定义了publish/subscribe的回调方法**  
可通过**继承JedisPubSub类**来**重写回调方法** 从而实现Java中的Redis发布订阅  
**当Redis发布或订阅时 会调用这些回调方法 在回调方法中实现业务逻辑**

`onMessage()`：当发布者发布消息时 会执行订阅者的onMessage()回调方法来**接收发布的消息**  
可在此方法中实现消息接收后的自定义的业务逻辑处理 例如访问数据库等

使用前须导入Jedis依赖：

<dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>2.9.0</version>
    </dependency>

#### 订阅者类： ####

public class RedisSubscribe extends JedisPubSub {
        
        @Override
        public void onMessage(String channel, String message) {
        
            // 当订阅者收到消息 此方法会自动被调用
            System.out.println("订阅的频道为："+channel);
            System.out.println("收到的消息为："+message);
            System.out.println("时间为："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        }
    
        public static void main(String[] args) {
        
            System.out.println("订阅者启动 等待接收消息...");
    
            // 创建Jedis对象
            Jedis jedis=new Jedis("192.168.1.1",6379);
    
            // 我设了个密码 所以需要认证 没设密码的可以略过
            jedis.auth("123456");
    
            // 创建订阅者对象：明确谁在订阅
            RedisSubscribe redisSubscribe =new RedisSubscribe();
    
            // 订阅消息
            jedis.subscribe(redisSubscribe,"classmate");
        }
    }

### 发布者类： ###

public class RedisPublish {
        
        public static void main(String[] args) {
        
            System.out.println("发布者启动...");
    
            // 创建Jedis对象
            Jedis jedis=new Jedis("192.168.1.1",6379);
    
            // 我设了个密码 所以需要认证 没设密码的可以略过
            jedis.auth("123456");
    
            // 发布消息
            jedis.publish("classmate","同学们，今晚有网课哦!");
            System.out.println("消息发送完毕!");
        }
    }

### 效果： ###

![在这里插入图片描述][20200314143834741.png]  
![在这里插入图片描述][20200314143842966.png]  
订阅者订阅一个频道后会一直监听 直到手动退出

--------------------

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70]: /images/20230529/17c05c22100842b8bf039335f6812886.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 1]: /images/20230529/0acf4c04bae74f28a5dcfbb719b1c899.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L1BpY29uam8_size_16_color_FFFFFF_t_70 2]: /images/20230529/aa939d387ad34da28adaa94a9382671c.png
[20200314142244814.png]: /images/20230529/771178a7c84546049e6356acb8b070e8.png
[20200314142303763.png]: /images/20230529/3867ecabb71946ad872af53e65c586ea.png
[20200314142354744.png]: /images/20230529/65d3fbb0a8e743a395403496ee8e5aa4.png
[20200314142424485.png]: /images/20230529/b158b758406842f09f9bd92deba787ea.png
[20200314142447115.png]: /images/20230529/dd2e4435c7d141a0acefaa8c79e26355.png
[20200314143834741.png]: /images/20230529/33e2a11a2b4548e5b56b4a6d77d901bd.png
[20200314143842966.png]: /images/20230529/746b4191fcdf494e9c6bde043ba381a8.png