百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

redis发布与订阅详解,刚好符合头条的好友关注及推荐模式的应用

mhr18 2024-10-29 14:34 24 浏览 0 评论

redis发布与订阅

本文讲解Redis发布(pub)与订阅(sub),它是一种消息通信模式,Redis的发布订阅机制包括三个主体,发布者,订阅者和Channel(频道)。

redis的发布与订阅的特点是订阅者负责订阅频道( channel),发送者( publisher)负责向频道发送二进制字符串消息(message)。当有信息被发送到定制的频道时,该频道的所有订阅者都将会受到消息。这个模式可以参考显示生活当中电台的运作流程。我们作为订阅者可以收听(即订阅)多个电台,而电台工作人员(发送者)可以在任何电台发送消息,收听的该电台的听众都可以收到该频道的消息。

redis订阅频道

redis的server端当中维持着一个pubsub_channels 属性是一个字典, 这个字典就用于保存订阅频道的信息。它是一个redis的list类型的结构。当客户端通过调用命令SUBSCRIBE进行订阅频道时,就把对应的客户端和订阅的频道通过字典pubsub_channels 中的频道信息进行关联。

比如:我们模拟三个客户端client1、client2、client3 同时订阅了channel1。命令如下:

SUBSCRIBE channel

当三个客户端都订阅了channe1频道后,我们通过PUBLISH命令给channe1发送信息,看看三个订阅该频道的客户端,是否收到对应的信息,命令如下:

PUBLISH channel "hello redis"

从上图可以看出,当发送者对频道发送信息时,三个客户端都可以收到订阅的信息。

redis发布与订阅常用命令:

1、Redis Subscribe 命令:用于订阅频道信息。如:

SUBSCRIBE channel

2、Redis Publish 命令:用于将信息发送到指定的频道。如:

PUBLISH channel "hello redis sub/pub"

3、Redis Psubscribe 命令:用于订阅一个或者多个按模糊条件匹配的频道,类似SQL中的like。如:(表示订阅所有以channel开始的所有频道)

PSUBSCRIBE channel*

4、Redis Pubsub 命令:用于查看订阅与发布系统状态,它由数个不同格式的子命令组成。比如查看活跃中的频道有哪些、频道的订阅者数量?如:

Pubsub channels --活跃的频道
PUBSUB NUMSUB channel--频道channel的订阅者数量

5、Redis Punsubscribe 命令:用于退订所有给定模式的频道。如果没有模式被指定,一个无参数的 PUNSUBSCRIBE 调用被执行,那么客户端订阅的频道都会被退订。

PUNSUBSCRIBE channel

6、Redis Unsubscribe 命令:用于退订给定的一个或多个频道的信息。如果没有指定频道,那么客户端订阅的所有频道都会被退订。

Unsubscribe 

总结:

1、redis的订阅频道的信息是redis服务器进程自己维持在?pubsub_channels链表字典当中。字典的KEY为被订阅的频道,值为订阅的客户端。

2、当发送者发送消息时,redis服务器遍历频道对应的所有客户端,然后将消息发送到所订阅的客户端上。

3、当有信息发送时,除了订阅该频道的客户端会收到消息,以及和订阅了匹配频道的客户端,其它客户端是收不到该信息的。

4、退订频道、退订模式和订阅频道、订阅模式是两组反操作。

应用场景:

俗话说的好,知识学得好不好,还得看用到哪。反正笔者看到redis的发布与订阅的模式的特点后,第一时间想到的是可以用来做一个实时聊天系统,还可以用来做分布式架构中写的过程,利用redis的实时发布功能,把要写入的值及时快速的分发到各个写入程序当中,保证分布式架构中数据的完整一致性。再比如博客系统和自媒体平台中,粉丝关注功能,就比如现在我的2000粉丝,当我发布文章时,就可以及时推送文章到粉丝的客户端上。总而言之,应用的场景比较多,需要大家多思考,多交流。

free教程,随时随地学习IT技术,欢迎关注交流

相关推荐

Java面试宝典之问答系列(java面试回答)

以下内容,由兆隆IT云学院就业部根据多年成功就业服务经验提供:1.写出从数据库表Custom中查询No、Name、Num1、Num2并将Name以姓名显示、计算出的和以总和显示的SQL。SELECT...

