当前位置: 首页 > article >正文

【Redis】Redis实现的消息队列

一、用list实现【这是数据类型所以支持持久化】

        消息基于redis存储不会因为受jvm内存上限的限制,支持消息的有序性,基于redis的持久化机制,只支持单一消费者订阅,无法避免消息丢失。

二、用PubSub【这不是数据类型,是一种通讯机制,所以不支持持久化】

        支持多消费者订阅,但是不支持消息持久化,无法避免消息丢失。

三、基于stream的消息队列

        单消费模式

        【】是可选参数

        消息可以回溯,也可以被多个消费者读取,读取后不会消失,可以阻塞读取数据,但是可能会漏读因为循环后读取$意思是读取最新消息,如果一次性插入多个数据,可以读取只读取到最后一条消息,其他消息可能会漏读。

        消费者组消费模式

        它可以保证消费者从最后次一次消费的时候开始消费,避免消息丢失。然后它可以避免消费者对于同一个消息重复消费,会有消息确认机制,发送消息后会是pending状态,它会进入一个pendding队列,防止消息进入队列后没有持久化就挂掉,它会先存起来,对redis恢复后进行ack消息确认如果确认了说明消息被使用了,那就移除这个pendding队列。


http://www.kler.cn/a/402224.html

相关文章:

  • (Linux 入门) 基本指令、基本权限
  • 使用ufw配置防火墙,允许特定范围IP访问
  • 使用MaxKB搭建知识库问答系统并接入个人网站(halo)
  • 《编程与艺术的交汇:Python Turtle 绘画与游戏制作》
  • Dart:字符串
  • 进程其他知识点
  • Vue3插槽v-slot使用方式
  • kubesphere问题处理:devops
  • 【leetcode】LCR150.彩灯装饰记录Ⅲ
  • Windsurf:超越 Cursor 的下一代 AI 编程助手
  • 使用C#编写一个控制台应用程序,实现文件的复制功能。
  • 软件工程9、10章小测
  • JavaScript 中,.call()的使用详解
  • Android U 多任务启动分屏——SystemUI流程(更新中)
  • perf使用方法
  • .NET 9 运行时中的新增功能
  • go语言中的切片含义和用法详解
  • (计算机毕设)基于SpringBoot+Vue的房屋租赁系统的设计与实现
  • 共享门店模式:创新零售的新篇章
  • 11.18 Maven-SpringBootWeb入门
  • Spring Boot图书馆管理系统:疫情中的技术实现
  • R环境依赖的备份与恢复全攻略
  • 【PHP小课堂】一起学习PHP中的反射(三)
  • selenium元素定位校验以及遇到的元素操作问题记录
  • OpenAI Adjusts Strategy as ‘GPT’ AI Progress Slow
  • 将大模型生成数据存入Excel,并用增量的方式存入Excel