Apache RocketMQ 从入门到实战setSuggestPullingFromSlave(diff > memory); // @3 代码@1:首先介绍一下几个局部变量的含义: maxOffsetPy 当前最大的物理偏移量。返回的偏移量为已存入到操作系统的 PageCache 中的内容。 maxPhyOffsetPulling 本次消息拉取最大物理偏移量,按照消息顺序拉取的基本原则,可以基本预测下次开始 拉取的物理偏移量将大于该值,并且就在其附近。 isTransientStorePoolDeficient(); // @2 } 拒绝请求的条件有两个,只要其中任意一个满足,则返回 true。 代码@1:Os PageCache busy,判断操作系统 PageCache 是否繁忙,如果忙, 则返回 true。想必看到这里大家肯定与我一样好奇,RocketMQ 是如何判断 pageCache 是否繁忙呢?下面会重点分析。 代码@2:transientStorePool RocketMQ 集群部署的最佳实践 < 108 1.11 从年末生产故障解锁 RocketMQ 集 群部署的最佳实践 笔者比较“悲催”,临近年末由笔者维护的生产 MQ 集群中的一台物理机内存故障导 致操作系统异常重启,持续 10 分钟中出现众多的应用发送客户端出现发送消息络超时,导 致事故并定性为 S1,笔者的“年终奖”。。。 一、故障描述 RocketMQ 集群采取的部署架构为 2 主 2 从,其部署架构如下图所示:0 码力 | 165 页 | 12.53 MB | 1 年前3
万亿级数据洪峰下的消息引擎Apache RocketMQ低延迟分布式存储系统 – PageCache的毛刺解决方案小结 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺解决方案小结 操作系统Page Cache Radix Tree 自旋锁,产生几秒的大毛刺 如果遇到坏盘,可能Block若干分钟,对系统产生致命影响。 操作系统Page Cache Radix Tree 每个Page的阻塞锁,产生几百毫秒小毛刺 写入数据平均响应时间不超过1ms 写入0 码力 | 35 页 | 993.29 KB | 1 年前3
万亿级数据洪峰下的消息引擎 Apache RocketMQ低延迟分布式存储系统 – PageCache的毛刺解决方案小结 1.4万亿 低延迟分布式存储系统 – PageCache的毛刺解决方案小结 操作系统Page Cache Radix Tree 自旋锁,产生几秒的大毛刺 如果遇到坏盘,可能Block若干分钟,对系统产生致命影响。 操作系统Page Cache Radix Tree 每个Page的阻塞锁,产生几百毫秒小毛刺 写入数据平均响应时间不超过1ms 写入0 码力 | 35 页 | 5.82 MB | 1 年前3
共 3 条
- 1













