消息中间件RocketMQ原理解析 - 斩秋size > 0 如果数据有效读取下 20 个字节判断是否有效 如果数据无效跳出循环,记录此时有效数据的偏移量 processOffset 如果读到文件尾,读取下一个文件 proccessOffset 是有效数据的偏移量,获取这个值的作用什么? (1) proccessOffset 后面的数据属于脏数据,后面的文件要删除掉0 码力 | 57 页 | 2.39 MB | 1 年前3
RocketMQ v3.2.4 开发指南长度的队列,丌管有多少数据迕来都能装得下,返个无限是有前提的,Broker 会定期删除过期的数据,例如 Broker 只保存 3 天的消息,那举返个 Buffer 虽然长度无限,但是 3 天前的数据会被从队尾删除。 4.11 回溯消费 回溯消费是挃 Consumer 已经消费成功的消息,由亍业务上需求需要重新消费,要支持此功能,Broker 在吐 Consumer 投递成功消息后,消息仍然需要保0 码力 | 52 页 | 1.61 MB | 1 年前3
共 2 条
- 1













