RocketMQ- 学习记录
远程调用服务接口:
复制代码
其中分客户端和服务端两种实现:
复制代码
基于 netty 的 SimpleChannelInboundHandler 做了实现:
复制代码
核心处理入口(processer):
复制代码
processer 定义了具体的处理方法
复制代码
消息存储
核心类:
复制代码
CommitLog 有默认实现和基于 Dledger 的实现,Dledger 自身实现了 Raft 协议:
默认实现基于 java nio,具体类为:MappedFile
复制代码
评论