1、简介
订阅与发布是redis中的一种消息通信模式,主要分为两大角色:发布者
和订阅者
,在发布者和订阅者之间需要一个通道,也叫频道。
发布者(pub):主要用来发送消息.
订阅者(sub);主要订阅发布者发布的消息.
通道(channel):主要用来传送消息.
其中发布者可以发送多次消息,订阅者可以订阅多个频道.
2、实例
前提需要开启两个redis
# 订阅者sub
# 连接进入redis 基于docker
[root@itbestboy ~]# docker ps
container id image command created status ports names
17e755da11bf redis:5.0.14 "docker-entrypoint.s…" 6 weeks ago up 4 days 6379/tcp # 进入redis
[root@itbestboy ~]# docker exec -it 17e /bin/bash
#进入客户端
root@17e755da11bf:/data# redis-cli
#检查是否可以正常启动
127.0.0.1:6379> ping
pong
# 订阅频道a
127.0.0.1:6379> subscribe a
reading messages... (press ctrl-c to quit)
1) "subscribe"
2) "a"
3) (integer) 1
#在开一个redis,用作发布者发送消息
127.0.0.1:6379> publish a hello
(integer) 1
127.0.0.1:6379>
# 发送完之后 订阅者就可以以立刻接受到消息
127.0.0.1:6379> subscribe a
reading messages... (press ctrl-c to quit)
1) "subscribe"
2) "a"
3) (integer) 1
1) "message"
2) "a"
3) "hello"
#查看订阅者和发布者的状态信息
127.0.0.1:6379> pubsub help
1) pubsub arg arg ... arg. subcommands are:
2) channels [] -- return the currently active channels matching a pattern (default: all).
3) numpat -- return number of subscriptions to patterns.
4) numsub [channel-1 .. channel-n] -- returns the number of subscribers for the specified channels (excluding patterns, default: none).
127.0.0.1:6379> pubsub channels
1) "a"
# 其中可以查看的状态包括三个,分别是 频道 模式数 订阅者数量
# 订阅者退出订阅
127.0.0.1:6379> unsubscribe a
1) "unsubscribe"
2) "a"
3) (integer) 0
在发布订阅中大致包括如下命令
3、常见命令
3.1、subscribe
用于订阅给定的一个或多个频道的信息,会进入阻塞状态,知道发布者发送消息
语法
subscribe channel [channel ...]
#一个订阅者可以订阅多个频道
3.2、psubscribe
订阅一个或多个符合给定模式的频道,会进入阻塞状态,知道发布者发送消息
语法:
psubscribe pattern [pattern ...]
#每个模式以 * 作为匹配符,比如 it* 匹配所有以 it 开头的频道( itbestboy 、 it.blog 等等)
3.3、 publish
用于将信息发送到指定的频道
语法:
publish channel message
3.4、unsubscribe
用于退订给定的一个或多个频道的信息
语法:
unsubscribe channel [channel ...]
3.5、punsubscribe
用于退订所有给定模式的频道
语法:
punsubscribe [pattern [pattern ...]]
3.6、pubsub
令用于查看订阅与发布系统状态.
语法:
pubsub [argument [argument ...]]
# 若不知道怎么使用可以使用命令 pubsub help
127.0.0.1:6379> pubsub help
1) pubsub arg arg ... arg. subcommands are:
2) channels [] -- return the currently active channels matching a pattern (default: all).
3) numpat -- return number of subscriptions to patterns.
4) numsub [channel-1 .. channel-n] -- returns the number of subscribers for the specified channels (excluding patterns, default: none).
channels:列出全部活跃的channel或者符合pattern的channel
channel活跃指:至少有一个订阅者。
返回值:活跃channel名称
numpat:获取channel模板个数
numsub:获取指定channel的订阅个数。如果不指定channel,返回空
返回值:订阅指定channel的数量(活跃的).输入channel模式为0