【1】是什么
进程间的一种消息通信模式:发送者(pub)发送消息,订阅者(sub)接收消息。
联想诸多消息中间件的发布订阅模式,但是Redis大多用来作为基于内存的分布式缓存,企业中消息中间件多用ActiveMQ、RibbitMQ等。
下图展示了频道channel1,以及订阅这个频道的三个客户端–client2、client5和client1之间的关系。
当有新消息通过publish命令发送给频道channel1时,这个消息就会被发送给订阅它的三个客户端:
【2】常用命令
① PSUBSCRIBE pattern [pattern …]
订阅一个或多个符合给定模式的频道。
每个模式以* 作为匹配符,比如it*匹配所有以 it 开头的频道( it.news 、 it.blog 、 it.tweets 等等), news.* 匹配所有以 news. 开头的频道( news.it 、 news.global.today 等等),诸如此类。
返回值:接收到的信息。
示例如下:
127.0.0.1:6379> PSUBSCRIBE news* Reading messages... (press Ctrl-C to quit) 1) "psubscribe" # 返回值的类型:显示订阅成功 2) "news*" # 订阅的模式 3) (integer) 1 # 目前已订阅的模式的数量 1) "pmessage" # 返回值的类型:信息 2) "news*" # 信息匹配的模式 3) "news1" # 信息本身的目标频道 4) "IT" # 信息的内容 1) "pmessage" 2) "news*" 3) "news2" 4) "english"
② PUBLISH channel message
将信息 message 发送到指定的频道 channel 。
返回值:接收到信息 message 的订阅者数量。
示例如下:
127.0.0.1:6379> PUBLISH c2 helloredis (integer) 1 #接收到信息 message 的订阅者数量。
③ SUBSCRIBE channel [channel …]
订阅给定的一个或多个频道的信息。
返回值:接收到的信息。
示例如下:
127.0.0.1:6379> SUBSCRIBE c1 c2 c3 Reading messages... (press Ctrl-C to quit) 1) "subscribe" # 返回值的类型:显示订阅成功 2) "c1" # 订阅的频道名字 3) (integer) 1 # 目前已订阅的频道数量 1) "subscribe" 2) "c2" 3) (integer) 2 1) "subscribe" 2) "c3" 3) (integer) 3 1) "message" # 返回值的类型:信息 2) "c2" # 来源(从那个频道发送过来) 3) "helloredis" # 信息内容
实际在工作中,一般采用ActiveMQ和RabbitMQ等消息中间件,并不使用Redis作为消息中间件。