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

RocketMQ消息文件过期原理

文章目录

  • 消费完后的消息去哪里了?
  • 什么时候清理物理消息文件?
  • 这样设计带来的好处
  • 跳过历史消息的处理

所有的消费均是客户端发起Pull请求的,告诉消息的offset位置,broker去查询并返回。但是有一点需要非常明确的是,消息消费后,消息其实并没有物理地被清除,这是一个非常特殊的设计。本文来探索此设计的一些细节。

消费完后的消息去哪里了?

消息的存储是一直存在于CommitLog中的,由于CommitLog是以文件为单位(而非消息)存在的,而且CommitLog的设计是只允许顺序写,且每个消息大小不定长,所以这决定了消息文件几乎不可能按照消息为单位删除(否则性能会极具下降,逻辑也非常复杂)。

什么时候清理物理消息文件?

那消息文件到底删不删,什么时候删?

消息存储在CommitLog之后,的确是会被清理的,但是这个清理只会在以下任一条件成立才会批量删除消息文件(CommitLog):

  1. 消息文件过期(默认72小时),且到达清理时点(默认是凌晨4点),删除过期文件。
  2. 消息文件过期(默认72小时),且磁盘空间达到了水位线(默认75%),删
http://www.lryc.cn/news/56291.html

相关文章:

  • Docker容器理解
  • SpringBoot 整合knife4j
  • 73-归并排序练习-LeetCode148排序链表
  • Hystrix学习笔记
  • 面向对象编程(基础)8:关键字:package、import
  • 【机器学习】P10 从头到尾实现一个线性回归案例
  • 【Java EE】-多线程编程(四) 死锁
  • 学习数据结构第1天(数据结构的基本概念)
  • 南大通用数据库-Gbase-8a-学习-33-空洞率查询与解决方法
  • 为什么我们认为GPT是一个技术爆炸
  • 程序员如何能提高自己的编程水平?
  • 从零使用vuepress搭建个人博客部署.github.io
  • Python 进阶指南(编程轻松进阶):十一、注释、文档字符串和类型提示
  • python item()方法
  • 【day2】Android Jetpack Compose环境搭建
  • stable-diffusion安装和简单测试
  • MATLAB算法实战应用案例精讲-【智能优化算法】 基于帕累托包络的选择算法II(PESA-II)(附MATLAB代码实现)
  • 【华为机试真题详解JAVA实现】—坐标移动
  • 【软考五】数据库(做题)
  • 【Java Web】012 -- SpringBootWeb综合案例(登录功能、登录校验、异常处理)
  • 跨界智能手表:比亚迪向左,小鹏向右
  • 【c++初阶】第九篇:vector(常用接口的使用 + 模拟实现)
  • Taro React组件使用(6) —— RuiSendCode 短信验证码【倒计时】
  • 把ChatGPT接入我的个人网站
  • 关于数字游民是未来年轻人工作趋势的一种思考
  • 2022年 合肥市经开区信息学竞赛区赛 初中组
  • 【工作小札】自定义classloader实现热加载jar
  • spring—AOP
  • 自己曾经的C++笔记【在c盘爆满的时候找到的回忆】
  • Nginx 实战-负载均衡