Redis Pub/Sub Redisson Topic

目录

    • 一、Redis Pub/Sub
    • 二、Redisson Topic

一、Redis Pub/Sub

Redis Pub/Sub实现了发布/订阅消息传递范式,发送端和订阅端通过channel进行关联。订阅端订阅一个或多个channel,而发送端向指定的channel发送消息。
Redis的Pub/Sub仅支持最多一次at-most-once消息传递语义,Redis Pub/Sub采取的是发送即忘(fire and forget)策略,这意味着一条消息将被传递一次(如果有的话),一旦Redis服务器发送了消息,就没有机会再次发送。如果订阅者无法处理消息(例如,出错、断线、网络断开后重新连接),则客户端断开时传递的所有消息都将丢失。同时Redis Sub无法在多客户端间负载均衡(即所有客户端都会收到同一条Redis消息,需要应用做去重(幂等)、分片处理等)。如果需要更强的交付保证,参见Redis Streams,Stream中的消息是持久化的,并且支持最多一次at-most-once至少一次at-least-once 传递语义。

Redis Pub/Sub具体命令示例如下:

# 订阅频道
SUBSCRIBE myChannel1 myChannel2
# 发送消息
PUBLISH myChannel1 myMessage
# 取消订阅
UNSUBSCRIBE myChannel1 myChannel2

Redis Pub/Sub支持Glob-style模式匹配的订阅,具体命令示例如下:

# 订阅频道
PSUBSCRIBE myChannel.*
# 发送消息
PUBLISH myChannel.weather myMessage
# 取消订阅
PUNSUBSCRIBE myChannel.*

Redis Pub/Sub支持的统计命令示例如下:

# 查询所有活动频道
PUBSUB CHANNELS
# 查询所有匹配模式的活动频道
PUBSUB CHANNELS myChannel.*
# 查询所有订阅者数量(支持SUBSCRIBE命令)
PUBSUB NUMSUB
# 查询所有订阅的模式数(调用PSUBSCRIBE的不重复模式数)
PUBSUB NUMPAT

二、Redisson Topic

在Redisson中可通过Topic实现Redis Pub/Sub,示例代码如下:

注:
如下topicName即对应channel名称,
MyMessage为自定义POJO对象(包括属性和getter/setter)

@Resource
private RedissonClient redisson;@Test
void testTopic() throws InterruptedException {String topicName = "myTopic";MyMessage myMessage = this.buildMyMessage();//获取TopicRTopic topic = this.redisson.getTopic(topicName);//订阅消息topic.addListener(MyMessage.class, (channel, msg) -> {log.info("topic[{}] receive message: {}", channel, msg);});//发布消息long receiveClientCount = topic.publish(myMessage);log.info("topic[{}] publish success, receiveClientCount: {}", topicName, receiveClientCount);this.sleep5Secs();
}

在Redisson中可通过PatternTopic实现Redis Pub/Sub模式匹配的订阅,示例代码如下:

@Resource
private RedissonClient redisson;@Test
void testPatternTopic() throws InterruptedException {String topicName = "myTopic";String topicPattern = "my*";MyMessage myMessage = this.buildMyMessage();//获取PatternTopicRPatternTopic patternTopic = this.redisson.getPatternTopic(topicPattern);//订阅消息patternTopic.addListener(MyMessage.class, (pattern, channel, msg) -> {log.info("PatternTopic[pattern={}, channel={}] receive message: {}", pattern, channel, msg);});//发布消息RTopic topic = this.distributedObjectService.getTopic(topicName);long receiveClientCount = topic.publish(myMessage);log.info("topic[{}] publish success, receiveClientCount: {}", topicName, receiveClientCount);this.sleep5Secs();
}

参考:

Redis pub/sub
https://redis.io/docs/latest/commands/subscribe/
https://redis.io/docs/latest/develop/interact/pubsub/
https://redis.io/docs/latest/develop/data-types/streams/

Redisson Topic
https://github.com/redisson/redisson/wiki/6.-distributed-objects#67-topic

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

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

相关文章

【LLM】PISSA:一种高效的微调方法

前言 介绍PISSA前,先简单过一下LLMs微调经常采用的LoRA(Low-Rank Adaptation)微调的方法,LoRA 假设权重更新的过程中有一个较低的本征秩,对于预训练的权重参数矩阵 W 0 ∈ R d k W_0 ∈ R^{dk} W0​∈Rdk&#xff0c…

Linux_内核缓冲区

目录 1、用户缓冲区概念 2、用户缓冲区刷新策略 3、用户缓冲区的好处 4、内核缓冲区 5、验证内核缓冲区 6、用户缓冲区存放的位置 7、全缓冲 结语 前言: Linux下的内核缓冲区存在于系统中,该缓冲区和用户层面的缓冲区不过同一个概念&#x…

数据结构与算法引入(Python)

华子目录 引入第一次尝试第二次尝试 算法的概念算法的五大特性 算法效率衡量执行时间单靠时间值绝对可信吗? 时间复杂度与 "大O记法"如何理解 “大O记法” 最坏时间复杂度时间复杂度的几条基本计算规则 算法分析常见的时间复杂度常见时间复杂度之间的关系…

2024最新版DataGrip安装教程-全网最全教程!!!

1.DataGrip下载安装 1.打开DataGrip官网,选择自己需要的版本下载即可: 2.进行安装: 3.重启打开: 我这个是正版激活码激活的,需要教程可以关注留言

