Redis Pub/Sub 指南

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.mzph.cn/news/52124.shtml

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

相关文章

分类预测 | MATLAB实现SCNGO-CNN-LSTM-Attention数据分类预测

分类预测 | MATLAB实现SCNGO-CNN-LSTM-Attention数据分类预测 目录 分类预测 | MATLAB实现SCNGO-CNN-LSTM-Attention数据分类预测分类效果基本描述程序设计参考资料 分类效果 基本描述 1.SCNGO-CNN-LSTM-Attention数据分类预测程序,改进算法,融合正余弦和…

最新ChatGPT网站程序源码+AI系统+详细图文搭建教程/支持GPT4.0/AI绘画/H5端/Prompt知识库

一、前言 SparkAi系统是基于国外很火的ChatGPT进行开发的Ai智能问答系统。本期针对源码系统整体测试下来非常完美,可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。 那么如何搭建部署AI创作ChatGPT?小编这里写一个详细图文教程吧&#xff01…

spark sql 数据倾斜--join 同时开窗去重的问题优化

spark sql 数据倾斜–join 同时开窗去重的问题优化 文章目录 spark sql 数据倾斜--join 同时开窗去重的问题优化结论1. 原方案:join步骤时,同时开窗去重数据倾斜 2. 优化2.1 参数调优2.2 SQL优化 背景: 需求:在一张查询日志表中&a…

【数据库】Mysql中的索引与失效场景

1、前言 MySQL中数据表设计合理的索引对提高性能很有帮助。使用索引可以快速地定位表中的某条记录,从而提高数据库查询的速度,提高数据库的性能。 大多数情况下都(默认)采用B 树来构建索引。只是空间列类型的索引使R- 树&#xf…

集合相关知识

1.为什么使用集合 如果让你统计公司每个月的销售额,你会用数组吗?由于数组创建时需要指定其长度,而且不能改变。集合不需要指定长度,空间不够集合自己会调整。集合里有很多见名知意的方法。 java1.8之后新有的removeIf用法 remove…

MySQL 日志

目录 一、日志概述 二、二进制日志 1、开启二进制日志 2、查看二进制文件 3、删除二进制日志文件 4、恢复二进制日志 5、暂时停止二进制日志功能 三、错误日志 1、启动和设置错误日志 2、查看错误日志 3、删除错误日志 四、通用查询日志 五、慢查询日志 一、日志概…

Qt 信号槽连接方式

使用示例: QObject::connect(sender, SIGNAL(signal()), receiver, SLOT(slot()), Qt::AutoConnection); 目录 连接方式 一、AutoConnection 二、DirectConnection 三、QueuedConnection 四、BlockingQueuedConnection 五、UniqueConnection 总结 连接方式 "q…

IPC之System V vs POSIX

文章目录 IPC示例共享内存POSIX shmSystem V shm IPC 当谈到IPC(Inter-Process Communication,进程间通信)时,它是指不同进程之间进行数据交换和通信的机制。 它允许在操作系统中运行的不同进程之间传输数据,这些进程…

Shell 编程:探索 Shell 的基本概念与用法

目录 Shell 简介 Shell 脚本 Shell 脚本运行 Shell 变量 1、创建变量和赋值 2、引用变量 3、修改变量的值 4、只读变量 5、删除变量 6、环境变量 Shell 字符串操作 1、拼接字符串 2、字符串长度 3、字符串截取 Shell 数组 1、创建数组 2、访问数组元素 shell …

数组分割(2023省蓝桥杯)n种讨论 JAVA

目录 1、题目描述:2、前言:3、动态规划(bug):3、递归 剪枝(超时):4、数学(正解): 1、题目描述: 小蓝有一个长度为 N 的数组 A [A0, A1,…, AN−…

【⑭MySQL | 数据类型(二)】字符串 | 二进制类型

前言 ✨欢迎来到小K的MySQL专栏,本节将为大家带来MySQL字符串 | 二进制类型类型的分享✨ 目录 前言5 字符串类型6 二进制类型总结 5 字符串类型 字符串类型用来存储字符串数据,还可以存储图片和声音的二进制数据。字符串可以区分或者不区分大小写的串比…

.net6.0引用的dll放置单独的文件夹

.net6.0 采用原有的设置方法不起作用 <?xml version"1.0" encoding"utf-8" ?> <configuration><startup> <supportedRuntime version"v4.0" sku".NETFramework,Versionv4.8" /></startup><runtim…

PDF如何转ppt?PDF转ppt的方法

PDF是一种广泛应用于文档传输和存储的格式&#xff0c;然而&#xff0c;在某些情况下&#xff0c;我们可能需要将PDF文件转换为PPT&#xff0c;以便更加灵活地编辑和展示内容。那么&#xff0c;PDF如何转ppt呢?在本文中&#xff0c;我们将介绍几种常用的方法和工具&#xff0c…

总结:Git 撤销操作

1、还未添加到暂存区&#xff1a;git checkout -- filename 执行命令后&#xff0c;会回退到未修改之前的状态 2、已经添加到暂存区&#xff1a;git reset HEAD filename 执行命令后&#xff0c;会回退到工作区之前的状态 3、已经 commit&#xff0c;但是还未 push git reset…

ImageReader保存图片转 opencvmat

目录 ImageReader 直接保存图片&#xff0c;没成功&#xff0c;格式是yuv420&#xff0c;需要转换 转opencv nv21保存图片&#xff0c;测试ok rgb888 data保存图片&#xff1a; ImageReader 直接保存图片&#xff0c;没成功&#xff0c;格式是yuv420&#xff0c;需要转换 …

VLOOKUP

VLOOKUP简单应用 VLOOKUP(A1,B:B,1,FALSE) 是查询A1这子格子的数据在B这一列里面有没有找到相同数据的值,如果有的话就放在当前格子里面去 如果没有的话就是#NA VLOOKUP(A1,F:G,2,FALSE) 是查询A1这子格子的数据在F列查相同的数据,然后再取G列这一行后面的这个格子的数据放到…

Python学习笔记_进阶篇(三)_django知识(二)

本章内容 Django model Model 基础配置 django默认支持sqlite&#xff0c;mysql, oracle,postgresql数据库。 <1> sqlite django默认使用sqlite的数据库&#xff0c;默认自带sqlite的数据库驱动 引擎名称&#xff1a;django.db.backends.sqlite3 <2>mysql …

【算法刷题之哈希表(2)】

目录 1.leetcode-454. 四数相加 II2.leetcode-383. 赎金信&#xff08;1&#xff09;暴力解法&#xff08;2&#xff09;哈希法 3.leetcode-205. 同构字符串&#xff08;1&#xff09;哈希法&#xff08;2&#xff09;直接对比查找 4.leetcode-128. 最长连续序列5.总结 1.leetc…

solidity0.8.0的应用案例14:空投合约

空投是币圈中一种营销策略,项目方将代币免费发放给特定用户群体。为了拿到空投资格,用户通常需要完成一些简单的任务,如测试产品、分享新闻、介绍朋友等。项目方通过空投可以获得种子用户,而用户可以获得一笔财富,两全其美。 因为每次接收空投的用户很多,项目方不可能一…

mysql-sql性能分析工具

一、sql执行频率 MySQL 客户端连接成功后&#xff0c;通过 show [session|global] status 命令可以提供服务器状态信息。通过如下指令&#xff0c;可以查看当前数据库的INSERT、UPDATE、DELETE、SELECT的访问频次&#xff1a; -- session 是查看当前会话 ; -- global 是查询全…