• Consumer

  消息接收者。如：收信者

  Consumer 與 NameServer 集群中的其中一個節(jié)點（隨機選擇）建立長連接，定期從 NameServer 獲取 Topic 路由信息，并向提供 Topic 服務(wù)的 Master、Slave 建立長連接，且定時向 Master、Slave 發(fā)送心跳。

  Consumer 既可以從 Master 訂閱消息，也可以從 Slave 訂閱消息，消費者在向 Master 拉取消息時，Master 服務(wù)器會根據(jù)拉取偏移量與最大偏移量的距離（判斷是否讀老消息，產(chǎn)生讀I/O）,以及從服務(wù)器是否可讀等因素建議下一次是從 Master 還是 Slave 拉取。

執(zhí)行流程：