中间件兴趣圈 + 关注
手机版

一次 RocketMQ 进程自动退出排查经验分享(实战篇)

1、背景 公司一个 RocketMQ 集群由4主4从组成,突然其中3台服务器“竟然”在同一时间下线,其监控显示如下:依次查看三台机器的监控图形,时间戳几乎完美“吻合”,不可思议吧。 2、故障分析 出现问题,先二话不说,马上重启各服务器,尽...

故障方案 分布式 消息系统 开发框架与中间件 java 日志 集群 中间件 Image RocketMQ rocketmq实战 broker异常退出

源码阅读技巧篇:RocketMQ DLedger 多副本即主从切换专栏回顾

RocketMQ DLedger 多副本即主从切换专栏总共包含9篇文章,时间跨度大概为2个月的时间,笔者觉得授人以鱼不如授人以渔,借以这个系列来展示该系列的创作始末,展示笔者阅读源码的技巧。 首先在下决心研读 RocketMQ DL...

消息系统 开发框架与中间件 日志 源码 同步 aliyun 主从切换 单元测试 存储 raft RocketMQ DLedger 日志复制 源码阅读技巧 raft选主

RocketMQ 平滑升级到主从切换实战

本文主要介绍如何将 RocketMQ 集群从原先的主从同步升级到主从切换。 首先介绍与 DLedger 多副本即 RocketMQ 主从切换相关的核心配置属性,然后尝试搭建一个主从同步集群,再从原先的 RocketMQ 集群平滑升级到 D...

分布式 消息系统 Java核心技术 开发框架与中间件 实战 配置 集群 Image 主从切换 RocketMQ DLedger 多副本

RocketMQ 整合 DLedger(多副本)即主从切换实现平滑升级的设计技巧

源码分析 RocketMQ DLedger 多副本系列已经进行到第 8 篇了,前面的章节主要是介绍了基于 raft 协议的选主与日志复制,从本篇开始将开始关注如何将 DLedger 应用到 RocketMQ中。

分布式 消息系统 开发框架与中间件 java 日志 源码 配置 集群 主从切换 主从同步 存储 RocketMQ DLedger 多副本 平滑升级

基于 raft 协议的 RocketMQ DLedger 多副本日志复制设计原理

上一篇 源码分析 RocketMQ DLedger(多副本) 之日志复制(传播) ,可能有不少读者朋友们觉得源码阅读较为枯燥,看的有点云里雾里,本篇将首先梳理一下 RocketMQ DLedger 多副本关于日志复制的三个核心流程图,然...

分布式 消息系统 开发框架与中间件 日志 源码 集群 Image aliyun 存储 raft RocketMQ 原理 DLedger 多副本 日志复制

源码分析 RocketMQ DLedger 多副本之 Leader 选主

本文将按照《RocketMQ 多副本前置篇:初探raft协议》的思路来学习RocketMQ选主逻辑。首先先回顾一下关于Leader的一些思考: 节点状态需要引入3种节点状态:Follower(跟随者)、Candidate(候选者),该...

消息系统 开发框架与中间件 java 源码 集群 request RocketMQ leader DLedger 多副本 选主

RocketMQ 主题扩分片后遇到的坑

消息组接到某项目组反馈,topic 在扩容后出现部分队列无法被消费者,导致消息积压,影响线上业务? 考虑到该问题是发送在真实的线上环境,为了避免泄密,本文先在笔者的虚拟机中来重现问题。 1、案情回顾 1.

故障方案 分布式 消息系统 开发框架与中间件 集群 Image RocketMQ 集群扩容 消息队列不消费

RocketMQ一个新的消费组初次启动时从何处开始消费呢?

本文详细介绍一个新的消费组在启动时从何处开始消费,并信息介绍了CONSUME_FROM_MAX_OFFSET、CONSUME_FROM_FIRST_OFFSET、CONSUME_FROM_TIMESTAMP其计算逻辑,解答CONSUME_F...

故障方案 消息系统 开发框架与中间件 消息队列 Consumer 存储 RocketMQ CONSUME_FROM_MAX_OFFSET CONSUME_FROM_FIRST_OFFSET CONSUME_FROM_TIMESTAMP

RocketMQ消息轨迹-设计篇

RocketMQ 消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍RocketMQ消息轨迹-设计相关。 RocketMQ消息轨迹,主要跟踪消息发送、消息消费的轨迹,即详细记录消息各个处理环节的日志,从设计上至少需要解决如下三个...

消息系统 开发框架与中间件 服务器 配置 集群 消息中间件 中间件 存储 数据存储 RocketMQ 消息轨迹

RocketMQ ACL使用指南

详细介绍RocketMQ acl访问控制列表的流程图、plain_acl.yml文件各配置项的详细介绍、权限匹配验证流程与acl使用示例。

消息系统 开发框架与中间件 配置 static Consumer 数组 RocketMQ acl 使用指南 rocketmq访问控制

RocketMQ 主从同步若干问题答疑

主,从服务器都在运行过程中,消息消费者是从主拉取消息还是从从拉取?当消息消费者向从服务器拉取消息后,会一直从从服务器拉取?主从服务消息消费进是如何同步的?

消息系统 开发框架与中间件 服务器 同步 主从切换 主从同步 存储 RocketMQ 从不消费

RocketMQ 消息发送system busy、broker busy原因分析与解决方案

1、现象 最近收到很多RocketMQ使用者,反馈生产环境中在消息发送过程中偶尔会出现如下4个错误信息之一:1)[REJECTREQUEST]system busy, start flow control for a while2)too...

架构 服务器 线程 源码 Image 解决方案 busy RocketMQ broker 开源框架与中间件 TransientStorePool isOSPageCacheBusy REJECTREQUEST PC_SYNCHRONIZED PCBUSY_CLEAN_QUEUE

RocketMQ实战:生产环境中,autoCreateTopicEnable为什么不能设置为true

1、现象 很多网友会问,为什么明明集群中有多台Broker服务器,autoCreateTopicEnable设置为true,表示开启Topic自动创建,但新创建的Topic的路由信息只包含在其中一台Broker服务器上,这是为什么呢? ...

消息系统 架构 服务器 集群 Image RocketMQ autoCreateTopicEnable

生产环境JVM内存溢出案例分析

线上JVM内存溢出案例分析详解,本文详细的介绍了生产环境JVM内存溢出的故障分析过程,更是提供在故障发生之前如何快速隔离故障源、防止故障扩散等方法。

服务器 SQL 线程 数据库 dump hashmap 内存溢出 线上故障分析

Es使用指南之Elasticsearch文档读写模型实现原理

本文详细介绍了ElasticSearch文档的读写模型的设计思路,涉及到写模型及其异常处理、读模型及其异常处理、主备负载模型背后隐含的设计缺陷与ElasticSearch在异常情况带来的影响。

集群 同步 索引 Elasticsearch elasticsearch读写模型 es分片数据一致性

RocketMQ事务消息实战

本文主要是考虑在使用消息中间件时,如果保证不丢消息的一些实践思考。

Apache 消息中间件 string 伪代码 RocketMQ 事务消息 事务消息实战

RocketMQ源码分析之从官方示例窥探:RocketMQ事务消息实现基本思想

RocketMQ源码分析之从官方示例窥探RocketMQ事务消息实现基本思想。

消息系统 线程 源码 thread RocketMQ事务消息

《RocketMQ技术内幕》作者维护,关注主流中间件技术,包含源码分析JAVA集合、JUC(并发包)、Netty、Mycat、Dubbo、RocketMQ、Mybatis、ElasticJob等。

管理员:
丁威
10
+ 关注
1
成员
63
文章