Redis的发布与订阅,有点类似于消息队列,发送者往频道发送消息,频道的订阅者接收消息。

1. 发布与订阅示例

首先,在本机开启第1个Redis客户端,执行如下命令订阅blog.redis频道:

SUBSCRIBE "blog.redis"

然后,在本机开启第2个Redis客户端,执行相同的命令订阅blog.redis频道:

然后,开启第3个Redis客户端,执行如下命令往blog.redis频道发送消息:

PUBLISH blog.redis "redis-in-action-01"

查看客户端1和客户端2,分别看到如下信息:

3个客户端与频道的关系如下图所示:

可以通过INFO clients命令查看连接的客户端数:

2. 订阅/退订频道

2.1 订阅频道

Redis的SUBSCRIBE命令用来订阅频道,使用方式如下所示:

SUBSCRIBE "blog.redis"

如果是订阅多个频道,可以使用如下所示命令:

SUBSCRIBE "blog.redis" "blog.rocketmq"

Redis将所有频道的订阅关系保存在服务器状态的pubsub_channels字典里,字典的键是某个被订阅的频道,键对应的值是1个链表,链表里记录了所有订阅这个频道的客户端。

以上图为例,说明客户端1、客户端2正在订阅频道"blog.redis",客户端3、客户端4正在订阅频道“blog.rocketmq”。

如果此时有1个客户端5,执行了如下命令:

SUBSCRIBE "blog.rocketmq" "blog.java"

那么服务器状态保存的频道订阅关系将变为如下图所示:

2.2 退订频道

Redis的UNSUBSCRIBE命令用来退订频道,使用方式如下所示:

UNSUBSCRIBE "blog.redis"

如果是退订多个频道,可以使用如下所示命令:

UNSUBSCRIBE "blog.redis" "blog.rocketmq"

假设现在服务器状态保存的频道订阅关系如下图所示:

如果此时客户端5,执行了如下命令:

UNSUBSCRIBE "blog.rocketmq" "blog.java"

那么服务器状态保存的频道订阅关系将变为如下图所示:

3. 订阅/退订模式

3.1 示例

首先,启动1个Redis客户端,执行如下命令订阅模式“blog.r*”:

PSUBSCRIBE "blog.r*"

然后,启动另1个Redis客户端,执行PUBLISH命令往频道发送消息:

PUBLISH "blog.redis" "redis-in-action-01"

PUBLISH "blog.rocketmq" "rocketmq-in-action-01"

PUBLISH "blog.java" "java-in-action-01"

可以看到,第1次启动的客户端可以接收到前2条消息,因为频道"blog.redis"、"blog.rocketmq"匹配模式“blog.r*”:

但频道"blog.java"不匹配该模式,所以最后1次发送的消息,该客户端未接收到。

3.2 订阅模式

Redis的PSUBSCRIBE命令用来订阅模式,使用方式如下所示:

PSUBSCRIBE "blog.r*"

如果是订阅多个模式,可以使用如下所示命令:

PSUBSCRIBE "blog.r*" "blog.j?va" "blog.j[ae]va"

Redis将所有模式的订阅关系保存在服务器状态的pubsub_patterns属性里。

pubsub_patterns属性是1个链表,链表中的每个节点是1个pubsub_Pattern结构,这个结构的pattern属性记录被订阅的模式,client属性记录订阅模式的客户端。

以上图为例,说明客户端1正在订阅模式"blog.r*,客户端2正在订阅模式“blog.j?va”。

如果此时有1个客户端3,执行了如下命令:

PSUBSCRIBE "blog.j[ae]va"

那么服务器状态保存的模式订阅关系将变为如下图所示:

3.3 退订模式

Redis的PUNSUBSCRIBE命令用来退订模式,使用方式如下所示:

PUNSUBSCRIBE "blog.r*"

如果是退订多个模式,可以使用如下所示命令:

PUNSUBSCRIBE "blog.j?va" "blog.j[ae]va"

假设现在服务器状态保存的模式订阅关系如下图所示:

如果此时客户端3,执行了如下命令:

PUNSUBSCRIBE "blog.j[ae]va"

