Redis Pub/Sub 指南

news2024/11/17 19:32:02

Redis 不仅仅是一个数据库,还可以作为支持发布和订阅(Pub/Sub)操作的消息代理。本文将使用 Navicat for Redis 简要概述 Redis 的 Pub/Sub 功能。

关于发布或订阅消息范式

Pub/Sub 是一种模式,发送者(广播者)不能向特定接收者(订阅者)发送消息。相反,发布的消息以频道形式发送,并且发送者不知道有多少订阅者正在订阅这个频道。而订阅者可以订阅一个或多个频道,以便只接收他们感兴趣的消息。以这种方式对发布者和订阅者进行解构能提高可扩展性,并更容易管理复杂系统中的信息流。

Redis Pub/Sub 提供了一种轻量级、快速、可扩展的消息解决方案,可用于各种目的,例如实时通知,在微服务之间发送消息或在单个应用程序的不同部分之间进行通信。

Redis中的消息传递

Redis 采用最多一次消息传递系统。顾名思义,消息只会被传递一次。因此,一旦 Redis 服务器发送消息,就不会再次发送。如果订阅者无法接收消息(例如,由于错误或网络中断),则消息将永远丢失。就像在收音机上收听你最喜欢的节目一样,如果错过了,就没有机会再听到。如果你的应用程序需要更强的传递保证,你应该使用 Redis Streams。

此外,Pub/Sub 与键空间无关。这意味着在数据库 10 上发布的消息能被数据库 1 上的订阅者接收到。如果你需要范围界定,Redis 建议在頻道名加上前缀(即 prod_mychannel,test_mychannel)。

使用 Navicat for Redis 发布消息

在 Navicat for Redis(或Navicat Premium)中,我们可以通过主工具栏上的 Pub/Sub 按钮打开 Pub/Sub 画面。我们可以在那里使用“发布窗格”发布消息:

pub-sub_screen (106K)

在 Redis 中,频道不是由用户创建的。当发布第一条消息或客户端订阅时,频道会自动创建。为了演示,我们将使用同一个 Redis 服务器创建两个连接。每个连接将充当不同的客户端。第一个连接将订阅“test_channel”,而第二个连接将向同一频道发布消息。这样做,我们希望消息在发布后能立即传递给订阅者。

在 Navicat 中订阅频道,我们只需要点击“订阅”按钮即可。这将打开“订阅”对话框:

subscribe_dialog (117K)

在这里,我们将输入频道名称“test_channel”,然后点击“订阅”。对话框关闭后,频道将出现在“频道”列表中,并记录订阅操作:

channel_added (110K)

如果要在 Navicat 中发布消息,我们将在“频道”列表中选择一个频道(由于我们此时只有一个通道,因此是默认选项),然后在“消息”文本字段中输入消息,点击“发布”。此时,我们应该看到收到消息的通知:

message_received (75K)

总结

本文使用 Navicat for Redis 简要介绍了 Redis 的 Pub/Sub 功能。如果你有兴趣试用 Navicat for Redis,可以在 此处 下载。试用版具备完整功能,试用期为 14 天。

相关技术文章

开始使用 Redis

Navicat for Redis 功能介绍

Redis 数据类型

如何在 Redis 中处理键值

Redis Pub/Sub 指南

Redis 列表 | 概述

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

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

相关文章

银河麒麟服务器arm安装qemu虚拟机

脚本 yum install -y virt-viewer virt-v2v libvirt* qemu* virt-manager 等待安装完成 打开虚拟系统管理器 接下来就可以新建虚拟机了

山西电力市场日前价格预测【2023-08-24】

日前价格预测 预测明日(2023-08-24)山西电力市场全天平均日前电价为319.98元/MWh。其中,最高日前电价为370.78元/MWh,预计出现在19: 30。最低日前电价为272.42元/MWh,预计出现在12: 45。 价差方向预测 1: 实…

Wlan——STA上线流程与802.11MAC帧讲解以及报文转发路径

目录 802.11MAC帧基本概念 802.11帧结构 802.11MAC帧的分类 管理帧 控制帧 数据帧 STA接入无线网络流程 信号扫描—管理帧 链路认证—管理帧 用户关联—管理帧 用户上线 不同802.11帧的转发路径 802.11MAC帧基本概念 802.11协议在802家族中的角色位置 其中802.3标…

Git,分布式版本控制工具

1.为常用指令配置别名(可选) 打开用户目录,创建.bashrc文件 (touch ~/.bashrc) 2.往其输入内容 #用于输出git提交日志 alias git-loggit log --prettyoneline --all --graph --abbrev-commit #用于输出当前目录所有文…

BES SDK 各算法模块所占Flash空间大小估计

他V hezkz17进数字音频系统研究开发交流答疑群(课题组) 1

shell 10(shell系统函数)

