Redis发布者/订阅者模式

相关命令

发布/订阅

SUBSCRIBE, UNSUBSCRIBE and PUBLISH实现了发布/订阅消息传递范式(引自维基百科),发送者(发布者)没有被编程为发送信息到特定的接受者(订阅者)。相反,发布消息被定义为通道,而不知道可能有哪些(如果有的话)订阅者。订阅者传递兴趣到一个或者更多的通道,并且仅接受感兴趣的消息,而不必知道发布者(如果有的话)是谁。发布者和订阅者的解耦可以实现更多的可伸缩性和更动态网络拓扑。

例如,为了订阅foobar,客户端发出了一个SUBSCRIBE并提供通道的名称。

SUBSCRIBE foo bar

其他客户端发送到这些通道的消息,将会被Redis推送到所有已订阅的客户端。

一个客户端已经订阅一个或者多个通道后不应该再发送命令,尽管它可以订阅或者取消订阅其他通道。订阅和取消订阅操作以消息形式回复,因此客户端仅能阅读一个连贯的消息流,第一个元素指示消息的类型。订阅客户端可以使用的命令有:SUBSCRIBE, PSUBSCRIBE, UNSUBSCRIBE, PUNSUBSCRIBE, PINGQUIT

请注意,一旦处于订阅模式,redis-cli将不会接受任何命令,并且只能使用Ctrl-C来退出这个模式。

已发布消息的格式

一条消息是含有3个元素的数组回复.

第一个元素是消息的类型:

  • subscribe:意味着我们成功的订阅了回复中第二个元素所代表的通道。第三个参数代表我们当前订阅的通道的数量。
  • unsubscribe:意味着我们成功的取消了回复中第二个参数所代表的通道的订阅。第三个参数代表我们当前订阅的通道的数量。当最后一个参数是0时,我们不再订阅任何通道,并且客户端可以发布任何类型的Redis命令,因为我们已经退出Pub/Sub状态了。
  • message:它代表的是接受一条由其他客户端发送的PUBLISH命令结果的消息。第二个元素是原始通道的名称,第三个参数代表的是实际的消息负载。

数据库 & 域

Pub/Sub跟键空间没有关联。它被设计为在任何层级上都不会被干扰,包括数据库号码。

在db 10上发布,将会被db 1上的订阅者听到。

如果你需要一些类型的域,使用环境的名称作为通道的前缀(test,staging,production,...)。

Wire protocol example

SUBSCRIBE first second
*3
$9
subscribe
$5
first
:1
*3
$9
subscribe
$6
second
:2

此时,我们从另外的客户端向名为second的通道发送一个PUBLISH操作:

> PUBLISH second Hello

这是第一个客户端接收到的:

*3
$7
message
$6
second
$5
Hello

现在这个客户端使用UNSUBSCRIBE命令不加任何参数,从所有的通道中取消订阅自己。

UNSUBSCRIBE
*3
$11
unsubscribe
$6
second
:1
*3
$11
unsubscribe
$5
first
:0

模式匹配订阅

Redis的发布者/订阅者(Pub/Sub)实现支持模式匹配。客户端可以订阅全局风格(glob-style)模式,以便接收名称与给定模式匹配的所有通道的所有消息。

例如:

PSUBSCRIBE news.*

将会接收到所有发送到news.art.figurative,news.music.jazz等通道上的消息。所有的全局风格(glob-style)模式都是有效的,所以多通配符是被支持的。

PUNSUBSCRIBE news.*

然后将所有客户端从该模式取消订阅。这次调用不会影响其他订阅。

由于模式匹配而接收到的消息,以不同的格式发送:

  • 这种类型的消息是pmessage:它是由另一个客户端发送的PUBLISH命令接收到的消息,匹配一个模式匹配的订阅。第二个元素是原始的模式匹配,地上那个元素是原始的通道名称,最后一个元素是实际的消息负载。

SUBSCRIBEUNSUBSCRIBE相似, PSUBSCRIBEPUNSUBSCRIBE 命令在系统发送psubscribepunsubscribe类型的消息时被确认,使用与subscribeunsubscribe相同的消息格式。

同时匹配模式和通道的消息订阅

如果一个客户端订阅多个模式匹配到一条已发布的消息,或者它同时订阅模式和通道匹配该消息,那么它可能会多次接收一条消息。就像下面的例子:

SUBSCRIBE foo
PSUBSCRIBE f*

在上面的例子中,如果一条消息被发送到通道foo,客户端将会接收到两个消息:一个是message类型,另一个是pmessage类型。

模式匹配的订阅意义

subscribe, unsubscribe, psubscribepunsubscribe消息类型中,最后一个参数是仍在活动中的订阅数量。这个数字实际上是客户端仍在订阅的通道和模式的总数。因此,仅当由于从通道和模式取消订阅导致这个数字降至0时,客户端才将会退出发布者/订阅者(Pub/Sub)状态。

编程示例

Pieter Noordhuis提供了一个非常棒的例子,使用EventMachine 和 Redis创建了一个多用户高性能web聊天室

客户端库的实现提示

因为接受的所有消息都包含原始的订阅信息,导致消息传递给(消息类型的通道,pmessage类型的原始模式)客户端类库需要绑定原始的订阅来回调(可以是匿名函数,块,函数指针),使用哈希表。

当接收到消息可以执行O(1)时间复杂度的查找,以便将消息传递给注册的回调。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,817评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,329评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,354评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,498评论 1 284
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,600评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,829评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,979评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,722评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,189评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,519评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,654评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,329评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,940评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,762评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,993评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,382评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,543评论 2 349

推荐阅读更多精彩内容