那么服务器状态保存的模式订阅关系将变为如下图所示:

4. 发送消息

如果,服务器状态保存的频道订阅关系如下图所示:

服务器状态保存的模式订阅关系如下图所示:

此时,如果1个Redis客户端执行了以下PUBLISH命令:

PUBLISH blog.redis "redis-in-action-01"

那么,服务器会执行以下2个动作:

  1. 将消息"redis-in-action-01"发送给频道“blog.redis”的所有订阅者
  2. 将消息"redis-in-action-01"发送给与频道“blog.redis”相匹配模式的订阅者

也就是说,消息"redis-in-action-01"不仅会发送给频道“blog.redis”的订阅者客户端1、客户端2,也会发送给与频道“blog.redis”相匹配的模式“blog.r*”的订阅者客户端5。

5. 查看订阅信息

可以使用Redis的PUBSUB命令来查看频道或者模式的相关信息。

5.1 查看被订阅的频道

如果想要查看被订阅的频道信息,可以使用命令PUBSUB CHANNELS [pattern],其中pattern参数是可选的:

  1. 如果不指定pattern参数,返回服务器当前被订阅的所有频道
  2. 如果指定pattern参数,返回服务器被订阅的频道中与pattern模式相匹配的频道

这个命令的实现原理是通过遍历服务器状态保存的pubsub_channels字典来实现的。

举个具体的例子,如果服务器状态保存的pubsub_channels字典如下所示:

那么执行命令PUBSUB CHANNELS的返回结果如下所示:

执行命令PUBSUB CHANNELS r*的返回结果如下所示:

5.2 查看频道的订阅者数量

如果想要查看频道的订阅者数量,可以使用命令PUBSUB NUMSUB [channel1 channel2 ... channeln]

这个命令的实现原理是通过遍历服务器状态保存的pubsub_channels字典来实现的,频道对应的订阅者链表的长度就是该频道的订阅者数量。

举个具体的例子,如果服务器状态保存的pubsub_channels字典如下所示:

那么执行命令PUBSUB NUMSUB blog.redis blog.rocketmq blog.java的返回结果如下所示:

5.3 查看被订阅模式的数量

如果想要查看被订阅模式的数量,可以使用命令PUBSUB NUMPAT

这个命令的实现原理是返回服务器状态保存的pubsub_patterns链表的长度。

举个具体的例子,如果服务器状态保存的pubsub_patterns链表如下所示:

那么执行命令PUBSUB NUMPAT的返回结果如下所示:

6. 总结

Redis的发布与订阅有点类似于消息队列的发布与订阅,主要包含以下7个命令:

  1. SUBSCRIBE
  2. UNSUBSCRIBE
  3. PSUBSCRIBE
  4. PUNSUBSCRIBE
  5. PUBSUB CHANNELS
  6. PUBSUB NUMSUB
  7. PUBSUB NUMPAT

这7个命令的核心都是基于存储在服务器状态的pubsub_channels字典和pubsub_patterns链表实现的。

7. 参考

黄健宏 《Redis设计与实现》

