四、RocketMQ消息消費總覽

1.消費者啓動 2.消息消費總覽 1.線程ReblanceService： 1.作用： a.Rebalanceservice線程每隔20s對消費者訂閱的主題進行一次隊列重新分配，每一次分配都會獲取主題的所有隊列、從 Broker 服務器實時查詢當前該主題該消費組內消費者列表，對新分配的消息隊列會創建對應的 PullRequest 對象。在一個 JVM 進程中，同一個消費組同一個隊列只會存在一個 P

>>阅读原文<<