02-实例化BrokerController
2024-12-09 10:03:15 0 举报实例化BrokerController
作者其他创作
大纲/内容
初始化 主题队列映射 管理器
初始化 拉取 线程池队列，用于管理拉取消息任务的队列
根据是否启用启用RocksDB存储初始化下面的3个对象
初始化消费者顺序信息管理器
初始化 发送 线程池队列，用于管理发送消息任务的队列
初始化广播偏移量管理器
启动客户端维护服务，负责客户端的定期清理和维护工作
TopicConfigManager初始化 主题配置 管理器
ConsumerOffsetManager初始化 消费者偏移量 管理器
BrokerMemberGroup
初始化BrokerMemberGroup实例，用于管理Broker集群中的成员信息
ColdDataPullRequestHoldService
litePullThreadPoolQueue
检查是否需要从旧版本迁移认证配置
初始化 轻量级拉取 线程池队列，用于管理轻量级拉取消息任务的队列
AckMessageProcessor
SendMessageProcessor
初始化 负载均衡 线程池队列，用于处理负载均衡相关任务
初始化转义桥接对象，用于处理消息的转义逻辑
DefaultConsumerIdsChangeListener
初始化 回复 线程池队列，用于处理回复消息任务
AuthMigrator
初始化事务结束处理器，负责处理事务的结束逻辑
创建冷数据拉取请求保持服务，用于管理冷数据拉取请求
adminBrokerThreadPoolQueue
初始化消费者过滤管理器
Broker统计管理器
初始化 心跳 线程池队列，用于处理心跳检测任务
初始化 消费者管理 线程池队列，用于处理消费者管理任务
replyThreadPoolQueue
SubscriptionGroupManager初始化 订阅组 管理器
AuthorizationMetadataManager
ScheduleMessageService
loadBalanceThreadPoolQueue
ConsumerManager
Broker2Client
BrokerStatsManager
ClientHousekeepingService
初始化 查询 线程池队列，用于处理查询消息任务
启动冷数据消费组控制服务，用于管理和控制冷数据的消费组
初始化 消息到达 监听器，用于监听消息到达的事件
PopInflightMessageCounter
ChangeInvisibleTimeProcessor
初始化客户端管理处理器，负责管理客户端的连接和通信
this.brokerStatsManager.setProducerStateGetter(...)
初始化预上线服务
EscapeBridge
初始化Broker快速故障切换机制
PopMessageProcessor
初始化 放置 线程池队列，用于管理放置消息任务的队列
初始化 消费者ID变更 监听器，用于监听消费者ID列表的变化
BrokerPreOnlineService
queryThreadPoolQueue
ProducerManager
endTransactionThreadPoolQueue
初始化认证元数据 管理器
ConsumerOrderInfoManager
pullThreadPoolQueue
初始化 轮询信息 处理器
QueryAssignmentProcessor
初始化从库同步器，负责与主库进行数据同步
建立与Broker的连接，负责客户端与Broker之间的通信
BrokerFastFailure
PullMessageProcessor
SlaveSynchronize
设置生产者状态获取器，以动态获取生产者在线状态
初始化定时消息服务，用于处理和管理定时消息的发送
EndTransactionProcessor
this.brokerStatsManager.setConsumerStateGetter(...)
clientManagerThreadPoolQueue
BroadcastOffsetManager
NotifyMessageArrivingListener
ackThreadPoolQueue
初始化拉取请求保持服务
结束
初始化 通知 处理器
初始化 ACK 线程池队列，用于处理确认消息任务
初始化消费者管理器
初始化与Broker的外部API通信对象
consumerManagerThreadPoolQueue
初始化 拉取消息 处理器，用于处理客户端的拉取消息请求
初始化 确认消息 处理器
初始化主题路由信息管理器，负责管理主题的路由信息
NotificationProcessor
ClientManageProcessor
初始化授权元数据 管理器
初始化 更改消息不可见时间 处理器
初始化 事务结束 线程池队列，用于处理事务结束相关任务
new BrokerController(...)
初始化生产者管理器
ReplyMessageProcessor
初始化 预览消息 处理器，用于处理消息预览相关操作
TopicRouteInfoManager
PollingInfoProcessor
初始化消息计数器，用于跟踪和管理客户端接收到的未确认消息的数量
初始化查询分配处理器，负责处理查询请求的分配
初始化 消息回复 处理器
BrokerOuterAPI
初始化 管理员Broker 线程池队列，用于处理管理员Broker相关任务
PeekMessageProcessor
初始化 客户端管理 线程池队列，用于处理客户端管理任务
ColdDataCgCtrService
PullRequestHoldService
AuthenticationMetadataManager
putThreadPoolQueue
heartbeatThreadPoolQueue
sendThreadPoolQueue
初始化 消息发送 处理器
ConsumerFilterManager
初始化 弹出消息 处理器
设置消费者状态获取器，用于获取消费者的在线状态
0 条评论
下一页
