博客
关于我
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数据库面试题(2021最新版)
查看>>
MySQL数据库高并发优化配置
查看>>
mysql数据恢复
查看>>
MySQL数据的主从复制、半同步复制和主主复制详解
查看>>
mysql数据碎片整理
查看>>
MySQL数据类型
查看>>
MySQL数据类型字节长度
查看>>
mysql数据被误删的恢复方案
查看>>
MySQL数据读写分离(MaxScale)上干货!!!
查看>>
mysql整库导入、导出
查看>>
mysql文本函数和数字函数
查看>>
Mysql新建用户和数据库并授权
查看>>
mysql日志文件
查看>>
mysql日志管理学习笔记
查看>>
MySQL日期时间函数大全
查看>>
mysql时间相减的问题
查看>>
mysql时间表示和计算
查看>>
mysql更新一个表里的字段等于另一个表某字段的值
查看>>
Mysql更新时间列只改日期为指定日期不更改时间
查看>>
MySQL更新锁(for update)摘要
查看>>