前沿:一种通信机制-->一般由队列来实现,会存在两个东西,发送者,订阅者,发送者通过消息管道发送内容给订阅者,订阅者通过消息管道获取发送者的信息
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
原理
网络异常,图片无法展示
|
网络异常,图片无法展示
|
暂时无法在文档外展示此内容