背景 在企業(yè)發(fā)展初期,企業(yè)使用的系統(tǒng)很少,通常一個(gè)或者兩個(gè),每個(gè)系統(tǒng)都有自己的登錄模塊,運(yùn)營(yíng)人員每天用自己的賬號(hào)登錄,很方便。 但隨著企業(yè)的發(fā)展,用到的系統(tǒng)隨之增多,運(yùn)營(yíng)人員...
背景 在企業(yè)發(fā)展初期,企業(yè)使用的系統(tǒng)很少,通常一個(gè)或者兩個(gè),每個(gè)系統(tǒng)都有自己的登錄模塊,運(yùn)營(yíng)人員每天用自己的賬號(hào)登錄,很方便。 但隨著企業(yè)的發(fā)展,用到的系統(tǒng)隨之增多,運(yùn)營(yíng)人員...
一、服務(wù)注冊(cè)與發(fā)現(xiàn) 這里會(huì)用到Spring Cloud Netflix,該項(xiàng)目是Spring Cloud的子項(xiàng)目之一,主要內(nèi)容是對(duì)Netflix公司一系列開(kāi)源產(chǎn)品的包裝,它為...
引言 本文希望以另外一種維度的思考方式來(lái)學(xué)習(xí)JVM內(nèi)存模型,希望自己能從設(shè)計(jì)原理的維度考慮為什么存在?有什么價(jià)值?解決什么問(wèn)題? 在學(xué)習(xí)JVM內(nèi)存模型之前,先回顧下前面兩章的...
終于講到Broker消息處理流程的最后一步了。講Consumer的時(shí)候說(shuō)到消費(fèi)消息分為Pull和Push兩種模式,底層其實(shí)都是依靠Pull實(shí)現(xiàn)的。在Broker這端處理Pus...
IndexFile作用 MessageStore中存儲(chǔ)的消息除了通過(guò)ConsumeQueue提供給consumer消費(fèi)之外,還支持通過(guò)MessageID或者M(jìn)essageKe...
ConsumeQueue的作用 上一篇文章講到Broker在收到消息后,通過(guò)MessageStore將消息存儲(chǔ)到commitLog中,但是consumer在消費(fèi)消息的時(shí)候是按...
從這篇文章開(kāi)始,主要看一下Broker處理一條消息的完整過(guò)程:接收Producer發(fā)來(lái)的消息->存儲(chǔ)消息->將消息推給Consumer。這一篇主要看下接收Producer消息...
消息消費(fèi)方式 Consumer分為兩種,PullConsumer和PushConsumer。從名字就可以看出一種是拉取的方式,一種是主動(dòng)Push的方式。具體實(shí)現(xiàn)如下: Pul...