Redis 订阅发布(Pub/Sub) 详解 如何使用订阅发布

Pub/Sub (发布订阅)

Redis的发布订阅(Pub/Sub)是一种消息传递模式,它允许消息的发送者(发布者)将消息发送到通道,而订阅者则可以订阅一个或多个通道,并接收发布者发送到这些通道的消息。发布订阅模式在实时通信和消息传递系统中非常有用,它可以用于构建聊天应用、实时数据更新、事件通知等场景。

以下是Redis发布订阅功能的主要特点和用法:

  1. 通道(Channel):发布订阅模式通过通道进行消息传递。发布者发布消息到一个或多个通道,而订阅者则可以订阅一个或多个通道以接收相关消息。

  2. 发布(Publish):发布者向指定通道发送消息。一旦发布者发布了一条消息,所有订阅了该通道的订阅者都会接收到这条消息。

  3. 订阅(Subscribe):订阅者可以选择订阅一个或多个通道,以接收发布者发送到这些通道的消息。一旦订阅了某个通道,订阅者将持续接收该通道上的消息。

  4. 模式订阅(Pattern Subscribe):除了普通的通道订阅外,Redis还支持模式订阅,即可以通过订阅模式来匹配多个通道。例如,订阅模式为 "chat:*" 的订阅者将接收到所有以 "chat:" 开头的通道上的消息。

  5. 取消订阅(Unsubscribe):订阅者可以取消订阅一个或多个通道,以停止接收相关通道上的消息。

  6. 消息传递:消息是异步传递的,发布者发布消息后,订阅者可以在稍后的时间接收到该消息。这种方式使得发布者和订阅者之间解耦,从而提高系统的可扩展性和灵活性。

命令

发布消息
publish channel message  
订阅消息
subscribe channel [channel ...]  
取消订阅
unsubscribe [channel [channel ...]]  

example:
127.0.0.1:6379> publish sports "test"
(integer) 0
127.0.0.1:6379> publish sports "test2"
(integer) 1
127.0.0.1:6379> publish sports "test3"
(integer) 1
127.0.0.1:6379>
127.0.0.1:6379> subscribe sports
1) "subscribe"
2) "sports"
3) (integer) 1
1) "message"
2) "sports"
3) "test2"
1) "message"
2) "sports"
3) "test3"
Reading messages... (press Ctrl-C to quit or any key to type command)
127.0.0.1:6379> unsubscribe sports
1) "unsubscribe"
2) "sports"
3) (integer) 0
按照模式订阅和取消订阅

除了subcribeunsubscribe命令, Redis 命令还支持glob风格的订阅命令 psubscribe 和取消订阅命令 punsubscribe

psubscribe pattern [pattern...]
punsubscribe [pattern [pattern ...]]  
example
psubscribe it*  
查询订阅
查看活跃的频道
pubsub channels [pattern]

所谓活跃的频道是指当前频道至少有一个订阅者, 其中[pattern]是可以指定具体的模式

查看频道订阅数
pubsub numsub [channel ...]  
查看模式订阅数
pubsub numpat

Tips:
  • 客户端在执行订阅命令之后进入了订阅状态, 只能接收subscribe、psubscribe、 unsubscribe、 punsubscribe的四个命令。

  • 发布者和订阅者之间是完全解耦的,它们之间不直接通信,而是通过Redis服务器来中转消息。

  • 新开启的订阅客户端, 无法收到该频道之前的消息, 因为Redis不会对发布的消息进行持久化。

  • 订阅者在断开连接后会自动取消订阅,而重新连接后需要重新订阅才能接收到消息。

  • Redis发布订阅模式并不适合大规模的消息传递,因为Redis是单线程的,如果有大量的订阅者连接到同一个Redis实例,可能会影响到Redis服务器的性能。

  • 发布订阅模式并不保证消息的可靠性传递,即使发布者发布了消息,但订阅者可能会由于网络问题或其他原因而无法接收到该消息。

参考资料:《Redis 开发与运维》

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/740821.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

学习记录之数学表达式(1)