Redis系列(八):发布与订阅的更多相关文章

  1. Redis中的发布与订阅

    redis中实现发布与订阅相对于zookeeper非常简单.直接使用publish和subscribe就行. subscrible news; 订阅news这个channel publish news ...

  2. Redis的消息发布和订阅

    Redis的消息发布和订阅 Author:SimpleWu GitHub-redis 什么是消息发布和订阅? Redis 发布订阅(pub/sub)是一种进程间的消息通信模式: 发送者(pub)发送消 ...

  3. redis 笔记06 发布与订阅、事务、慢查询日志、监视器

    发布与订阅 1. 服务器状态在pubsub_channels字典保存了所有频道的订阅关系:SUBSCRIBE命令负责将客户端和被订阅的频道关联到这个字典里面,而UNSUBSCRIBE命令则负责 解除客 ...

  4. redis 事务 及发布于订阅功能

    事务: Redis事务可以一次执行多个命令,事务具有以下特征: 1.隔离操作:事务中的所有命令都会序列化.按顺序地执行,不会被其他命令打扰. 2.原子操作:事务中的命令要么全部被执行,要么全部都不执行 ...

  5. Redis系列(三)—— 订阅/发布

    Redis 订阅/发布 参考:http://www.cnblogs.com/mushroom/p/4470006.html,http://www.tuicool.com/articles/ABry2a ...

  6. Redis系列八:redis主从复制和哨兵

    一.Redis主从复制 主从复制:主节点负责写数据,从节点负责读数据,主节点定期把数据同步到从节点保证数据的一致性 1. 主从复制的相关操作 a,配置主从复制方式一.新增redis6380.conf, ...

  7. redis 实现消息发布和订阅

    1,打开二个客户端机器 一个用于发布,一个用于接受 2,发布一个channel1 3,用另外一个客户端收听上面的客户端 4,当再次在发布的redis客户端 发布一个消息  其他所有订阅的客户端会自动收 ...

  8. Redis消息之发布与订阅

    "发布/订阅"可以实现进程间的消息传递 发布的消息不会持久化,只能收到订阅后的消息,执行subscribe命令后客户端会进入"订阅"状态,处于此状态下的客户端不 ...

  9. Redis 之消息发布与订阅(publish、subscribe)

    使用办法: 订阅端: Subscribe 频道名称 发布端: publish 频道名称 发布内容 一般做群聊,聊天室,发布公告信息等.

  10. Redis系列八 使用Jedis

    使用Jedis jar操作Redis 1.配置redis.conf文件,修改 2.建java工程,加入 jedis jar包 3.代码示例: package com.ntjr.redis; impor ...

随机推荐

  1. C#通过SSH连接MySql

    出于安全考虑,有的时候数据库服务器只能通过SSH访问,比如MySql服务装在了服务器A上,并且A机器只允许B机器才能访问,而部署环境可能在C机器上,这时候就要C服务器通过B服务器连接A服务器,这时候就 ...

  2. Linux中profile文件详解(转)

    1.Linux是一个多用户的操作系统.每个用户登录系统后,都会有一个专用的运行环境.通常每个用户默认的环境都是相同的,这个默认环境实际上就是一组环境变量的定义.用户可以对自己的运行环境进行定制,其方法 ...

  3. RealSense 3D实感体验:前景广阔目前应用少

    腾讯数码讯(周硕)在去年的IDF大会上,英特尔着重展示了其全新的RealSense 3D实感技术,而厚度仅6mm堪称史上最薄平板的戴尔Venue 8 7000也成为首个搭载RealSense技术的产品 ...

  4. 如何给Windows添加自动启动的程序

    博客搬到了fresky.github.io - Dawei XU,请各位看官挪步.最新的一篇是:如何给Windows添加自动启动的程序.

  5. 让程序自动以管理员身份运行(用到了DuplicateToken,模拟管理员的身份,不可思议)

    using System; using System.Data; using System.Configuration; using System.Web; using System.Web.Secu ...

  6. 安装Codeception框架

    安装Codeception框架 打开终端,进入项目根目录: composer require "codeception/codeception:*" 安装完成,在vendor目录会 ...

  7. Hibernate参数绑定的五种方式

    Hibernate参数绑定 参数绑定优点: (1)安全性 防止用户恶意输入条件和恶意调用存储过程 (2)提高性能 底层采用JDBC的PreparedStatement预定义sql功能,后期查询直接从缓 ...

  8. Java的语言特点详解

    1)简单性:java从C++简化而来,设计者们把C++语言中许多可用的特征去掉了,这些特征是一般程序员很少使用的.java还剔除了C++操作符过载和指针操作. 2)面向对象:java是一个面向对象的语 ...

  9. PHP反射学习总结

    反射(Reflection) PHP的反射机制提供了一套反射API,用来访问和使用类.方法.属性.参数和注释等,比如可以通过一个对象知道这个对象所属的类,这个类包含哪些方法,这些方法需要传入什么参数, ...

  10. lnmp部署知乎出现403

    查看错误日志: [root@web01 /]# tailf  /var/log/nginx/error.log 2019/01/16 19:02:06 [error] 10023#10023: *8 ...