Reactor模型 Netty中的Reactor模型主要由多路復(fù)用器(Acceptor)、事件分發(fā)器(Dispatcher)、事件處理器(Han...
投稿
收錄了88篇文章 · 199人關(guān)注
-
Netty 線程模型 -
Netty 之 ChannelOutboundBuffer 源碼分析
每個 ChannelSocket 的 Unsafe 都有一個綁定的 ChannelOutboundBuffer ， Netty 向站外輸出數(shù)據(jù)的...
-
Netty 之 AbstractNioByteChannel 源碼分析
Netty 版本：4.1.33.Final-SNAPSHOT AbstractNioByteChannel 1、該類定義了一個 flushTas...
-
Netty 之 AbstractChannel 和 AbstractNioChannel 源碼分析概述 channel 是 netty 網(wǎng)絡(luò) IO 操作抽象出來的一個接口，主要功能有：網(wǎng)絡(luò)IO的讀寫，客戶端發(fā)起連接、主動關(guān)閉連接，鏈路關(guān)閉，獲...
-
Netty 之 ByteBuf 分析
概述 Netty 中的 ByteBuf 和 NIO 中的 ByteBuffer 的區(qū)別。 1、Netty 中的 ByteBuf 支持動態(tài)的擴容和...
-
RocketMQ 同步刷盤實現(xiàn)原理
未寫完，待續(xù)。。。。 刷盤服務(wù)類有三種 同步刷盤時使用 GroupCommitService 異步刷盤時使用 FlushRealTimeServ...
-
RocketMQ MappedFile 預(yù)熱原理解析
創(chuàng)建 MappedFile 文件 創(chuàng)建 MappedFile 文件實現(xiàn)如下： 從代碼中可以看出，只有 MappedFile 的大小等于或大于 C...
-
RocketMQ 延遲消息
概述 RocketMQ 支持發(fā)送延遲消息，但不支持任意時間的延遲消息的設(shè)置，僅支持內(nèi)置預(yù)設(shè)值的延遲時間間隔的延遲消息。 預(yù)設(shè)值的延遲時間間隔為：...
-
RocketMQ CommitLog 文件規(guī)則1、CommitLog 文件生成規(guī)則 偏移量：每個 CommitLog 文件的大小為 1G，一般情況下第一個 CommitLog 的起始偏移量為...
-
RocketMQ 存儲機制源碼解析
producer 發(fā)送消息后，broker端開始存儲消息，會調(diào)用 store 模塊的 DefaultMessageStore.putMessag...
{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/492020/201505210101.jpg', '推薦專題《java 成神之路》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/69d13d14190f?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}