redis 学习（12）-- redis 发布订阅

深藏阁楼爱情的钟 2021-12-05 17:13 271阅读 0赞

## redis 发布订阅 ##

### 发布订阅模式中的角色 ###

*  发布者（publisher）
 *  订阅者（subscriber）
 *  频道（channel）

如图所示：

![1240][]

发布者发布消息到频道，订阅了频道的订阅者可以收到消息，订阅者可以订阅不同的频道。

### 通信模型 ###

*  RedisServer中可以创建若干channel
 *  一个订阅者可以订阅多个channel
 *  当发布者向一个频道中发布一条消息时，所有的订阅者都将会收到消息
 *  Redis的发布订阅模型没有消息积压功能，即新加入的订阅者收不到发布者之前发布的消息
 *  当订阅者收到消息时，消息内容如下
    
     *  第一行：固定内容message
     *  第二行：channel的名称
     *  第三行：收到的新消息

### 发布订阅的 API ###

<table> 
 <thead> 
  <tr> 
   <th style="text-align:center;">命令</th> 
   <th style="text-align:center;">含义</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td style="text-align:center;">publish channel message</td> 
   <td style="text-align:center;">向指定的channel中发布消息</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">subscribe channel1 [channel2...]</td> 
   <td style="text-align:center;">订阅给定的一个或多个渠道的消息</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">unsubcribe [channel1 [channel2...]]</td> 
   <td style="text-align:center;">取消订阅给定的一个或多个渠道的消息</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">psubscribe pattern1 [pattern2...]</td> 
   <td style="text-align:center;">订阅一个或多个符合给定模式的频道</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">punsubscribe [pattern1 [pattern2...]]</td> 
   <td style="text-align:center;">退订所有给定模式的频道</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">pubsub channel</td> 
   <td style="text-align:center;">列出至少有一个订阅者的频道</td> 
  </tr> 
  <tr> 
   <td style="text-align:center;">pubsub numsub [channel...]</td> 
   <td style="text-align:center;">列出给定频道的订阅者数量</td> 
  </tr> 
 </tbody> 
</table>

### 演示 ###

![1240][1240 1]

### 消息队列和发布订阅区别 ###

我们来看一张消息队列通信模型的图：

![1240][1240 2]

可以看到：

> 发布订阅模式是将消息通知每一个订阅者，消息队列是消息发布者发表消息后只有一个消息订阅者收得到，订阅者争抢接受消息，这是一个抢的功能。

### 发布订阅 - Jedis ###

//订阅 public void testSubscribe() { Jedis jedis = new Jedis("127.0.0.1" , 6381); jedis.subscribe(new JedisPubSub() { @Override public void onMessage(String channel, String message) { System.out.println("receive channel ["+channel+"] message ["+message+"]"); } } , "aliTV" , "googleTV"); } //发布 public void testPublish() { Jedis jedis = new Jedis("127.0.0.1" , 6381); jedis.publish("aliTV" , "I am xxx"); jedis.publish("googleTV" , "My age is 21"); }

转载于:https://www.cnblogs.com/weixuqin/p/10962408.html

[1240]: /images/20211205/a08a4600ac3943bf8709f7bb9fc59990.png
[1240 1]: /images/20211205/91c0a6f58b864fe0bc96896091a2f86a.png
[1240 2]: /images/20211205/a1ba126382724d4bb914c80c142bc40f.png