Redis(消息队列Stream)

Stream是一个轻量级的消息队列。

Redis中Stream的作用是提供一种高效的消息传递机制,允许多个消费者并行地消费消息,并且不会重复消费已经处理过的消息。它可以用于实现分布式任务队列、日志收集、实时数据处理等场景。Redis中的Stream支持多个消费者组,每个消费者组可以独立消费消息,并且可以设置消费者组的消费位置,从而支持消息的多次消费和重放。同时,Redis的Stream还提供了一些高级特性,如持久化、自动截断、消息过期等,使得它更加适合在生产环境中使用。

Stream相关的命令都以X开头。

使用XADD添加返回的是消息ID,通过XLEN查看消息的数量。

通过使用XRANGE查询消息队列中的所有消息,包括消息ID,- +代表所有。

当然消息队列也是可以删除的,使用XDEL加消息ID就可以实现删除,这里就不做演示了。

删除消息也可以通过XTRIM来实现

XTRIM xbcl MAXLEN 0

上述代码代表删除所有消息

 

 在添加时可以自己指定消息ID,要保证这个ID是递增的,如果输入* Redis会保证消息ID是递增的 。

指定的ID第一个整数表示一个时间戳,第二个整数表示一个序列号。

可以使用XREAD来获取消息,COUNT后面的2代表获取的消息数量,BLOCK 1000代表如果没有消息就阻塞1000毫秒(返回nil),geekhour 0代表从头开始获取(下标从0开始)。

如果希望获取从现在开始以后的最新消息就可以把最后的0改成$。

创建一个叫做group1的消费者组:

XGROUP GREATE geekhour group1 0

 

使用XINFO查询消费者组,XGROUP添加消费者。 

 

在连续添加了3个消费者后,查询消息发现group1组中有3个消费者 

使用XREADGROUP来读取消息,消息名字geekhour后的>表示从这个消息中读取最新消息

在Redis的XREADGROUP命令中,消息名称是由消费者组名和消息ID组成的。消息ID是一个由Redis自动生成的唯一标识符,它的格式为时间戳+序列号,例如"1631714987556-0"。在XREADGROUP命令中,消息名称的最后一个参数是">"符号,表示从当前时间开始获取最新的消息。如果想要获取指定消息ID之后的消息,可以将">"符号替换为指定的消息ID。例如,如果想要从消息ID为"1631714987556-0"之后获取消息,可以将消息名称的最后一个参数设置为"1631714987556-0"。

COUNT 2表示一次读取两条消息

输出就表明我们刚刚发布的消息被消费了。

为什么能解决订阅消息的问题:

Stream在Redis中是一种新的数据结构,用于解决发布/订阅模式中存在的一些问题。发布/订阅模式通常使用PUB/SUB命令来实现,但它存在一些限制和缺点,比如无法保证消息的持久性、消息的顺序性和消费者的灵活性等。

Stream通过引入消息ID、消费者组和消费者偏移量等概念,解决了这些问题。具体来说,Stream解决了以下几个问题:

1. 持久性:Stream中的消息会被持久化保存在内存中,即使没有订阅者,消息也不会丢失。这样就可以保证消息的持久性。

2. 顺序性:Stream中的消息是有序的,每个消息都有一个唯一的消息ID。消费者可以按照消息ID的顺序来消费消息,确保消息的顺序性。

3. 消费者灵活性:Stream引入了消费者组的概念,允许多个消费者共同消费一个消息流,而且每个消费者可以有自己的消费偏移量。这样就可以实现消费者的灵活性,比如可以动态地添加或移除消费者,而不会影响其他消费者。

4. 消息确认和重试:Stream中的消费者可以使用XACK命令来确认已经处理过的消息,同时可以使用XCLAIM命令来重新获取未确认的消息,从而实现消息的确认和重试。

总之,Stream通过引入消息ID、消费者组和消费者偏移量等概念,解决了发布/订阅模式中存在的一些问题,使得消息的处理更加灵活和可靠。

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Python数据分析实战① Python实现数据可视化

文章目录 一、数据可视化介绍二、matplotlib和pandas画图1.matplotlib简介和简单使用2.matplotlib常见作图类型3.使用pandas画图4.pandas中绘图与matplotlib结合使用 三、订单数据分析展示四、Titanic灾难数据分析显示 一、数据可视化介绍 数据可视化是指将数据放在可视环境中…

6.2 List和Set接口

1. List接口 List接口继承自Collection接口,List接口实例中允许存储重复的元素,所有的元素以线性方式进行存储。在程序中可以通过索引访问List接口实例中存储的元素。另外,List接口实例中存储的元素是有序的,即元素的存入顺序和取…

【Linux网络编程】高级I/O

目录 五种I/O模型 阻塞和非阻塞 非阻塞I/O I/O多路复用之Select、Poll、与Epoll 本文目的是深入浅出理解高级I/O相关的知识,结尾附上代码加深理解相关知识。 五种I/O模型 1.阻塞I/O:在内核将数据准备好之前,系统调用会一直等待。所有的套…

【踩坑笔记】国科GK7202V300芯片开发常见问题解决办法

国科Linux芯片开发常见问题&解决办法 0.读前须知 不管什么时候,下载程序还是啥,一定要检查路径!!!别问我为什么,呜呜呜~ tips:该芯片是仿造海思的产品,所以,有些不…

cp: can‘t stat ‘/usr/share/zoneinfo/Asia/Shanghai‘: No such file or directory

