9篇文章 · 10582字 · 6人關(guān)注
-
RocketMQ源碼分析----Consumer消費進度相關(guān)在Consumer消費的時候總有幾個疑問： 消費完成后，這個消費進度存在哪里 消費完成后屉凯，還沒保存消費進度就掛了立帖，會不會導(dǎo)致重復(fù)消費 Consu...
-
RocketMQ源碼分析----ProcessQueue
RockerMQ里有個非常重要的數(shù)據(jù)結(jié)構(gòu)叫ProcessQueue，很多功能悠砚，例如消費進度晓勇，消費等等功能的底層核心數(shù)據(jù)保存都是有ProcessQ...
-
RocketMQ源碼分析----Producer隊列選擇與容錯策略
隊列選擇 在HA的文章里大概講了一下Producer如何為高可用貢獻出一份力量的，當(dāng)時只是說了遍歷列表選擇隊列灌旧，然后選擇一個宵蕉，沒有深入分析，這篇...
-
RocketMQ源碼分析----Producer啟動過程
總體流程 首先從demo為入口分析整個啟動過程 DefaultMQProducer構(gòu)造方法如下： 然后調(diào)用start方法后节榜，即開始初始化流程羡玛，其...
-
RocketMQ源碼分析----HA相關(guān)(2)
上一篇文章分析了MS之間的同步，Client端在多Matser多Slave下的情況宗苍，這一篇文章主要從NameServer的角度來分析稼稿，在整個 架...
-
RocketMQ源碼分析----HA相關(guān)(1)簡單介紹 RocketMQ搭建集群無非就是搭建Master和Slave，而根據(jù)Master和Slave的數(shù)量不同又分為幾種方式： 單Master...
-
RocketMQ源碼分析----長輪詢
廢話 這篇文章主要講RocketMQ的長輪詢讳窟，為什么叫長輪詢我也不清楚....主要別人這樣叫我也這樣叫吧让歼，大家明白意思就好。 正文 Rcocke...
-
RocketMQ源碼分析----延時消息和重試消息的實現(xiàn)
延時消息的例子 和普通消息發(fā)送沒多大區(qū)別丽啡，只是多了個句設(shè)置延時級別的代碼 level為3那么代表10s后消費者10s后能拉到這條消息谋右，消費者端的...
-
RocketMQ源碼分析----ConsumeQueue介紹和其構(gòu)建過程
廢話 很久沒寫過看過RocketMQ源碼了，就剛開始用MQ的時候补箍，順便看了下源碼改执，由于當(dāng)時水平較差，寫了幾篇文章坑雅，現(xiàn)在感覺真JB亂....有種想...
