13篇文章 · 19901字 · 23人關(guān)注
-
RocketMQ源碼解析(十三)-事務(wù)消息什么是事務(wù)消息 首先我們用一個(gè)場(chǎng)景來(lái)講一下事務(wù)消息解決的問題。分布式消息隊(duì)列多用來(lái)解決多個(gè)微服務(wù)之間的調(diào)用解耦拳魁，不會(huì)因?yàn)閱蝹€(gè)服務(wù)的服務(wù)質(zhì)量問題而...
-
RocketMQ源碼解析(十二)-順序消息
什么是順序消息 順序消息是RocketMQ相對(duì)于其它分布式消息隊(duì)列方案一個(gè)很有特色的特性。所謂順序就是consumer端用戶Listener收到...
-
RocketMQ源碼解析(十一)-Broker#消息消費(fèi)
終于講到Broker消息處理流程的最后一步了。講Consumer的時(shí)候說到消費(fèi)消息分為Pull和Push兩種模式，底層其實(shí)都是依靠Pull實(shí)現(xiàn)的...
-
RocketMQ源碼解析(十)-Broker#消息存儲(chǔ)IndexIndexFile作用 MessageStore中存儲(chǔ)的消息除了通過ConsumeQueue提供給consumer消費(fèi)之外辙售，還支持通過Messa...
-
RocketMQ源碼解析(九)-Broker#消息存儲(chǔ)ConsumeQueueConsumeQueue的作用 上一篇文章講到Broker在收到消息后，通過MessageStore將消息存儲(chǔ)到commitLog中倘要，但是con...
-
RocketMQ源碼解析(八)-Broker#消息發(fā)送
從這篇文章開始圾亏，主要看一下Broker處理一條消息的完整過程：接收Producer發(fā)來(lái)的消息->存儲(chǔ)消息->將消息推給Consumer。這一篇主...
-
RocketMQ源碼解析(七)-Topic創(chuàng)建
用了前面幾篇文章封拧，終于把RocketMQ的各個(gè)組件介紹完了∝参剩可以看到一條消息整個(gè)流轉(zhuǎn)過程都是要有一個(gè)topic的泽西，一般日常業(yè)務(wù)使用過程中，都是使...
-
RocketMQ源碼解析(六)-Broker#MessageStoreBroker將消息存儲(chǔ)抽象成MessageStore接口缰趋，默認(rèn)實(shí)現(xiàn)類是DefaultMessageStore捧杉。主要提供如下方法： 保存消息，包括...
-
RocketMQ源碼解析(五)-Broker架構(gòu)及服務(wù)啟動(dòng)之前幾篇文章講了Producer如何發(fā)送消息秘血，Consumer如何收消息味抖。后面會(huì)用更多的幾篇來(lái)講Broker，其實(shí)也就是消息隊(duì)列的核心-分布式Q...
