订阅与发布

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 <subcommand> arg arg ... arg. Subcommands are:
2) CHANNELS [<pattern>] -- 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 <subcommand> [argument [argument ...]]
# 若不知道怎么使用可以使用命令   pubsub help
  127.0.0.1:6379> PUBSUB help
1) PUBSUB <subcommand> arg arg ... arg. Subcommands are:
2) CHANNELS [<pattern>] -- 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

Redis发布与订阅