目录 问题描述问题分析解决方案容器时区验证 问题描述 使用下面的 Dockerfile 为 youlai-boot 项目制作镜像设置容器时区报错。 # 基础镜像 FROM openjdk:17-jdk-alpine # 时区修改 RUN /bin/cp /usr/share/zoneinfo/Asia/Shanghai /etc/localtime \&& echo Asia/Sha…

【每周一测】Java阶段三阶段考试

目录 1、SpringBoot在整合RabbitMQ时需要导入的包是 2、下列关于RabbitMQ的confirm消息确认机制解释说明正确的是 3、关于SpringBoot的配置文件,以下说法正确的是() 4、变量命名规范说法正确的是? 5、哪个关键字可以对对象加互斥锁&…

计算机视觉的应用18-一键抠图人像与更换背景的项目应用,可扩展批量抠图与背景替换

大家好,我是微学AI,今天给大家介绍一下计算机视觉的应用18-一键抠图人像与更换背景的项目应用,可扩展批量抠图与背景替换。该项目能够让你轻松地处理和编辑图片。这个项目的核心功能是一键抠图和更换背景。这个项目能够自动识别图片中的主体&…

医院绩效考核系统源码 医院绩效考核系统方案

医院绩效考核系统源码 医院绩效考核系统是现代医院管理的重要方法和科学的管理工具。良好的绩效管理,有助于带动全院职工的工作积极性,有助于提高工作效率、提高医疗质量、改善服务水平、降低运营成本,全面提升医院的精细化管理水平。 医院绩…

Flask学习一:概述

搭建项目 安装框架 pip install Flask第一个程序 from flask import Flaskapp Flask(__name__)app.route(/) def hello_world():return "Hello World"if __name__ __main__:app.run()怎么说呢,感觉还不错的样子。 调试模式 if __name__ __main__:a…

后端老项目迁移方法

老项目迁移方法 需求: 因某个模块MySQL表结构、表关系 错乱复杂,而且其他模块的代码也在操作这个模块的数据库 耦合严重 导致Web工程代码紊乱、不易理解、性能低下, 故在 系统由A JavaWeb工程迁移至B工程 时,重构MySQL表结构、表…

VS中修改解决方案名称和项目名称

如何修改visual studio2019中的项目名 - 知乎 (zhihu.com) 查了很多,还是这个可行。虽然文中说不是最简单的,但在所查找资料中是可行且最简单的。 要点主要是: 1、比如我们复制一个解决方案,最好是带代码哈,也就是添…

ToolJet:开源低代码框架,轻松构建复杂可响应界面 | 开源日报 No.78

ToolJet/ToolJet Stars: 25.0k License: AGPL-3.0 ToolJet 是一个开源的低代码框架,可以通过最小化工程投入来构建和部署内部工具。ToolJet 的拖放式前端构建器允许您在几分钟内创建复杂、响应式的前端界面。此外,您还可以集成各种数据源,包…

java使用 TCP 的 Socket API 实现客户端服务器通信

一:什么是 Socket(套接字) Socket 套接字是由系统提供于网络通信的技术, 是基于 TCP/IP 协议的网络通信的基本操作,要进行网络通信, 需要有一个 socket 对象, 一个 socket 对象对应着一个 socket 文件, 这个文件在 网卡上而不是硬盘上, 所以有了 sokcet…

互联网医院牌照|智慧医疗离不开牌照办理

互联网医院牌照是由卫生健康行政部门颁布的,所有材料审核通过后,相关部门授予《医疗机构执业许可证》,取得牌照后才有开展互联网诊疗活动的资质,但开展线上问诊也需要向发证机关提出申请,下面小编就给大家讲解下互联网…

LLM大模型量化原理

大型语言模型(LLM)可以用于文本生成、翻译、问答任务等。但是,LLM 也非常大(显然,大型语言模型)并且需要大量内存。 这对于手机和平板电脑等小型设备来说可能具有挑战性。 可以将参数乘以所选的精度大小以…

深入理解Linux网络笔记(六):深度理解TCP连接建立过程

本文为《深入理解Linux网络》学习笔记,使用的Linux源码版本是3.10,网卡驱动默认采用的都是Intel的igb网卡驱动 Linux源码在线阅读:https://elixir.bootlin.com/linux/v3.10/source 5、深度理解TCP连接建立过程 1)、深入理解liste…

JVM:字节码文件,类的生命周期,类加载器

JVM:字节码文件,类的生命周期,类加载器 为什么要学这门课程 1. 初识JVM1.1. 什么是JVM1.2. JVM的功能1.3. 常见的JVM 2. 字节码文件详解2.1. Java虚拟机的组成2.2. 字节码文件的组成2.2.1. 以正确的姿势打开文…

进阶理解:leetcode115.不同的子序列(细节深度)

这道题是困难题,本章是针对于动态规划解决,对于思路进行一个全面透彻的讲解,但是并不是对于基础讲解思路,而是渗透到递推式和dp填数的详解,如果有读者不清楚基本的解题思路,请看我的这篇文章算法训练营DAY5…

基于Vue+SpringBoot的厦门旅游电子商务预订系统 开源项目

项目编号: S 030 ,文末获取源码。 \color{red}{项目编号:S030,文末获取源码。} 项目编号:S030,文末获取源码。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 景点类型模块2.2 景点档案模块2.3 酒…

MatLab的下载、安装与使用(亲测有效)

1、概述 MatLab是由MathWorks公司开发并发布的,支持线性代数、矩阵运算、绘制函数和数据、信号处理、图像处理以及视频处理等功能。广泛用于算法开发、数据可视化、数据分析以及数值计算等。 Matlab 的主要特性包括: 简单易用的语法,使得程…