博客
关于我
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 常见错误
查看>>
mysql 常见问题
查看>>
MYSQL 幻读(Phantom Problem)不可重复读
查看>>
mysql 往字段后面加字符串
查看>>
mysql 快速自增假数据, 新增假数据,mysql自增假数据
查看>>
Mysql 批量修改四种方式效率对比(一)
查看>>
Mysql 报错 Field 'id' doesn't have a default value
查看>>
MySQL 报错:Duplicate entry 'xxx' for key 'UNIQ_XXXX'
查看>>
Mysql 拼接多个字段作为查询条件查询方法
查看>>
mysql 排序id_mysql如何按特定id排序
查看>>
Mysql 提示:Communication link failure
查看>>
mysql 插入是否成功_PDO mysql:如何知道插入是否成功
查看>>
Mysql 数据库InnoDB存储引擎中主要组件的刷新清理条件:脏页、RedoLog重做日志、Insert Buffer或ChangeBuffer、Undo Log
查看>>
mysql 数据库中 count(*),count(1),count(列名)区别和效率问题
查看>>
mysql 数据库备份及ibdata1的瘦身
查看>>
MySQL 数据库备份种类以及常用备份工具汇总
查看>>
mysql 数据库存储引擎怎么选择?快来看看性能测试吧
查看>>
MySQL 数据库操作指南:学习如何使用 Python 进行增删改查操作
查看>>
MySQL 数据库的高可用性分析
查看>>
MySQL 数据库设计总结
查看>>