一、系统函数 Shell编程和其他编程语言一样,有函数,函数是由若干条shell命令组成的语句块,实现Shel脚本代码重用和模块化编程。 1.1 系统函数 系统自带提供的函数,可以直接使用. basename函数用于获取文件名的函数,根据给出的文件路径截取…

Leetcode刷题之1658. 将 x 减到 0 的最小操作数

题目: 算法分析: 可以看出,这道题本意是从计算两侧和为x 的数字, 要求数量最少, 那我们可以反向思考, 假如整个数组的和为sum, 那么我们就可以求中间部分和为sum-x的数字(当然必须连续), 当中间部分的数字同时达到和为sum-x以及长度最长两个要求时, 两侧数字也就达到了和为x以…

【PHP】函数-作用域可变函数匿名函数闭包常用系统函数

文章目录 函数定义&使用命名规则参数种类默认值引用传递函数返回值return关键字 作用域global关键字静态变量 可变函数匿名函数闭包常用系统函数输出函数时间函数数学函数与函数相关函数 函数 函数:function,是一种语法结构,将实现某一个…

PIL.Image和base64,格式互转

将PIL.Image转base64 ##PIL转base64 import base64 from io import BytesIOdef pil_base64(image):img_buffer BytesIO()image.save(img_buffer, formatJPEG)byte_data img_buffer.getvalue()base64_str base64.b64encode(byte_data)return base64_str将base64转PIL.Image …

WiFi天线和NB-IoT天线不通用

表面看起来完全一样。但是把WiFi天线插到NB-IoT设备后,信号弱了很多。还导致设备反复重启

使用Coding对java项目进行自动化的部署 (亲测有用)

Coding是啥嘞?看看百度百科把 https://baike.baidu.com/item/coding/8921246?fraladdin 普通部署和自动化部署比较 普通部署:打jar包->将jar包上传到服务器->执行java -jar命令,好像也不是很麻烦… coding自动化部署:提交…

bh004- Blazor hybrid / Maui 使用 BootstrapBlazor UI 库快速教程

1. 建立工程 bh004_BootstrapBlazorUI 源码 2. 添加 nuget 包 <PackageReference Include"BootstrapBlazor" Version"7.*" /> <PackageReference Include"BootstrapBlazor.FontAwesome" Version"7.*" />3. 添加样式表文…

【实例分割】(二)Mask2Former

mask2former提出了一个统一的分割架构&#xff0c;能够在语义分割、实例分割、全景分割上取得sota的结果&#xff0c;在coco数据集上&#xff0c;全景分割57.8PQ、实例分割50.1AP、语义分割在ADE20K达57.7miou。 目录 1.&#x1f353;&#x1f353; 网络总体结构 2.&#x…

Android GreenDao数据库升级(附Demo)

前言 大家好久不见&#xff0c;一转眼马上八月份下旬了&#xff0c;最近由于工作比较忙&#xff0c;没时间给大家更新博文。百忙之中抽出时间&#xff0c;给大家来更新一篇关于GreenDao3数据库的升级。 关于GreenDao的详细介绍以及一些逻辑性的增、删、改、查等&#xff0c;可以…

Maven的超级POM

对于我们创建的一个maven工程&#xff0c;即便我们自己的pom.xm文件中没有明确指定一个父工程&#xff08;父POM&#xff09;&#xff0c;其实也默认继承了超级POM&#xff0c;就好比JAVA类继承Object类一样。 maven官网关于超级POM的介绍&#xff1a; https://maven.apache.o…

Tomcat10安装及配置教程win11

Tomcat10安装及配置教程win11 Tomcat下载链接 Tomcat官网 Tomcat官网地址 https://tomcat.apache.org/ Tomcat的版本列表 点击上图中左侧红框内**Which version?**即可得下图 下载Tomcat 点击上图中左侧红框内红框内tomcat版本即可得下图&#xff0c;下载zip包 解压zip包…

dnsmasq-dhcp DHCPDISCOVER “no address available“ 问题解决方法

问题现象 在Centos7.5系统中已安装dnsmasq组件并开启DHCP服务功能&#xff0c;然而客户端无法通过DHCP的方式获取IP&#xff0c;通过查看系统日志/var/log/messages发现日志中存在以下两个关键信息&#xff1a; dnsmasq-dhcp DHCPDISCOVER “no address available”DHCPNAK 1…

docker 内apt-get安装软件都不好使

报各种错误 apt-get install --no-install-recommends libboost-all-dev Reading package lists... Done Building dependency tree Reading state information... Done The following additional packages will be installed:autoconf automake autotools-dev cpp-8 gc…

CRC循环冗余码计算

计算步骤 计算冗余位的位数&#xff0c;即生成多项式的最高阶数 在信息位后补冗余位个数的0 将第二步的结果与生成多项式相除&#xff0c;这里采用的除法叫做模2除法&#xff0c;就是只要部分余数的高位为1&#xff0c;便可商1 之后上下做的减法是异或。 经过第三步不断地计…