## Consumer 消息消費的角色，支持分布式集群方式部署。支持以push推，pull拉兩種模式對消息進行消費。同時也支持集群方式和廣播方式的消費，它提供實時消息訂閱機制，可以滿足大多數用戶的需求 Consumer與Name Server集群中的其中一個節點(隨機選擇)建立長連接，定期從Name Server取Topic路由信息，并向提供Topic服務的Master、Slave建立長連接，且定時向Master、Slave發送心跳。Consumer既可以從Master訂閱消息，也可以從Slave訂閱消息，訂閱規則由Broker配置決定。 Consumer每隔30s從Name server獲取topic的最新隊列情況，這意味著Broker不可用時，Consumer最多最需要30s才能感知。 Consumer每隔30s（由ClientConfig中heartbeatBrokerInterval決定）向所有關聯的broker發送心跳，Broker每隔10s掃描所有存活的連接，若某個連接2分鐘內沒有發送心跳數據，則關閉連接；并向該Consumer Group的所有Consumer發出通知，Group內的Consumer重新分配隊列，然后繼續消費。 當Consumer得到master宕機通知后，轉向slave消費，slave不能保證master的消息100%都同步過來了，因此會有少量的消息丟失。但是一旦master恢復，未同步過去的消息會被最終消費掉。 消費者對列是消費者連接之后（或者之前有連接過）才創建的。我們將原生的消費者標識由 {IP}@{消費者group}擴展為 {IP}@{消費者group}{topic}{tag}，（例如[xxx.xxx.xxx.xxx@mqtest\_producer-group\_2m2sTest\_tag-zyk](http://xxx.xxx.xxx.xxx@mqtest_producer-group_2m2sTest_tag-zyk)）。任何一個元素不同，都認為是不同的消費端，每個消費端會擁有一份自己消費隊列（默認是broker對列數量\*broker數量）。新掛載的消費者隊列中擁有commitlog中的所有數據