网络爬虫中selenium和requests这两个工具有什么区别呢?

在自动化和网络爬虫的开发过程中,Selenium和Requests是两个常用的工具。尽管它们都可以用于从互联网上获取数据,但它们在用途、功能和工作原理上存在显著的差异。以下将详细探讨Selenium和Requests之间的主要区别。 一、用途和定位 Selenium&#xff1…

互联网的盈利模式

1. 广告收入 展示广告:通过在网站或应用上展示横幅广告、视频广告等,按点击次数(CPC)或展示次数(CPM)收费。搜索广告:通过搜索引擎上的关键词竞价广告,按点击次数收费。社交媒体广告…

conda 常用指令大集合

增删改查 注:所有的环境都保存在路径 ${anaconda安装目录}/env/[环境名]下 查看现有环境 (星号✳️代表当前) conda info --env 创建 conda 环境 conda create -n [环境名] python[版本号] 删除 conda 环境 conda remove -n [环境名] --all 修改…

如何通过京东API优雅地获取商品评论数据

在当今电商领域,用户评论成为了影响消费者购买决策的关键因素之一。京东,作为中国领先的电商平台,深知商品评论的重要性,并通过其开放平台提供了商品评论数据接口,让开发者能够轻松获取商品的用户反馈信息。本文将指导…

[Redis]持久化机制

众所周知,Redis是内存数据库,也就是把数据存在内存上,读写速度很快,但是,内存的数据容易丢失,为了数据的持久性,还得把数据存储到硬盘上 也就是说,内存有一份数据,硬盘也…

如何在 Windows 上安装 Docker Desktop

如何在 Windows 上安装 Docker Desktop Docker 是一个开放平台,用于开发、部署和运行应用程序。Docker Desktop 是 Docker 在 Windows 和 macOS 上的官方客户端,它使得开发者能够轻松地在本地环境中构建、运行和共享容器化应用程序。本文将详细介绍如何…

RuoYi Swagger请求401

问题描述: 提示:这里简述项目相关背景: 使用ruoyi-vue分离版,访问swagger,发现接口都调用失败:401 解决方案: 最终解决问题如下步骤: 1、 调用swagger中的接口,报错&a…

如何在SpringSecurity中配置基于角色的访问控制?

在Spring Security中配置基于角色的访问控制是保护应用程序和资源不被未授权访问的基本策略之一。这里,我们将详细介绍如何在配置中和方法级别上实现基于角色的访问控制。 1. 配置基于角色的访问控制 在Spring Security的配置类中,你可以使用HttpSecur…

揭秘MMAdapt:如何利用AI跨领域战胜新兴健康谣言?

MMAdapt: A Knowledge-Guided Multi-Source Multi-Class Domain Adaptive Framework for Early Health Misinformation Detection 论文地址: MMAdapt: A Knowledge-guided Multi-source Multi-class Domain Adaptive Framework for Early Health Misinformation Detection …

【Mysql】DQL操作单表、创建数据库、排序、聚合函数、分组、limit关键字

DQL操作单表 1.1 创建数据库 •创建一个新的数据库 db2 CREATE DATABASE db2 CHARACTER SET utf8;•将db1数据库中的 emp表 复制到当前 db2数据库 ** 1.2 排序** 通过 ORDER BY 子句,可以将查询出的结果进行排序 (排序只是显示效果,不会影响真实数据) 语法结构:…

算法:渐进记号的含义及时间复杂度计算

渐进记号及时间复杂度计算 渐近符号渐近记号 Ω \Omega Ω渐进记号 Θ \Theta Θ渐进记号小 ο \omicron ο渐进记号小 ω \omega ω渐进记号大 O \Omicron O常见的时间复杂度关系 时间复杂度计算:递归方程代入法迭代法套用公式法 渐近符号 渐近记号 Ω \Omega Ω …

每天写java到期末考试--接口1--基础--6.22

规则: 练习: 抽象类的抽象方法 动物类Animal package 期末复习;public abstract class Animal {private String name;private int age;//1.空构造public Animal(){}public Animal(String name,int age){this.ageage;this.namename;}public String getNa…

【C++提高编程-11】----C++ STL常用集合算法

🎩 欢迎来到技术探索的奇幻世界👨‍💻 📜 个人主页:一伦明悦-CSDN博客 ✍🏻 作者简介: C软件开发、Python机器学习爱好者 🗣️ 互动与支持:💬评论 &…

Nginx 负载均衡实现上游服务健康检查

Nginx 负载均衡实现上游服务健康检查 Author:Arsen Date:2024/06/20 目录 Nginx 负载均衡实现上游服务健康检查 前言一、Nginx 部署并新增模块二、健康检查配置2.1 准备 nodeJS 应用程序2.2 Nginx 配置负载均衡健康检查 小结 前言 如果你使用云负载均衡…

深入理解适配器模式:Java实现与框架应用

适配器模式是一种结构型设计模式,它允许将一个类的接口转换成客户端希望的另一个接口。适配器模式使得原本由于接口不兼容而不能一起工作的类可以协同工作。在本篇博客中,我们将详细介绍适配器模式,并演示如何在Java中实现它。最后&#xff0…

python从入门到精通9:字符串简介

Python中的字符串是一种非常常见且重要的数据类型,用于存储一系列字符(如文本、数字、标点符号等)。Python的字符串处理功能强大且灵活,为开发者提供了丰富的操作方法和工具。下面我们将对Python字符串进行深入的解析。 1. 字符串…