发表评论取消回复
相关阅读
相关 RocketMQ源码:consumer 负载均衡(重平衡)
前面我们有提到一个非常重要的概念,就是重平衡,只有在经过重平衡后,消息的拉取对象`PullMessageService`才可以去`Broker`拉取消息,那么这篇文章就单独分析
相关 RocketMQ源码:consumer 提交消费偏移量
1.什么是消费偏移量offset? 我们先看一幅图 ![format_png][] 消费偏移量`offset`就是记录消费者的消费进度的。也是`rocketmq保证消
相关 RocketMQ源码15- consumer启动流程
> 本系列[RocketMQ4.8注释github地址][RocketMQ4.8_github],希望对大家有所帮助,要是觉得可以的话麻烦给点一下Star哈 `org.apa
相关 RocketMQ源码9- broker 启动流程
1. 启动入口 `broker`的启动类为`org.apache.rocketmq.broker.BrokerStartup`,代码如下: public cla
相关 RocketMQ源码2-NameServer架构设计及启动流程
本文我们来分析NameServer相关代码,在正式分析源码前,我们先来回忆下NameServer的功能: NameServer是一个非常简单的Topic路由注册中心,其角色类
相关 RocketMQ源码分析【三】Broker启动流程源码分析
文章目录 入口 核心流程 BrokerController是如何被创建的 Broker是如何注册到NameServe
相关 RocketMQ源码解析七(Consumer拉取消息流程)
> RocketMQ版本4.6.0,记录自己看源码的过程 这里基于PUSH模式和集群模式来分析消息拉取机制。 在Consumer启动的时候,会开启一个线程,专门用来拉取消
相关 RocketMQ源码分析【二】NameServer启动流程源码分析
文章目录 入口 NamesrvController是如何被创建出来的 启动NameServer 定时任务线程池
还没有评论,来说两句吧...