已有3人关注此标签
源码分析 RocketMQ DLedger 多副本之 Leader 选主
作者: 丁威
18人浏览
本文将按照《RocketMQ 多副本前置篇：初探raft协议》的思路来学习RocketMQ选主逻辑。首先先回顾一下关于Leader的一些思考： 节点状态需要引入3种节点状态：Follower(跟随者)、Candidate(候选者)，该状态下的节点会发起投票请求，Leader(主节点)。
源码分析 RocketMQ DLedger 多副本存储实现
作者: 丁威
16人浏览
详细介绍了RocketMQ DLedger 多副本存储实现部分，主要参考RocketMQ 存储部分的设计理念，并重点阐述 DLedger 消除存储格式、索引文件存储格式，诸如内存映射、刷盘、过期文件删除、文件加载与恢复由于在《RocketMQ技术内幕》中详细介绍，故本文并未重复介绍。
RocketMQ 多副本前置篇：初探raft协议
作者: 丁威
242人浏览
详细介绍了raft协议的Leader选举流程、日志复制两个重要部分，并提出实现raft协议需要考虑的问题点，为源码解析RocketMQ Dledger 多副本模块打下坚实的基础。
RocketMQ一个新的消费组初次启动时从何处开始消费呢？
作者: 丁威
132人浏览
本文详细介绍一个新的消费组在启动时从何处开始消费，并信息介绍了CONSUME_FROM_MAX_OFFSET、CONSUME_FROM_FIRST_OFFSET、CONSUME_FROM_TIMESTAMP其计算逻辑，解答CONSUME_FROM_MAX_OFFSET在什么情况下不生效并如何解决。
RocketMQ消息轨迹-设计篇
作者: 丁威
2356人浏览
RocketMQ 消息轨迹主要包含两篇文章：设计篇与源码分析篇，本节将详细介绍RocketMQ消息轨迹-设计相关。 RocketMQ消息轨迹，主要跟踪消息发送、消息消费的轨迹，即详细记录消息各个处理环节的日志，从设计上至少需要解决如下三个核心问题： 消费轨迹数据格式 记录消息轨迹(消息日志) 消息轨迹数据存储在哪？ 1、消息轨迹数据格式 RocketMQ4.5版本消息轨迹主要记录如下信息： traceType跟踪类型，可选值：Pub(消息发送)、SubBefore(消息拉取到客户端，执行业务定义的消费逻辑之前)、SubAfter(消费后)。
源码分析RocketMQ ACL实现机制
作者: 丁威
3001人浏览
有关RocketMQ ACL的使用请查看上一篇《RocketMQ ACL使用指南》，本文从源码的角度，分析一下RocketMQ ACL的实现原理。 备注：RocketMQ在4.4.0时引入了ACL机制，本文代码基于RocketMQ4.5.0版本。
RocketMQ ACL使用指南
作者: 丁威
162人浏览
详细介绍RocketMQ acl访问控制列表的流程图、plain_acl.yml文件各配置项的详细介绍、权限匹配验证流程与acl使用示例。
RocketMQ 主从同步若干问题答疑
作者: 丁威
191人浏览
主，从服务器都在运行过程中，消息消费者是从主拉取消息还是从从拉取？当消息消费者向从服务器拉取消息后，会一直从从服务器拉取？主从服务消息消费进是如何同步的？
RocketMQ问题排查思路
作者: 阴转多云转晴
228人浏览
1、使用HTTP协议报错500。排查思路： 1）. 是不是有tcp的producer在发送。 2）. 是不是有大量的非法字符。建议单独建一个topic给http，然后再进行测试。 2、报没有权限： 1). 如果是主账号：确保GID和topic都是主账号创建； 2). 如果是子账号：确保GID是子账号创建，并且topic授权这个ak使用。
RocketMQ 消息发送system busy、broker busy原因分析与解决方案
作者: 丁威
211人浏览
1、现象 最近收到很多RocketMQ使用者，反馈生产环境中在消息发送过程中偶尔会出现如下4个错误信息之一：1）[REJECTREQUEST]system busy, start flow control for a while2）too many requests and system thre.
RocketMQ源码分析之RocketMQ事务消息实现原下篇(事务提交或回滚)
作者: 丁威
1234人浏览
事务消息提交或回滚的实现原理就是根据commitlogOffset找到消息，如果是提交动作，就恢复原消息的主题与队列，再次存入commitlog文件进而转到消息消费队列，供消费者消费，然后将原预处理消息存入一个新的主题RMQ_SYS_TRANS_OP_HALF_TOPIC，代表该消息已被处理；回滚消息与提交事务消息不同的是，提交事务消息会将消息恢复原主题与队列，再次存储在commitlog文件中。
RocketMQ源码分析之RocketMQ事务消息实现原理中篇----事务消息状态回查
作者: 丁威
1063人浏览
本文详细分析了RocketMQ事务消息实现原理中的事务状态回查实现，RocketMQ会默认一分钟的频率处理消息状态为Prepare的消息，通过调用消息生产者的事务状态查询接口得知消息的事务状态，从而决定提交或回滚消息。
RocketMQ实战：生产环境中，autoCreateTopicEnable为什么不能设置为true
作者: 丁威
249人浏览
1、现象 很多网友会问，为什么明明集群中有多台Broker服务器，autoCreateTopicEnable设置为true，表示开启Topic自动创建，但新创建的Topic的路由信息只包含在其中一台Broker服务器上，这是为什么呢？ 期望值：为了消息发送的高可用，希望新创建的Topic在集群中的每台Broker上创建对应的队列，避免Broker的单节点故障。
RocketMQ 学习之路 | 第二章 ：RocketMQ-console的安装
作者: ____h
594人浏览
一.介绍 rocketmq有一个对其扩展的开源项目，github：https://github.com/apache/rocketmq-externals 。 其中有一个子模块rocketmq-console，该子模块提供为rocketmq提供可视化的监控界面。
RocketMQ 学习之路 | 第一章 ：RocketMQ 的安装与配置
作者: ____h
594人浏览
一：RocketMQ 简介 RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点： 能够保证严格的消息顺序。 提供丰富的消息拉取模式。 高效的订阅者水平扩展能力。 实时的消息订阅机制。
如何在优雅地Spring 中实现消息的发送和消费
作者: 中间件小哥
3283人浏览
本文将对rocktmq-spring-boot的设计实现做一个简单的介绍，读者可以通过本文了解将RocketMQ Client端集成为spring-boot-starter框架的开发细节，然后通过一个简单的示例来一步一步的讲解如何使用这个spring-boot-starter工具包来配置，发送和消费RocketMQ消息。
【3-2 报名中】Apache RocketMQ 开发者沙龙 成都站
作者: amber涂南
1920人浏览
2019 年 3 月 2 日，【Apache RocketMQ 开发者沙龙成都站】将携社区核心成员、创始人，带着 Apache RocketMQ 5.0 新特性和渴望交流探讨的心，希望能与成都的开发者碰撞出火花。
《RocketMQ技术内幕：RocketMQ架构设计与实现原理》—1.1.2 Eclipse调试RocketMQ源码
作者: 小编辑01
1379人浏览
本节书摘来自华章计算机《RocketMQ技术内幕：RocketMQ架构设计与实现原理》一书中的第1章，丁威 周继峰 著。更多章节内容可以访问云栖社区“华章计算机”公众号查看。
《RocketMQ技术内幕：RocketMQ架构设计与实现原理》—1.1.1 Eclipse获取RocketMQ源码
作者: 小编辑01
1759人浏览
本节书摘来自华章计算机《RocketMQ技术内幕：RocketMQ架构设计与实现原理》一书中的第1章，丁威 周继峰 著。更多章节内容可以访问云栖社区“华章计算机”公众号查看。
