背景 在企業(yè)發(fā)展初期,企業(yè)使用的系統(tǒng)很少,通常一個或者兩個,每個系統(tǒng)都有自己的登錄模塊,運營人員每天用自己的賬號登錄,很方便。 但隨著企業(yè)的發(fā)展,用到的系統(tǒng)隨之增多,運營人員...
背景 在企業(yè)發(fā)展初期,企業(yè)使用的系統(tǒng)很少,通常一個或者兩個,每個系統(tǒng)都有自己的登錄模塊,運營人員每天用自己的賬號登錄,很方便。 但隨著企業(yè)的發(fā)展,用到的系統(tǒng)隨之增多,運營人員...
一、服務注冊與發(fā)現(xiàn) 這里會用到Spring Cloud Netflix,該項目是Spring Cloud的子項目之一,主要內(nèi)容是對Netflix公司一系列開源產(chǎn)品的包裝,它為...
引言 本文希望以另外一種維度的思考方式來學習JVM內(nèi)存模型,希望自己能從設計原理的維度考慮為什么存在?有什么價值?解決什么問題? 在學習JVM內(nèi)存模型之前,先回顧下前面兩章的...
@空擋 謝謝博主 我大概明白了
RocketMQ源碼解析(四)-Consumer消息消費方式 Consumer分為兩種,PullConsumer和PushConsumer。從名字就可以看出一種是拉取的方式,一種是主動Push的方式。具體實現(xiàn)如下: Pul...
終于講到Broker消息處理流程的最后一步了。講Consumer的時候說到消費消息分為Pull和Push兩種模式,底層其實都是依靠Pull實現(xiàn)的。在Broker這端處理Pus...
IndexFile作用 MessageStore中存儲的消息除了通過ConsumeQueue提供給consumer消費之外,還支持通過MessageID或者MessageKe...
ConsumeQueue的作用 上一篇文章講到Broker在收到消息后,通過MessageStore將消息存儲到commitLog中,但是consumer在消費消息的時候是按...
從這篇文章開始,主要看一下Broker處理一條消息的完整過程:接收Producer發(fā)來的消息->存儲消息->將消息推給Consumer。這一篇主要看下接收Producer消息...
博主,您好 。請問RebalanceImpl通過updateProcessQueueTableInRebalance()方法來檢查新加入queue,這里要檢查新加入的queue的作用是什么呢?
RocketMQ源碼解析(四)-Consumer消息消費方式 Consumer分為兩種,PullConsumer和PushConsumer。從名字就可以看出一種是拉取的方式,一種是主動Push的方式。具體實現(xiàn)如下: Pul...
消息消費方式 Consumer分為兩種,PullConsumer和PushConsumer。從名字就可以看出一種是拉取的方式,一種是主動Push的方式。具體實現(xiàn)如下: Pul...
發(fā)送方式 producer發(fā)送消息支持3種方式,同步、異步和Oneway。 同步發(fā)送:客戶端提交消息到broker后會等待返回結果,相對來說是最常用的方式。 異步發(fā)送:調(diào)用發(fā)...
RocketMQ是阿里開源的分布式消息中間件,在阿里云上有它的商業(yè)版本ONS,類似的開源消息中間件還有Kafka, ActiveMQ等。跟其它中間件相比,rocketMQ的特...