kafka生產者線程負責生產消息砌梆，而將消息發(fā)送給broker是有一個專門的發(fā)送者線程來處理的蛙粘，也稱之為IO Thread艰猬，實現了消息的生產與發(fā)送...

程序中調用kafka生產者發(fā)送消息聪富，并不是每調用一次send方法愕宋，就直接將消息通過底層網絡發(fā)送給broker了玻靡，而是會將多個消息形成一個批次，然...

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

在netty開發(fā)中邻寿，當調用pipeline的write方法時蝎土，并不會將數據直接寫入到底層channel通道發(fā)送出去，而是先添加到緩沖區(qū)中绣否；只有當...

編解碼器指的是轉換兩種不同格式的數據誊涯，在網絡編程中幾乎是必不可少的。比如將String轉成ByteBuf蒜撮，將Student轉成String等等暴构。...

拆包與粘包是網絡編程中必會出現的一個問題。因此段磨，本文先介紹下什么是拆包與粘包取逾，然后通過例子演示這個現象，最后再介紹netty中如何處理拆包與粘包...

在netty中苹支，ByteBuf是對字節(jié)的封裝菌赖，對nio的ByteBuffer的增強，用于從socket緩沖區(qū)讀取和寫入數據的沐序。 ByteBuf有...

NioEventLoop的事件循環(huán)處理琉用，就是在一個死循環(huán)中處理IO事件和隊列里的任務堕绩，并且可以根據策略來平衡這兩者之間的執(zhí)行比例。 首先邑时，先來看...

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