文章目录 一、概述二、符号表2.1 常用符号表2.2 希腊字母表 三、集合的表示与运算3.1 集合的表示3.2 元素与集合3.3 集合的运算3.4 幂集3.5 笛卡尔积3.6 作业 一、概述 本系列内容参考闵老师的博客:数学表达式: 从恐惧到单挑 (符号表) (1)数学…

【Java】bigdecimal转为string时会变成科学计数法 | 大数取消转换为科学计数法

遇见“隐形刺客” 在银行写代码,我们通常用BigDecimal来处理大数计算,确保精度无损,正所谓“精打细算”。然而,当你满怀信心地将BigDecimal转换为String,准备输出或存储时,突然发现它变成了一串让人眼花缭…

Linux 服务器挂载盘阵(运维工程师必备技能难度***)

以下为真实操作过程 [rootdg1 ~]# fdisk -l -uDisk /dev/sda: 32.2 GB, 32212254720 bytes 255 heads, 63 sectors/track, 3916 cylinders, total 62914560 sectors Units sectors of 1 * 512 512 bytesDevice Boot Start End Blocks Id System /dev/s…

回归分析之boxcox

Box-Cox变换是一种用于处理非正态分布数据的统计方法。它通过对数据进行一系列的变换,将其转化为近似正态分布的形式,以便用于回归分析。 Box-Cox变换的基本思想是通过对数据应用一个参数λ的幂函数变换,其中λ可以是任意实数。具体而言&…

2022-6 青少年软件编程(图形化) 等级考试试卷(一级)

第1题:【 单选题】 广场中有声控喷泉, 当声音的音量大于 60 的时候, 喷泉就会喷出水, 现在的音量为30,下列哪个选项可以让喷泉喷出水? ( ) A: B: C: D: 【正确答案】: B 【试题解析】 : 当前声音的音量为 30, 需要将声音增加到 60 以上就可以让喷泉喷出水, …

基于YOLOv8/YOLOv7/YOLOv6/YOLOv5的日常场景下的人脸检测系统(深度学习模型+PySide6界面+训练数据集+Python代码)

摘要:开发用于日常环境中的人脸识别系统对增强安全监测和提供定制化服务极为关键。本篇文章详细描述了运用深度学习技术开发人脸识别系统的全过程,并附上了完整的代码。该系统搭建在强大的YOLOv8算法之上,并通过与YOLOv7、YOLOv6、YOLOv5的性…

HTML5:七天学会基础动画网页12

“书接上回”继续对transition补充,在检查中找到ease后,鼠标放到ease前的紫色小方块就可以对运动曲线进行调整,这个曲线叫贝塞尔曲线,这里不做别的补充,不用了解,我们只要知道这个运动方式不只是有简单的匀…

.Net Core 中间件验签

文章目录 为什么是用中间件而不是筛选器?代码实现技术要点context.Request.EnableBuffering()指针问题 小结 为什么是用中间件而不是筛选器? 为什么要用中间件验签,而不是筛选器去验签? 1、根据上图我们可以看到,中间件在筛选器之…

MySQL--彻底解决Navicat备份时的报错

原文网址:MySQL--彻底解决Navicat备份时的报错_IT利刃出鞘的博客-CSDN博客 简介 本文介绍彻底解决Navicat备份时的报错。 正确的方法 见:MySQL命令--使用mysqldump导出导入数据库_IT利刃出鞘的博客-CSDN博客 错误的方法 方法1.转储SQL文件 这种方…

2.2 塑性力学——主应力、主方向、不变量

个人专栏—塑性力学 1.1 塑性力学基本概念 塑性力学基本概念 1.2 弹塑性材料的三杆桁架分析 弹塑性材料的三杆桁架分析 1.3 加载路径对桁架的影响 加载路径对桁架的影响 2.1 塑性力学——应力分析基本概念 应力分析基本概念 2.2 塑性力学——主应力、主方向、不变量 主应力、主…

【嵌入式——QT】标准对话框

