没有合适的资源?快使用搜索试试~ 我知道了~
首页RocketMQ_UML图示说明
资源详情
资源评论
资源推荐
DefaultMQProducer
MQProducer
ClientConfig MixAll
«uses»
DefaultMQProducerImpl
1 1
MQProducerInner
MQClientFactory
1 1
TransactionMQProducer
MQClientManager
«uses»
TopicPublishInfo
«uses»
TopicPublishInfo
-topicPublishInfoTable1
*
1
1
MQClientAPIImpl
1 1
NettyRemotingClient
TopAddressing
1
1
1
1
ClientRemotingProcessor
1
1
NettyRequestProcessor
RemotingClient
NettyRemotingAbstract NettyEventExecuter
ServiceThread
Runnable
11
Thread
1 1
The run() will be executed
in Thread.
It uses channel event
listener in enclosing class
It encapsulates method to start,
stop and interrupt a thread
ClientHousekeepingService
ChannelEventListener
1
1
ScheduledExecutorService
1 1
BrokerController
1
1
ConsumerManager
ProducerManager
1 1
1
1
ConsumerGroupInfo
1 *
PullMessageService
RebalanceService
11
DatagramSocket
1
1
1
1
1
1
PullRequest
1 *
ChannelWrapper
NettyClientHandler
NettyConnetManageHandler
1
1
1
1
Bootstrap
1
1
MessageQueue
1
*
ChannelDuplexHandler
SimpleChannelInboundHandler
1
*
ResponseFuture
1*
NettyEncoder
<<uses>>
MessageToByteEncoder
NettyDecoder
LengthFieldBasedFrameDecoder
<<uses>>
TransactionCheckListenerImpl
1
1
TransactionCheckListener
Encapsulate API to talk
to Server
DefaultMQPullConsumerImpl
MQConsumerInner
DefaultMQPullConsumer
1 1
AllocateMessageQueueAveragely
AllocateMessageQueueStrategy
1
1
«interface»
MessageQueueListener
1
1
MQClientManager
«uses»
MQClientFactory
«uses»
1 *
1
1
RebalancePullImpl
1
1
LocalFileOffsetStore RemoteBrokerOffsetStore
«interface»
Interface2
1
1
PullMessageService
1 1
A handler running in
a thread to take request
from its pullRequestQueue
PullRequest
1 *
RebalanceService
1
1
DefaultMQProducer
1
1
MQAdminImpl
1
1
PullAPIWrapper
1
1
DefaultMQPushConsumerImpl
MQConsumerInner
RebalancePushImpl
1 1
1
1
1
1
«interface»
« interface »
ConsumeMessageService
ConsumeMessageConcurrentlyService
ConsumeMessageOrderlyService
1
1
RebalanceImpl
SendMessageProcessor
NettyRequestProcessor
SocketAddress
-storeHost1
1
BrokerController
RemotingServer
1
1
NettyRemotingAbstract
NettyRemotingServer
NettyServerHandler
NettyConnetManageHandler
1
1
1
1
ExecutorService
1
*
ThreadPoolExecutor
DefaultMessageStore
MessageStore
1
1
AllocateMapedFileService
ServiceThread
1
1
MapedFile
1
1
AllocateRequest
1 *
CleanCommitLogService
CleanConsumeQueueService
DispatchMessageService
IndexService
ReputMessageService
HAService AcceptSocketService
ScheduleMessageService
TransactionStateService
StoreStatsService
1 1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
1
FlushConsumeQueueService
1
1
PullRequestHoldService
1
1
ClientHousekeepingService
1
1
DigestLogManager
1
1
SimpleChannelInboundHandler
NettyEncoder
«uses»
MessageToByteEncoder
NettyDecoder
LengthFieldBasedFrameDecoder
«uses»
1
1
CommitLog
1
1
MapedFileQueue
1 1
ConsumeQueue
1
*
-tranRedoLog
1
1
-tranStateTable1
1
1
1
1
1
MapedFile
1
*
ReferenceResource
MappedByteBuffer
1 1
DirectByteBuffer
ConfigManager
MessageStoreConfig
1
1
StoreCheckpoint
1
1
IndexFile
1
1
IndexHeader
1
1
Total file size
IndexHeader.INDEX_HEADER_SIZE
+ (hashSlotNum * HASH_SLOT_SIZE)
+ (indexNum * INDEX_SIZE)
1 *
GroupCommitService
1
1
FlushCommitLogService
GroupTransferService
HAClient
1
1
1
1
HAConnection
«uses»
WriteSocketService
ReadSocketService
1 1
1
1
Read request from slave
Write data to slave
Guarantee message sender blocked
until its msg is synced to slave.
Sender waits on a countdown latch,
it does the count down.
ConcurrentHashMap<String/* topic */, ConcurrentHashMap<Integer/* queueId */, ConsumeQueue>>
SlaveSynchronize
1
1
SubscriptionGroupManager
1
1
TopicConfigManager
1
1
DefaultMQPushConsumer
subscribe
DefaultMQPushConsumerImpl
subscribe
FilterAPI
buildSubscriptionData
Save (topic, subscriptionData)
to RelalancePushImpl
start
start
checkConfig
copySubscription
Save (retryTopic, subscriptionData)
to RelalancePushImpl
MQClientManager
getAndCreateMQClientFactory
PullAPIWrapper
new
RemoteBrokerOffsetStore
new
MQClientFactory
registerConsumer
start
updateTopicSubscribeInfoWhenSubscriptionChanged
updateTopicRouteInfoFromNameServer
sendHeartbeatToAllBrokerWithLock
rebalanceImmediately
ConsumeMessageConcurrentlyServ
ice
new
start
PullMessageService
RebalanceService
CleanConsumeQueueService
IndexService
FlushConsumeQueueService
FlushRealTimeService
GroupCommitRequest
StoreStatsService
ScheduleMessageService.persist
ReputMessageService
TransactionStateService
AcceptSocketService
GroupTransferService
HAClient
NettyEncoder
NettyDecoder
IdleStateHandler
NettyConnetManageHandler
NettyServerHandler
NettyEncoder
NettyDecoder
IdleStateHandler
NettyConnetManageHandler
NettyClientHandler
PullRequestHoldService
ClientHousekeepingService.scanExceptionChannel
ReadSocketService WriteSocketService
AllocateMapedFileService
DispatchMessageService
Broker
NameServer
DefaultRequestProcessor
NettyRemotingServer.scanResponseTable
NettyEventExecuter
NettyEncoder
NettyDecoder
IdleStateHandler
NettyConnetManageHandler
NettyServerHandler
NameServer
DefaultMQPushConsumer
PullMessageService
NettyEncoder
NettyDecoder
IdleStateHandler
NettyConnetManageHandler
NettyClientHandler
MQClientAPIImpl.fetchNameServerAddr
MQClientFactory.updateTopicRouteInfoFromNameServer
MQClientFactory.cleanOfflineBroker
MQClientFactory.sendHeartbeatToAllBrokerWithLock
MQClientFactory.persistAllConsumerOffset
MQClientFactory.recordSnapshotPeriodically
MQClientFactory.logStatsPeriodically
RebalanceService
NettyEncoder
NettyDecoder
IdleStateHandler
NettyConnetManageHandler
NettyServerHandler
ConsumeRequest
剩余25页未读,继续阅读
qq_31108369
- 粉丝: 0
- 资源: 3
上传资源 快速赚钱
- 我的内容管理 收起
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
会员权益专享
最新资源
- 2023年中国辣条食品行业创新及消费需求洞察报告.pptx
- 2023年半导体行业20强品牌.pptx
- 2023年全球电力行业评论.pptx
- 2023年全球网络安全现状-劳动力资源和网络运营的全球发展新态势.pptx
- 毕业设计-基于单片机的液体密度检测系统设计.doc
- 家用清扫机器人设计.doc
- 基于VB+数据库SQL的教师信息管理系统设计与实现 计算机专业设计范文模板参考资料.pdf
- 官塘驿林场林防火(资源监管)“空天地人”四位一体监测系统方案.doc
- 基于专利语义表征的技术预见方法及其应用.docx
- 浅谈电子商务的现状及发展趋势学习总结.doc
- 基于单片机的智能仓库温湿度控制系统 (2).pdf
- 基于SSM框架知识产权管理系统 (2).pdf
- 9年终工作总结新年计划PPT模板.pptx
- Hytera海能达CH04L01 说明书.pdf
- 数据中心运维操作标准及流程.pdf
- 报告模板 -成本分析与报告培训之三.pptx
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论1