写点什么

RocketMQ- 学习记录

用户头像
闲云野鹤
关注
发布于: 3 小时前
RocketMQ-学习记录

远程调用服务接口:

RemotingService
复制代码

 

其中分客户端和服务端两种实现:

NettyRemotingClientNettyRemotingServer
复制代码

 

基于 netty 的 SimpleChannelInboundHandler 做了实现:

NettyServerHandler--》NettyRequestProcessorNettyClientHandler--》NettyRequestProcessor
复制代码

 

核心处理入口(processer):

NettyRequestProcessor
复制代码

 

processer 定义了具体的处理方法

 

Broker--》BrokerControllerNameSrv--》NamesrvController
复制代码

 

消息存储

核心类:

MessageStore--》DefaultMessageStore--》CommitLog
复制代码

CommitLog 有默认实现和基于 Dledger 的实现,Dledger 自身实现了 Raft 协议:

默认实现基于 java nio,具体类为:MappedFile

 

DLedgerCommitLog--》DLedgerServerCommitLog--》MappedFile
复制代码

 

用户头像

闲云野鹤

关注

州亦难添诗亦难改,然闲云孤鹤,何天而不可飞 2017.01.02 加入

还未添加个人简介

评论

发布
暂无评论
RocketMQ-学习记录