Redis发布订阅模式（7）

  • Z时代
  • 2024-01-10
  • 分类：综合

编程

1、如果生产者生产消息的速度远大于消费者消费消息的速度，List会占用大量的内存。

2、消息的实时性降低。list还提供了一个阻塞的命令：blpop，没有任何元素可以弹出的时候，连接会被阻塞。

基于list实现的消息队列，不支持一对多的消息分发。

发布订阅模式

除了通过list实现消息队列之外，Redis还提供了一组命令实现发布/订阅模式。

这种方式，发送者和接收者没有直接关联（实现了解耦），接收者也不需要持续尝试获取消息。

订阅频道

首先，我们有很多的频道（channel），我们也可以把这个频道理解成queue。订阅者可以订阅一个或者多个频道。消息的发布者（生产者）可以给指定的频道发布消息。只要有消息到达了频道，所有订阅了这个频道的订阅者都会收到这条消息。

需要注意的注意是，发出去的消息不会被持久化，因为它已经从队列里面移除了，所以消费者只能收到它开始订阅这个频道之后发布的消息。

下面我们来看一下发布订阅命令的使用方法。

订阅者订阅频道：可以一次订阅多个，比如这个客户端订阅了3个频道。

127.0.0.1:6379> subscribe topic1 topic2 topic3
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "topic1"
3) (integer) 1
1) "subscribe"
2) "topic2"
3) (integer) 2
1) "subscribe"
2) "topic3"
3) (integer) 3

发布者可以向指定频道发布消息（并不支持一次向多个频道发送消息）：

127.0.0.1:6379> publish topic1 222222
(integer) 1
### 消息订阅方收到的信息
1) "message"
2) "topic1"
3) "222222"

取消订阅（不能在订阅状态下使用）：

unsubscribe topic1

按规则（Pattern）订阅频道

支持?和*占位符。?代表一个字符，*代表0个或者多个字符。

消费端（订阅方）
psubscribe news* 
psubscribe news-word 
psubscribe *message
生产者（发布方）
publish news-word1 111111
publish news-message 1111
publish sms-message 1111

注意：Redis无法保证消息的可靠投递，当发送的消息没有接收方时，会造成数据丢失。正式环境建议使用专业MQ。

以上是 Redis发布订阅模式（7） 的全部内容， 来源链接： utcz.com/z/514336.html

回到顶部