kafka生產(chǎn)者線程負責生產(chǎn)消息，而將消息發(fā)送給broker是有一個專門的發(fā)送者線程來處理的，也稱之為IO Thread，實現(xiàn)了消息的生產(chǎn)與發(fā)送解耦，提高吞吐量。 IO Th...
發(fā)簡信
IP屬地：福建
-
kafka發(fā)送者線程一
-
kafka消息累加器作用
程序中調(diào)用kafka生產(chǎn)者發(fā)送消息，并不是每調(diào)用一次send方法，就直接將消息通過底層網(wǎng)絡(luò)發(fā)送給broker了，而是會將多個消息形成一個批次，然后再以批次的形式，發(fā)送給bro...
-
kafka分區(qū)器原理
在kafka中，生產(chǎn)者發(fā)送的消息最終會落在主題下的某個分區(qū)，但是很多開發(fā)者在使用的過程中其實并沒有指定消息發(fā)往哪個分區(qū)，那么kafka是如何處理的呢？ 在kafka中，消息主...
-
netty之write和flush
在netty開發(fā)中，當調(diào)用pipeline的write方法時，并不會將數(shù)據(jù)直接寫入到底層channel通道發(fā)送出去，而是先添加到緩沖區(qū)中；只有當調(diào)用flush方法，才會真正將...
-
netty的編解碼器
編解碼器指的是轉(zhuǎn)換兩種不同格式的數(shù)據(jù)，在網(wǎng)絡(luò)編程中幾乎是必不可少的。比如將String轉(zhuǎn)成ByteBuf，將Student轉(zhuǎn)成String等等。 netty中，編碼器處理的是...
-
netty如何處理拆包與粘包
拆包與粘包是網(wǎng)絡(luò)編程中必會出現(xiàn)的一個問題。因此，本文先介紹下什么是拆包與粘包，然后通過例子演示這個現(xiàn)象，最后再介紹netty中如何處理拆包與粘包 所謂的拆包就是發(fā)送方發(fā)送一條...
-
netty之ByteBuf引用計數(shù)使用
在netty中，ByteBuf是對字節(jié)的封裝，對nio的ByteBuffer的增強，用于從socket緩沖區(qū)讀取和寫入數(shù)據(jù)的。 ByteBuf有基于堆內(nèi)存和直接內(nèi)存的，若是堆...
-
netty之NioEventLoop事件循環(huán)處理
NioEventLoop的事件循環(huán)處理，就是在一個死循環(huán)中處理IO事件和隊列里的任務(wù)，并且可以根據(jù)策略來平衡這兩者之間的執(zhí)行比例。 首先，先來看下selectStrategy...
-
netty注冊流程分析二
上一篇中netty注冊流程分析一[http://www.itdecent.cn/p/0743e40dee69]，分析到了channel注冊到nioEventLoop中了，接...
-
netty中channel、pipeline、handler方法調(diào)用關(guān)系
在之前的這篇文章有講述三者的關(guān)系[http://www.itdecent.cn/p/84b0456f4f83]，本文主要講解下三者的一些重要方法及方法的調(diào)用關(guān)系 先看下Ch...
-
netty自適應緩沖區(qū)實現(xiàn)
netty的自適應緩沖區(qū)用于接收從channel讀取的數(shù)據(jù)，且可以動態(tài)調(diào)整緩沖區(qū)大小，減少內(nèi)存的浪費。當連續(xù)兩次讀取的字節(jié)數(shù)小于當前緩沖區(qū)大小時，就會縮小，當讀取的字節(jié)數(shù)剛好...
-
springmvc源碼分析-HandlerMapping初始化流程
從本文開始，來分析下springmvc幾個重要組件是如何工作的。 首選，來看下HandlerMapping 這個接口主要有這個方法，通過request獲取一個HandlerE...
-
springmvc源碼解析-核心組件賦值方式
在之前的文章說過，springmvc在要初始化spring容器時，會提前注冊一個監(jiān)聽器，當spring容器完成刷新后，此監(jiān)聽器的回調(diào)方法會收到回調(diào)通知，會執(zhí)行如下方法 這個方...
-
springmvc源碼分析-容器初始化
在前文知道了，DispatcherServlet的init方法是springmvc項目初始化的入口，init方法內(nèi)部又調(diào)用了initServletBean configure...
-
springmvc源碼分析-初始化DispatcherServlet
springmvc的啟動流程分析一 在servlet3.0以前，啟動一個springmvc項目，需要在classpath目錄下web-inf目錄新建一個web.xml文件，然...
-
springmvc源碼分析-handlerExceptionResolver原理
異常解析器也是springmvc的一個非常重要組件，在編寫程序代碼時，若拋出異常了，那么springmvc是通過異常解析器來獲取異常并進行后續(xù)的處理 看下接口定義的方法 入?yún)?..
-
會發(fā)送，有時間閾值和空間閾值，滿足其中一個就會發(fā)送
springmvc源碼分析-HandlerMapping工作流程
之前的一篇HandlerMapping初始化流程[http://www.itdecent.cn/p/b43fe22546ab]，講述了HandlerMapping的初始化流...
-
springmvc源碼分析-HandlerAdapter原理
springmvc中HandlerAdapter用于執(zhí)行具體的Handler，也就是controller，是springmvc中一個特別重要的組件，先來看下接口定義的方法 方...
-
springmvc源碼分析-HandlerMapping工作流程
之前的一篇HandlerMapping初始化流程[http://www.itdecent.cn/p/b43fe22546ab]，講述了HandlerMapping的初始化流...
-
spring的factoryBean原理
spring容器管理的bean中，有一種比較特殊的類型FactoryBean，這種類型的bean，自身即是一個bean對象，也能產(chǎn)生其他類型的bean對象，通過接口方法便可得...