博客
关于我
Redis 高级特性(2)—— 发布 订阅模式
阅读量:503 次
发布时间:2019-03-07

本文共 1867 字,大约阅读时间需要 6 分钟。

Redis 高级特性 —— 发布订阅

1. 发布-订阅介绍

“发布-订阅”模式包含两种角色,分别为发布者和订阅者。订阅者可以订阅一个或者若干个频道(channel),而发布者可以向指定的频道发送消息,所有订阅此频道的订阅者都可以收到此消息。

2. 发布-订阅命令

发布模式的命令为:

publish channel message

订阅模式的命令为:

subscribe channel [channel...]

3. 发布-订阅实例

publish 命令的返回值表示接收到这条消息的订阅者数量,没有客户端订阅该频道时返回 0 。

127.0.0.1:6379> publish channel "hello"(integer) 0127.0.0.1:6379>

发出去的消息不会做持久化处理,也就是说当客户端订阅该频道后,只能收到后续发布到该频道的消息,之前发送的就收不到了。

127.0.0.1:6379> subscribe channelReading messages... (press Ctrl-C to quit)1) "subscribe"2) "channel"3) (integer) 1

进入订阅状态的客户端可能收到 3 种类型的回复,每种类型的回复都包含 3 个值,第一个是消息的类型,根据消息类型的不同,第二、三值的含义也不同。

消息类型取值有以下 3 种:

  • subscribe

    表示订阅成功的反馈信息,第二个值是订阅成功的频道名称,第三个值是当前客户端订阅的频道数量;

  • message

    表示接收到的消息,第二个值表示产生消息的频道名称,第三个值是消息的内容;

  • unsubscribe

    表示成功取消订阅某个频道,第二个值是对应的频道名称,第三个值是当前客户端订阅的频道数量;当此值为 0 时客户端会退出订阅状态,之后就可以执行其它非 “发布-订阅” 模式的命令了;

wohu@iZm5egn5zptnov4j3oxh4fZ:~$ redis-cli127.0.0.1:6379> publish channel "hello"(integer) 0127.0.0.1:6379> publish channel "How are you"(integer) 1127.0.0.1:6379>
127.0.0.1:6379> subscribe channelReading messages... (press Ctrl-C to quit)1) "subscribe"2) "channel"3) (integer) 11) "message"2) "channel"3) "How are you"

4. 多频道发布订阅模式

以上只是单个频道的发布订阅, 如果想订阅多个频道,则需要使用 使用 psubscribe 命令,后面跟着我们要订阅的频道的表达式,* 代表任意值

订阅多个频道:

127.0.0.1:6379> PSUBSCRIBE greets*Reading messages... (press Ctrl-C to quit)1) "psubscribe"2) "greets*"3) (integer) 1

发布消息:

root@171669ba8bdb:/data# redis-cli127.0.0.1:6379> publish greet1 "hello"(integer) 0127.0.0.1:6379> publish greets_1 "hello"(integer) 1127.0.0.1:6379> publish greets_2 "world"(integer) 1127.0.0.1:6379> publish greets_3 "I am redis"(integer) 1127.0.0.1:6379>

订阅者收到的消息:

127.0.0.1:6379> psubscribe greets*Reading messages... (press Ctrl-C to quit)1) "psubscribe"2) "greets*"3) (integer) 11) "pmessage"2) "greets*"3) "greets_1"4) "hello"1) "pmessage"2) "greets*"3) "greets_2"4) "world"1) "pmessage"2) "greets*"3) "greets_3"4) "I am redis"

转载地址:http://njkjz.baihongyu.com/

你可能感兴趣的文章
MySql中 delimiter 详解
查看>>
MYSQL中 find_in_set() 函数用法详解
查看>>
MySQL中auto_increment有什么作用?(IT枫斗者)
查看>>
MySQL中B+Tree索引原理
查看>>
mysql中cast() 和convert()的用法讲解
查看>>
mysql中datetime与timestamp类型有什么区别
查看>>
MySQL中DQL语言的执行顺序
查看>>
mysql中floor函数的作用是什么?
查看>>
MySQL中group by 与 order by 一起使用排序问题
查看>>
mysql中having的用法
查看>>
MySQL中interactive_timeout和wait_timeout的区别
查看>>
mysql中int、bigint、smallint 和 tinyint的区别、char和varchar的区别详细介绍
查看>>
mysql中json_extract的使用方法
查看>>
mysql中json_extract的使用方法
查看>>
mysql中kill掉所有锁表的进程
查看>>
mysql中like % %模糊查询
查看>>
MySql中mvcc学习记录
查看>>
mysql中null和空字符串的区别与问题!
查看>>
MySQL中ON DUPLICATE KEY UPDATE的介绍与使用、批量更新、存在即更新不存在则插入
查看>>
MYSQL中TINYINT的取值范围
查看>>