ADG (Active Data Guard) 数据容灾架构下,如何配置 Druid 连接池?

如上图的数据容灾架构下,上层应用如果使用Druid连接池,应该如何配置,才能在数据库集群节点切换甚至主备数据中心站点切换的情况下,上层应用不需要变动(无需修改配置也无需重启);即数据库节点宕机/...

SpringBoot多数据源dynamic-datasource快速入门

一、简介dynamic-datasourc是一个基于SpringBoot的快速集成多数据源的启动器,其主要特性如下:支持数据源分组,适用于多种场景纯粹多库读写分离一主多从混合模式。支持...

SpringBoot项目快速开发框架JeecgBoot——项目简介及系统架构!

项目简介及系统架构JeecgBoot是一款基于SpringBoot的开发平台,它采用前后端分离架构,集成的框架有SpringBoot2.x、SpringCloud、AntDesignof...

常见文件系统格式有哪些(文件系统类型有哪几种)

PART.01常见文件系统格式有哪些常见的文件系统格式有很多,通常根据使用场景(Windows、Linux、macOS、移动设备、U盘、硬盘等)有所不同。以下是一些主流和常见的文件系统格式及其特点:一...

Oracle MySQL Operator部署集群(oracle mysql group by)

以下是使用OracleMySQLOperator部署MySQL集群的完整流程及关键注意事项:一、部署前准备安装MySQLOperator通过Helm安装Operator到Ku...

LibreOffice加入"转向Linux"运动

LibreOffice项目正准备削减部分Windows支持,并鼓励用户切换到Linux系统。自Oracle放弃OpenOffice后,支持和指导LibreOffice开发的文档基金会对未来有着明确的观...

Oracle Linux 10发布:UEK 8.1、后量子加密、增强开发工具等

IT之家6月28日消息,科技媒体linuxiac昨日(6月27日)发布博文,报道称OracleLinux10正式发布,完全二进制兼容(binarycompatibility...

【mykit-data】 数据库同步工具(数据库同步工具 开源)

项目介绍支持插件化、可视化的数据异构中间件,支持的数据异构方式如下MySQL<——>MySQL(增量、全量)MySQL<——>Oracle(增量、全量)Oracle...

oracle关于xml的解析(oracle读取xml节点的属性值)

有时需要在存储过程中处理xml,oracle提供了相应的函数来进行处理,xmltype以及相关的函数。废话少说,上代码:selectxmltype(SIConfirmOutput).extract...

如何利用DBSync实现数据库同步(通过dblink同步数据库)

DBSync是一款通用型的数据库同步软件,能侦测数据表之间的差异,能实时同步差异数据,从而使双方始终保持一致。支持各种数据库,支持异构同步、增量同步,且提供永久免费版。本文介绍其功能特点及大致用法,供...

MYSQL存储引擎InnoDB(八十):InnoDB静态数据加密

InnoDB支持独立表空间、通用表空间、mysql系统表空间、重做日志和撤消日志的静态数据加密。从MySQL8.0.16开始,还支持为模式和通用表空间设置加密默认值,这允许DBA控制在这些模...

JDK高版本特性总结与ZGC实践(jdk高版本兼容低版本吗)

美团信息安全技术团队核心服务升级JDK17后,性能与稳定性大幅提升,机器成本降低了10%。高版本JDK与ZGC技术令人惊艳,且JavaAISDK最低支持JDK17。本文总结了JDK17的主要...

4 种 MySQL 同步 ES 方案,yyds!(两个mysql数据库自动同步的方法)

本文会先讲述数据同步的4种方案,并给出常用数据迁移工具,干货满满!不BB,上文章目录:1.前言在实际项目开发中,我们经常将MySQL作为业务数据库,ES作为查询数据库,用来实现读写分离,...

计算机Java培训课程包含哪些内容?其实就这六大块

不知不觉秋天已至,如果你还处于就业迷茫期,不如来学习Java。对于非科班小白来说,Java培训会更适合你。提前了解下计算机Java培训课程内容,会有助于你后续学习。下面,我就从六个部分为大家详细介绍...

取消回复欢迎 发表评论: