Redis 的发布/订阅模式
迪丽瓦拉
2025-06-01 02:25:56
0

1. 描述

Redis 的发布/订阅模式较 Kafka 等简单很多;

Redis 通过 Channal 实现发布-订阅,订阅者可以对频道进行订阅(不存在的频道将创建频道),发布者向频道发送的消息会自动推送到订阅者端,先发送的消息,后订阅的订阅者是收不到之前的消息的;

2. 相关命令

命令

说明

subscribe channel [channel ...]

订阅给定的一个或多个频道

unsubscribe channel [channel ...]

退订给定的频道

说明:若没有指定 channel,则默认退订所有频道

publish channel message

将消息发送给指定频道 channel

返回结果:接收到信息的订阅者数量,无订阅者返回 0

pubsub channels [argument [argument ...]]

查看订阅与发布系统的状态

说明:返回活跃频道列表(即至少有一个订阅者的频道,订阅模式的客户端除外)

psubscribe pattern1 [pattern ...]

订阅一个或多个符合给定模式的频道

说明:每个模式以 * 作为匹配符;例如 channel* 匹配所有 channel 开头的频道,如:channel1、channel.sub1

punsubscribe [pattern [pattern ...]]

退订所有给定模式的频道

说明:pattern 未指定,则订阅的所有模式都会被退订,否则只退订指定的订阅的模式

3. 实例

创建 5 个终端 shell 窗口,分别运行 redis-cli 客户端;

终端2:

订阅频道 channel1、channel2、channel3,因为频道不存在,因此会自动创建这 3 个频道;

127.0.0.1:6379> subscribe channel1 channel2 channel3

Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel1"
3) (integer) 1
1) "subscribe"
2) "channel2"
3) (integer) 2
1) "subscribe"
2) "channel3"
3) (integer) 3

终端3:

批量订阅 channel*

127.0.0.1:6379> psubscribe channel*

Reading messages... (press Ctrl-C to quit)
1) "psubscribe"
2) "channel*"
3) (integer) 1

终端4:

订阅 channel1

127.0.0.1:6379> subscribe channel1

1) "subscribe"
2) "channel1"
3) (integer) 1

终端5:

订阅 channel2

127.0.0.1:6379> subscribe channel2

Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel2"
3) (integer) 1

终端1:

  • 查看所有活跃频道

127.0.0.1:6379> pubsub channels

1) "channel1"
2) "channel2"
3) "channel3"

  • 向一个新的 channe12 发消息,因为 channel 不存在,会新建

127.0.0.1:6379> publish channel12 hello

(integer) 1 

此时在终端3(批量订阅)有输出

1) "pmessage"
2) "channel*"
3) "channel12"
4) "hello"

其他订阅终端无输出;

  • 向 channel1 发消息

127.0.0.1:6379> publish channel1 hello channel1

(integer) 3

在终端2(订阅了 3 个频道)和终端4(订阅了 channel1)输出一致:

1) "message"
2) "channel1"
3) "hello_channel1"

在终端3(批量订阅)输出:

1) "pmessage"
2) "channel*"
3) "channel1"
4) "hello_channel1"

在终端5(订阅 channel2)无输出

  • 向 channel2 发消息

127.0.0.1:6379> publish channel2 hello channel2

(integer) 3

在终端2(订阅了3个频道)和终端5(订阅了 channel2)输出:

1) "message"
2) "channel2"
3) "hello_channel2"

在终端3(批量订阅)输出:

1) "pmessage"
2) "channel*"
3) "channel2"
4) "hello_channel2"

在终端4(订阅 channel1)无输出;

  • 所有订阅者都退出

在终端2、终端3、终端4、终端5 上面都执行 Ctrl+C 退出订阅,当没有订阅者了,频道自动关闭

此时在终端1 查看活跃频道:

127.0.0.1:6379> pubsub channels

(empty array)

相关内容

热门资讯

linux入门---制作进度条 了解缓冲区 我们首先来看看下面的操作: 我们首先创建了一个文件并在这个文件里面添加了...
C++ 机房预约系统(六):学... 8、 学生模块 8.1 学生子菜单、登录和注销 实现步骤: 在Student.cpp的...
A.机器学习入门算法(三):基... 机器学习算法(三):K近邻(k-nearest neigh...
数字温湿度传感器DHT11模块... 模块实例https://blog.csdn.net/qq_38393591/article/deta...
有限元三角形单元的等效节点力 文章目录前言一、重新复习一下有限元三角形单元的理论1、三角形单元的形函数(Nÿ...
Redis 所有支持的数据结构... Redis 是一种开源的基于键值对存储的 NoSQL 数据库,支持多种数据结构。以下是...
win下pytorch安装—c... 安装目录一、cuda安装1.1、cuda版本选择1.2、下载安装二、cudnn安装三、pytorch...
MySQL基础-多表查询 文章目录MySQL基础-多表查询一、案例及引入1、基础概念2、笛卡尔积的理解二、多表查询的分类1、等...
keil调试专题篇 调试的前提是需要连接调试器比如STLINK。 然后点击菜单或者快捷图标均可进入调试模式。 如果前面...
MATLAB | 全网最详细网... 一篇超超超长,超超超全面网络图绘制教程,本篇基本能讲清楚所有绘制要点&#...
IHome主页 - 让你的浏览... 随着互联网的发展,人们越来越离不开浏览器了。每天上班、学习、娱乐,浏览器...
TCP 协议 一、TCP 协议概念 TCP即传输控制协议(Transmission Control ...
营业执照的经营范围有哪些 营业执照的经营范围有哪些 经营范围是指企业可以从事的生产经营与服务项目,是进行公司注册...
C++ 可变体(variant... 一、可变体(variant) 基础用法 Union的问题: 无法知道当前使用的类型是什...
血压计语音芯片,电子医疗设备声... 语音电子血压计是带有语音提示功能的电子血压计,测量前至测量结果全程语音播报࿰...
MySQL OCP888题解0... 文章目录1、原题1.1、英文原题1.2、答案2、题目解析2.1、题干解析2.2、选项解析3、知识点3...
【2023-Pytorch-检... (肆十二想说的一些话)Yolo这个系列我们已经更新了大概一年的时间,现在基本的流程也走走通了,包含数...
实战项目:保险行业用户分类 这里写目录标题1、项目介绍1.1 行业背景1.2 数据介绍2、代码实现导入数据探索数据处理列标签名异...
记录--我在前端干工地(thr... 这里给大家分享我在网上总结出来的一些知识,希望对大家有所帮助 前段时间接触了Th...
43 openEuler搭建A... 文章目录43 openEuler搭建Apache服务器-配置文件说明和管理模块43.1 配置文件说明...