加载中
rocketmq之源码分析阶段总结(二十一)

RocketMQ是队列模型的消息中间件,具有高性能,高可靠,高实时,分布式的特点。同时支持分布式事物的两阶段提交,实现在分布式环境的事物操作。 1,nameserv是分布式的部署,并且相互之间不通...

2019/06/27 14:09
150
rocketmq之源码分析broker之核心存储(二十)

这里根据RocketMQ的前期操作将整理Broker的存储设计及核心层次关系,先上图,根据源码的分析及整理,最终的核心层级关系如下: 1,通信层采用netty来进行网络的接受及处理 2,核心的处理有针...

2019/06/13 17:30
182
rocketmq之源码分析broker之核心MessageStore消息拉取(十九)

根据消息的拉取代码,broker端的大体操作步骤如下,主要进行pullMessage 1,构建netty协议的响应体,主要是返回数据用,后期的操作是基于该对象进行内容填充 2,构造响应头对象,从请求体中解...

2019/06/11 17:32
373
rocketmq之源码分析broker之核心MessageStore消息接受(十八)

这章我们从broker接受到消息后的处理,从源码加注解的角度解析整体处理及技术,整体的处理步骤如下: sendMessage 1,消息协议转换,主要是兼容协议版本 2,验证消息的正确性,主要是当前bro...

2019/06/10 19:06
222
rocketmq之源码分析broker之核心MessageStore存储设计(十七)

Broker的BrokerController的初始化中比较核心的就是MessageStore的初始化操作,这章我们根据源码的加载顺序详细的解析MessageStore的初始化及加载操作,涉及到Broker的高性能技术及设计,找到...

2019/06/10 16:54
575
rocketmq之源码分析broker入口BrokerController初始化过程(十六)

接着上一章的BrokerController的基础功能讲,本章主要介绍的是BrokerController的初始化操作,在初始化的过程中做了哪些事情,使用了哪些技术设计完成了对broker的初始化操作。一切分析都是基...

2019/06/07 23:10
383
rocketmq之源码分析broker入口BrokerController解析(十五)

broker的入口管理服务类BrokerController,在该类中定义并初始化了整个broker需要的核心操作。broker在接口请求处理的过程中,涉及到四方服务的数据交互:namesrv服务,进行发布当前broker的...

2019/06/06 15:01
935
rocketmq之源码分析broker整体事件流(十四)

这里先从整体的执行请求流程进行梳理,然后针对broker的实现细节再做深入优化 RocketMQ的整体事件操作步骤为: producer -> netty -> broker -> netty -> consumer 先从整体的一张大图上看,...

2019/06/05 16:06
269
rocketmq之源码分析broker的类逻辑(十三)

broker的功能比较重要,体现了很多高性能的功能及技术,这里会分的比较细来介绍和源码解释 首先将broker的整体初始化,启动类的逻辑调用顺序捋顺,下图是整体的逻辑图 分为三个主要阶段 1,构...

2019/06/04 17:10
191
rocketmq之源码分析consumer持续拉取操作(十二)

consumer的核心,特别是push性的消息拉取,实现自动感知,自动拉取消息的操作 核心的启动在拉取消息的自动任务执行,核心思想如下 拉取消息任务-》根据订阅信息、消费消息位置-》组装请求协议...

2019/06/03 15:37
235
rocketmq之源码分析consumer源码解析注释(十一)

consumer的常规订阅消息的总体操作流程: 构造初始化-》注册监听-》启动-》无限循环请求队列-》长连接的数据拉取 一,构造初始化 DefaultMQPushConsumer:常规的订阅消息,需要制定唯一的分组...

2019/06/03 14:48
277
rocketmq之源码分析consumer启动流程(十)

基于consumer的启动流程,前期先基于类的顺序图来说明,可以一目了然,然后再基于源码进行分析 consumer的核心操作类: DefaultMQPushConsumer: MessageListener:消息监听,接受消息做处理...

2019/06/03 10:28
241
rocketmq之源码分析producer的常规操作细节(九)

细节一,消息发送前,需要获得topic的发布配置信息 TopicPublishInfo topicPublishInfo = this.tryToFindTopicPublishInfo(msg.getTopic());//获得消息发布的topic配置信息 private TopicPub...

2019/05/31 15:58
135
rocketmq之源码分析producer的常规操作(八)

前提:rocketmq的broker是重点,里面涉及到最终的性能及技术实现,放置到最后,后面的章节会根据操作不同,穿插和功能相关的说明 producer的操作,我们这里先做基本的操作,就是我们说的快速...

2019/05/31 14:21
324
rocketmq之源码分析netty流程及细节(七)

netty的标准设计流程为:编码,解码,检测,链接,其他handler,业务。按照这个流程将rocketmq的netty的实现流程进行细化。 编码 NettyEncoder 继承MessageToByteEncoder,netty的编码规范要...

2019/05/30 15:13
298
rocketmq之源码分析netty实现源码(六)

netty的服务端核心属性 public class NettyRemotingServer extends NettyRemotingAbstract implements RemotingServer { private static final InternalLogger log = InternalLoggerFactory...

2019/05/29 17:21
414
rocketmq之源码分析netty简要分析(五)

这里介绍的都是有一定netty基础的,如果没有可以从网上找一个netty的入门 涉及到两个方面的操作,一是服务端,二是客户端 大体的类关系如图 根据netty的整理通信,可以大体整理的调用示意图如...

2019/05/29 17:07
556

没有更多内容

加载失败,请刷新页面

返回顶部
顶部