kafka生產(chǎn)者線程負(fù)責(zé)生產(chǎn)消息，而將消息發(fā)送給broker是有一個專門的發(fā)送者線程來處理的，也稱之為IO Thread蕾额，實現(xiàn)了消息的生產(chǎn)與發(fā)送...

程序中調(diào)用kafka生產(chǎn)者發(fā)送消息，并不是每調(diào)用一次send方法，就直接將消息通過底層網(wǎng)絡(luò)發(fā)送給broker了谍珊，而是會將多個消息形成一個批次，然...

在kafka中急侥，生產(chǎn)者發(fā)送的消息最終會落在主題下的某個分區(qū)砌滞，但是很多開發(fā)者在使用的過程中其實并沒有指定消息發(fā)往哪個分區(qū)，那么kafka是如何處理...

在netty開發(fā)中坏怪，當(dāng)調(diào)用pipeline的write方法時贝润，并不會將數(shù)據(jù)直接寫入到底層channel通道發(fā)送出去，而是先添加到緩沖區(qū)中铝宵；只有當(dāng)...

編解碼器指的是轉(zhuǎn)換兩種不同格式的數(shù)據(jù)题暖，在網(wǎng)絡(luò)編程中幾乎是必不可少的。比如將String轉(zhuǎn)成ByteBuf捉超，將Student轉(zhuǎn)成String等等胧卤。...

拆包與粘包是網(wǎng)絡(luò)編程中必會出現(xiàn)的一個問題。因此拼岳，本文先介紹下什么是拆包與粘包枝誊，然后通過例子演示這個現(xiàn)象，最后再介紹netty中如何處理拆包與粘包...

在netty中惜纸，ByteBuf是對字節(jié)的封裝叶撒，對nio的ByteBuffer的增強，用于從socket緩沖區(qū)讀取和寫入數(shù)據(jù)的耐版。 ByteBuf有...

NioEventLoop的事件循環(huán)處理祠够，就是在一個死循環(huán)中處理IO事件和隊列里的任務(wù)，并且可以根據(jù)策略來平衡這兩者之間的執(zhí)行比例粪牲。 首先古瓤，先來看...

上一篇中netty注冊流程分析一[http://www.reibang.com/p/0743e40dee69]，分析到了channel注冊到n...