CentOS Redis的发布订阅模式

Redis的发布订阅模式什么是发布订阅

**任务队列:**顾名思义,就是“传递消息的队列”。与任务队列进行交互的实体有两类,一类是生产者(producer),另一类则是消费者(consumer)。生产者将需要处理的任务放入任务队列中,而消费者则不断地从任务独立中读入任务信息并执行。

发布订阅模式

其实从Pub/Sub的机制来看,它更像是一个广播系统,多个订阅者(Subscriber)可以订阅多个频道(Channel),多个发布者(Publisher)可以往多个频道(Channel)中发布消息。

可以这么简单的理解:1)Subscriber:收音机,可以收到多个频道,并以队列方式显示2)Publisher:电台,可以往不同的FM频道中发消息3)Channel:不同频率的FM频道

布订阅模式分类一个发布者,多个订阅者

如下图所示,可以作为消息队列或者消息管道。**主要应用:**通知、公告

多个发布者,一个订阅者

可以将PubSub做成独立的HTTP接口,各应用程序作为Publisher向Channel中发送消息,Subscriber端收到消息后执行相应的业务逻辑,比如写数据库,显示等等。**主要应用:**排行榜、投票、计数。

多个发布者,多个订阅者

故名思议,就是可以向不同的Channel中发送消息,由不同的Subscriber接收。**主要应用:**群聊、聊天。

发布订阅操作1)PUBLISH channel msg将信息 message 发送到指定的频道 channel 2)SUBSCRIBE channel [channel …]订阅频道,可以同时订阅多个频道3)UNSUBSCRIBE [channel …]取消订阅指定的频道, 如果不指定频道,则会取消订阅所有频道4)PSUBSCRIBE pattern [pattern …]订阅一个或多个符合给定模式的频道,每个模式以 * 作为匹配符,比如 it* 匹配所 有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等), news.* 匹配所有 以 news. 开头的频道( news.it 、 news.global.today 等等),诸如此类5)PUNSUBSCRIBE [pattern [pattern …]]退订指定的规则, 如果没有参数则会退订所有规则6)PUBSUB subcommand [argument [argument …]]查看订阅与发布系统状态

_注意:_使用发布订阅模式实现的任务队列,当有客户端订阅channel后只能收到后续发布到该频道的消息,之前发送的不会缓存,必须Provider和Consumer同时在线。

## 1.订阅fm9922频道SUBSCRIBE fm9922## 2.发布者,往fm9922频道发消息publish fm9922 ‘today is a good day’# 注意:订阅模式不支持输入中文

一个订阅者订阅多个频道## 1.订阅所有频道127.0.0.1:6379> PSUBSCRIBE *## 2.发布127.0.0.1:6379> PUBLISH fm9100 ‘kiss kiss'(integer) 1127.0.0.1:6379> PUBLISH fm9200 ‘kiss too'(integer) 1127.0.0.1:6379> PUBLISH fm9300 ‘one too'(integer) 1## 3.订阅多个频道127.0.0.1:6379> PSUBSCRIBE fm91.8 fm92.8 fm93.8Reading messages… (press Ctrl-C to quit)1) "psubscribe"2) "fm91.8"3) (integer) 11) "psubscribe"2) "fm92.8"3) (integer) 21) "psubscribe"2) "fm93.8"3) (integer) 3## 4.发布127.0.0.1:6379> PUBLISH fm91.8 ‘one two'(integer) 1127.0.0.1:6379> PUBLISH fm93.8 ‘one two'(integer) 1127.0.0.1:6379> PUBLISH fm92.8 ‘one two'(integer) 1127.0.0.1:6379> PUBLISH fm95.8 ‘one two'(integer) 0127.0.0.1:6379> PUBLISH fm96.8 ‘one two'(integer) 0

多个订阅者订阅一个频道## 多个订阅者127.0.0.1:6379> SUBSCRIBE fm91.8Reading messages… (press Ctrl-C to quit)1) "subscribe"2) "fm91.8"3) (integer) 11) "message"2) "fm91.8"3) "one two there"127.0.0.1:6379> SUBSCRIBE fm91.8Reading messages… (press Ctrl-C to quit)1) "subscribe"2) "fm91.8"3) (integer) 11) "message"2) "fm91.8"3) "one two there"## 发布者127.0.0.1:6379> PUBLISH fm91.8 ‘one two there'(integer) 2

发布订阅模式和消息队列对比

客户端在执行订阅命令之后进入了订阅状态,只能接收 SUBSCRIBE 、PSUBSCRIBE、 UNSUBSCRIBE 、PUNSUBSCRIBE 四个命令。 开启的订阅客户端,无法收到该频道之前的消息,因为 Redis 不会对发布的消息进行持久化。 和很多专业的消息队列系统(例如Kafka、RocketMQ、RabbitMQ)相比,Redis的发布订阅略显粗糙。

**例如:**无法实现消息堆积和回溯。但胜在足够简单,如果当前场景可以容忍的这些缺点,也不失为一个不错的选择。

思想如钻子,必须集中在一点钻下去才有力量

CentOS Redis的发布订阅模式

相关文章:

你感兴趣的文章:

标签云: