NSQ源碼分析(五)——Channel

 Channel相關的代碼主要位於nsqd/channel.go, nsqd/nsqd.go中。 Channel是消費者訂閱特定Topic的一種抽象。對於發往Topic的消息,nsqd向該Topic下的所有Channel投遞消息,而同一個Channel只投遞一次,Channel下如果存在多個消費者,則隨機選擇一個消費者做投遞。這種投遞方式可以被用作消費者負載均衡。Channel會將消息進行排列,如
相關文章
相關標籤/搜索