Nacos是阿里巴巴開源的,用于服務(wù)發(fā)現(xiàn)和配置管理的中間件。配置中心已經(jīng)使用Apollo,所以我們只需要使用服務(wù)發(fā)現(xiàn)能力即可。 問題 學(xué)習(xí)研究N...
RocketMQ的定時(shí)消息有2種實(shí)現(xiàn)方式,第一種實(shí)現(xiàn)機(jī)制在[ RocketMQ源碼閱讀 8 ] 延遲消息實(shí)現(xiàn)機(jī)制-非TimeWheel實(shí)現(xiàn)[ht...
Broker的功能點(diǎn)很多,安裝程序啟動(dòng)的順序去看源碼,發(fā)現(xiàn)代碼量比之前的組件要大很多。閱讀過程中發(fā)現(xiàn)Broker會(huì)去持久化一些配置,并且會(huì)將消息...
RocketMQ采用了后臺(tái)定時(shí)任務(wù),定時(shí)輪詢延遲消息隊(duì)列來實(shí)現(xiàn)。 先介紹一下延遲隊(duì)列用到的數(shù)據(jù)結(jié)構(gòu),所有的消息都存儲(chǔ)在名為SCHEDULE_TO...
之前我們進(jìn)行RocketMQ的搭建,其中有一個(gè)參數(shù)是用來配置刷盤方式的。存在“同步”和“異步”兩種方式。 和刷新磁盤邏輯相關(guān)的代碼可以從這里開始...
RocketMQ官方文檔介紹了多種部署方式。我們拋開Local和Cluster集群的差異(Broker和Proxy是否部署在同一個(gè)進(jìn)程),再去分...
該組件的核心就是一個(gè)Raft協(xié)議的實(shí)現(xiàn)。這個(gè)Raft協(xié)議的實(shí)現(xiàn)用的也不是淘寶系的JRaft,而是第三方的產(chǎn)品DLedger。對(duì)于生產(chǎn)要求比較嚴(yán)格...
啟動(dòng)過程 NameServer模塊下的代碼結(jié)構(gòu),項(xiàng)目啟動(dòng)類為NamesrvStartup。啟動(dòng)過程主要做了如下幾件事情。 讀取配置文件和命令行參...
我選擇的源碼版本是5.1.4(源碼地址[https://github.com/apache/rocketmq/tree/release-5.1....