什么是rocketmq RocketMQ 是阿里巴巴開源的消息隊(duì)列中間件。具有下列特點(diǎn)： 能夠保證嚴(yán)格的消息順序 提供豐富的消息拉取模式 高效的...
投稿
收錄了15篇文章 · 23人關(guān)注
-
rocketmq 使用學(xué)習(xí) -
RocketMQ源碼閱讀(六)-消息生產(chǎn)者上文介紹了雙Master模式的就你部署, 本文分析消息生產(chǎn)者發(fā)送消息的過(guò)程. 1.例子 在源碼包的org.apache.rocketmq.exa...
-
RocketMQ源碼閱讀(五)-Linux環(huán)境搭建RocketMQ雙Master模式
前面幾片文章介紹了RocketMQ底層的文件存儲(chǔ)技術(shù), 后續(xù)的文章會(huì)分析RocketMQ的消息發(fā)送和處理. 本文先介紹一下RocketMQ的部署...
-
RocketMQ源碼閱讀(四)-消息存儲(chǔ)三
前文已經(jīng)介紹了消息存儲(chǔ)中使用到的充要對(duì)象, 本文分析一下消息介紹的主流程. 另外, 此篇主要分析消息存儲(chǔ)主流程的代碼, 不影響主流程的代碼先不看...
-
RocketMQ源碼閱讀(四)-消息存儲(chǔ)二
RocketMQ的消息存儲(chǔ)過(guò)程非常復(fù)雜, 本文先介紹存儲(chǔ)模塊中幾個(gè)重要對(duì)象. 1. MappedFile 對(duì)MappedByteBuffer的封...
-
RocketMQ源碼閱讀附一TopicQueue的劃分RocketMQ存儲(chǔ)Topic消息時(shí)會(huì)按照TopicQueue進(jìn)行劃分. 如下圖 首先按照BrokerName劃分到不同的master上(每一個(gè)...
-
RocketMQ源碼閱讀(二)-通信模塊簡(jiǎn)介 在使用了消息隊(duì)列的通信方之間, 總體的通信架構(gòu)圖如下: 在消息生產(chǎn)者, broker和消息消費(fèi)者之間都會(huì)發(fā)生通信, RocketMQ的通信...
-
RocketMQ源碼閱讀(四)-消息存儲(chǔ)前言 接下來(lái)會(huì)介紹RocketMQ的消息存儲(chǔ), 本文先對(duì)RocketMQ的整體設(shè)計(jì)和組件進(jìn)行簡(jiǎn)單介紹,后續(xù)會(huì)針對(duì)細(xì)節(jié)進(jìn)行源代碼的分析. 目前MQ...
-
RocketMQ源碼閱讀(三)-NameServer
概述 如RocketMQ源碼閱讀(二)中所述, RocketMQ的總體架構(gòu)如下: RocketMQ將注冊(cè)中心單獨(dú)提取出來(lái)封裝成了一個(gè)可以單獨(dú)部署...
-
RocketMQ源碼閱讀(一)-調(diào)試環(huán)境搭建最近想深入學(xué)習(xí)一下消息隊(duì)列, 本來(lái)想看kafka的源碼, 但由于kafka是scala寫的,本人又不懂kafaka,最終選擇了阿里的Rocket...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/560451/174037biyowmz9zorr3mix.jpg', '推薦專題《RocketMQ》（ 分享自 @簡(jiǎn)書 ）','http://www.itdecent.cn/c/1603a79f398e?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁(yè)面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}