【嵌入式——QT】标准对话框 文件对话框颜色对话框字体对话框输入对话框消息框代码示例 文件对话框 QFileDialog 常用静态函数 getOpenFileName:选择打开一个文件;getOpenFileNames:选择打开多个文件;getSaveFileName&#xff1…

【算法面试题】-07

小明找位置 题目描述 小朋友出操&#xff0c;按学号从小到大排成一列;小明来迟了&#xff0c;请你给小明出个主意&#xff0c;让他尽快找到他应该排的位置。 算法复杂度要求不高于nLog(n);学号为整数类型&#xff0c;队列规模<10000; 输入描述 1、第一行:输入已排成队列的…

Vue中怎么使用router进行页面传参

在响应式编程中&#xff0c;使用 Vue Router 传递参数通常涉及到以下几个方面&#xff1a; 1. 动态路由匹配 动态路由匹配允许你根据 URL 中的参数来渲染不同的组件。这在显示用户信息、博客文章等需要根据 ID 或其他标识符来区分内容的情况下非常有用。 例如&#xff0c;如果…

浅淡 C++ 与 C++ 入门

我们知道&#xff0c;C语言是结构化和模块化的语言&#xff0c;适用于较小规模的程序。而当解决复杂问题&#xff0c;需要高度抽象和建模时&#xff0c;C语言则不合适&#xff0c;而C正是在C的基础之上&#xff0c;容纳进去了面向对象编程思想&#xff0c;并增加了许多有用的库…

基于YOLOv8/YOLOv7/YOLOv6/YOLOv5的吸烟检测系统(深度学习+Python代码+PySide6界面+训练数据集)

摘要&#xff1a;本文详细说明了如何利用深度学习开发一个用于监测吸烟行为的系统&#xff0c;并分享了完整的代码实现。该系统采用了先进的YOLOv8算法&#xff0c;同时还使用YOLOv7、YOLOv6、YOLOv5算法&#xff0c;并对它们进行了性能比较&#xff0c;呈现了不同模型的性能指…

记一次特殊的渗透经历

起因 搞安全的小伙伴们应该知道&#xff0c;干我们这行老是会碰到一些奇奇怪怪的问题和需求&#xff0c;比如上次&#xff0c;某客户领导说让我给他找个会渗透的小伙子来&#xff0c;有个比较棘手的业务。我一听&#xff0c;心想&#xff1a;好嘛&#xff0c;这私活不就来了嘛…

MySQL 开发规范

优质博文&#xff1a;IT-BLOG-CN 一、设计原则 原则&#xff1a; SQL开发规范制定是基于良好的编码习惯和可读性&#xff1b; 目的&#xff1a; 消除冗余&#xff0c;数据简约&#xff0c;提高效率&#xff0c;提高安全&#xff1b; 【1】禁止在线上生产环境做数据库压力测试&…

Linux环境下的数据库SQL学习

1.在Ubuntu下安装sqlite3软件 输入sqlite3启动&#xff0c;输入.quit退去 2.SQL语言与命令&#xff1a; sqlite3文件名----寻找文件地址 .header on/off 打开/关闭 数据库中列的名称 .mode csv/column/html/insert/line/list/tabs/tcl 数据库程序&#xff1a;名字.sql …

视频监控管理系统EasyCVR平台设备增删改操作不生效是什么原因?

国标GB28181协议EasyCVR安防平台可以提供实时远程视频监控、视频录像、录像回放与存储、告警、语音对讲、云台控制、平台级联、磁盘阵列存储、视频集中存储、云存储等丰富的视频能力&#xff0c;平台支持7*24小时实时高清视频监控&#xff0c;能同时播放多路监控视频流&#xf…

使用Python检测贝叶斯网络的因果关系检测

在机器学任务中&#xff0c;确定变量间的因果关系&#xff08;causality&#xff09;可能是一个具有挑战性的步骤&#xff0c;但它对于建模工作非常重要。本文将总结有关贝叶斯概率&#xff08;Bayesian probabilistic&#xff09;因果模型&#xff08;causal models&#xff0…