Redis的发布订阅

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
云数据库 Tair(兼容Redis),内存型 2GB
简介: Redis的发布订阅

前沿:一种通信机制-->一般由队列来实现,会存在两个东西,发送者,订阅者,发送者通过消息管道发送内容给订阅者,订阅者通过消息管道获取发送者的信息

Redis发布订阅(pub/sub)是一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息,我们的微信公众号,微博.以及关注up主,这种关注系统 都是类似的机制和场景

Redis客户端可以订阅任意数量的频道(比如我们bilibili一个用户可以关注很多up主)

订阅/发布消息流程图

必须有以下三个条件才能实现基本的消息订阅

1:消息发送(发布)者

2:频道(中间件),发送者通过它传给订阅者,订阅者通过它得到发送者发送到内容

3:消息(订阅)接受者

暂时无法在文档外展示此内容

简单的模型

下图展示了频道channel1,以及订阅这个频道的三个客户端client1,client2,client4他们两者直接的关系

暂时无法在文档外展示此内容

当有新的消息publish命令发送给频道channel1时,这个消息就会被发送给订阅它的三个客户端

暂时无法在文档外展示此内容

Redis中发布订阅的相关命令

这些命令被广泛的用于构建即时通信应用,比如网络聊天室(chatroom)和实时广播,实时提醒等场景

网络异常,图片无法展示
|

做一个简单的例子测试,订阅者订阅发送者,发送者发送内容给订阅者

1 订阅端:订阅者订阅频道方便接收发送者以后给频道发送的内容

127.0.0.1:6379> subscribe weiyihe #订阅一个叫weiyihe的频道
Reading messages... (press Ctrl-C to quit) #订阅成功 按ctrl+c退订频道(退出)
#订阅成功,等待读取推送的信息
1) "subscribe"
2) "weiyihe" #订阅了一个叫weiyihe的频道
3) (integer) 1 #当前订阅了一个频道
1) "message" #消息
2) "weiyihe" #来自那个频道名的消息
3) "hello,weiyihe" #消息的具体内容,可能是一片文章,也可能是一个对象.频道接送出来的消息
1) "message" #消息
2) "weiyihe" #频道名
3) "hello,redis" #频道接送出来的消息
127.0.0.1:6379> subscribe CCTV #订阅CCTV
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "CCTV" #频道名
3) (integer) 1
1) "message"
2) "CCTV"
3) "studyTimeNow" #频道发送到内容
#当然 也是可以同时订阅多个频道的
127.0.0.1:6379> subscribe pindao1 pindao2 #订阅两个频道
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "pindao1"
3) (integer) 1
1) "subscribe"
2) "pindao2"
3) (integer) 2 #当前订阅了两个频道
1) "message"
2) "pindao1"
3) "one"
1) "message"
2) "pindao2"
3) "two"
1) "message"
2) "pindao1"
3) "oneone"
1) "message"
2) "pindao2"
3) "twotwo"

2 发布端:发布(送)者给频道频道发布内容,通过频道传给订阅者

#发布者发送消息到频道
127.0.0.1:6379> publish weiyihe  hello,weiyihe #给频道名叫weiyihe的频道发送内容
(integer) 1 #发送成功
127.0.0.1:6379> publish weiyihe  hello,redis #给频道名叫weiyihe的频道发送内容
(integer) 1 #发送成功
127.0.0.1:6379> publish weiyihe1  hello,redis1 ##给频道名叫weiyihe1的频道发送内容,注意:这个频道不存在
(integer) 0 #发送失败,因为频道不存在
127.0.0.1:6379> publish CCTV studyTimeNow #给CCCTV这个频道发送内容
(integer) 1
#两个频道一起发送信息
127.0.0.1:6379> publish pindao1 one
(integer) 1
127.0.0.1:6379> publish pindao2 two
(integer) 1
127.0.0.1:6379> publish pindao1 oneone
(integer) 1
127.0.0.1:6379> publish pindao2 twotwo
(integer) 1

原理

网络异常,图片无法展示
|

网络异常,图片无法展示
|

暂时无法在文档外展示此内容

使用场景:

1.实时消息系统

2.实时聊天,聊天室(频道当做聊天室,将信息回显给所有人即可)

3.订阅,关注系统

稍微复杂的场景我们就会使用我们的消息中间件(MQ)来做

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
7月前
|
存储 缓存 NoSQL
聊聊 Redis 的高级特性之一: 发布订阅
Redis 发布订阅 (pub/sub) 是一种消息通信模式:发送者 (pub) 发送消息,订阅者 (sub) 接收消息。 图中,消费者1和消费者2 订阅了 Redis 服务的频道 channel ,当生产者通过 PUBLISH 命令发送给频道 channel 时, 这个消息就会被发送给订阅它的两个客户端。
聊聊 Redis 的高级特性之一: 发布订阅
|
7月前
|
消息中间件 移动开发 NoSQL
Redis 协议 事务 发布订阅 异步连接
Redis 协议 事务 发布订阅 异步连接
|
7月前
|
NoSQL Redis
Redis之发布订阅
Redis之发布订阅
|
2月前
|
NoSQL Redis
Redis 发布订阅
10月更文挑战第18天
33 1
Redis 发布订阅
|
3月前
|
消息中间件 存储 NoSQL
18)Redis 的发布订阅模型
18)Redis 的发布订阅模型
38 0
|
7月前
|
存储 NoSQL Redis
Redis 简介 + Python 操作发布订阅
Redis 简介 + Python 操作发布订阅
109 0
|
7月前
|
消息中间件 设计模式 缓存
Redis发布订阅:美丽的陷阱与不宜之境
Redis发布订阅:美丽的陷阱与不宜之境
716 1
|
消息中间件 缓存 NoSQL
探索Redis发布订阅与消息队列:构建实时消息通信系统
本篇深入探讨了Redis的发布订阅模式和消息队列功能,展示了如何使用这两个特性构建实时消息通信系统。我们首先介绍了Redis的发布订阅模式,演示了如何通过PUBLISH命令将消息发布到特定频道,并使用SUBSCRIBE和UNSUBSCRIBE命令进行订阅和取消订阅操作。
592 0
|
7月前
|
消息中间件 NoSQL Redis
Redis发布订阅
【1月更文挑战第7天】 消息队列 Redis 发布订阅(publsub)是一种消息通信模式︰发送者(pub)发送消息,订阅者(sub)接收消息。微信、微博、关注系统! Redis客户端可以订阅任意数量的频道。
206 6
|
7月前
|
消息中间件 NoSQL Java
硬核 | Redis Pub/Sub 发布订阅与宅男有什么关系?
硬核 | Redis Pub/Sub 发布订阅与宅男有什么关系?
85 0