先從整體上看一下Netty的構(gòu)成。
核心組件
Bootstrap&ServerBootstrap
netty程序的啟動(dòng)器,負(fù)責(zé)配置netty程序,把各個(gè)組件組合起來。通過客戶端使用Bootstrap進(jìn)行connect,服務(wù)器端使用ServerBootstrap進(jìn)行bind。
EventLoop&EventLoopGroup
一個(gè)EventLoop其實(shí)就是一個(gè)線程,處理 Channel的IO操作.一個(gè)Channel的IO操作由一個(gè)EventLoop負(fù)責(zé),但不是每個(gè)Channel都會(huì)有特定的EventLoop,而是由EventLoopGroup統(tǒng)一分配和回收。因此在EventLoop里面,萬萬不能阻塞。
通常ServerBootstrap會(huì)使用兩個(gè)EventLoopGroup,一個(gè)用于接受客戶端連接;另一個(gè)用于處理客戶端的數(shù)據(jù)。
Handler
netty程序真正業(yè)務(wù)邏輯所在,Handler主要用來處理各種事件,這里的事件很廣泛,比如可以是連接、數(shù)據(jù)接收、異常、數(shù)據(jù)轉(zhuǎn)換等。其執(zhí)行線程正是從EventLoopGroup分配的EventLoop。
Handler有ChannelInboundHandler、ChannelOutboundHandler兩種,分別處理輸入、輸出數(shù)據(jù)。
ChannelPipeline
Channel是管道,數(shù)據(jù)在其中in或者out。而Handler則是管道中的過濾閥門,支持多個(gè)Handler,組成一個(gè)ChannelPipeline。其中機(jī)制類似Filter和FilterChain。
ChannelInitializer
ChannelInitializer便是用來配置這些Handler,它會(huì)提供一個(gè)ChannelPipeline,并把Handler加入到ChannelPipeline。
Encoders和Decoders
用于字節(jié)流和Message之間的相互轉(zhuǎn)換。Netty中提供了很多現(xiàn)成的編碼/解碼器,我們一般從他們的名字中便可知道他們的用途,如ByteToMessageDecoder、MessageToByteEncoder,如專門用來處理Google Protobuf協(xié)議的ProtobufEncoder、 ProtobufDecoder。
其他
Unpooled
對(duì)象池。
TCP粘包/拆包
基于流的TCP,即read到的數(shù)據(jù),有可能不是完整的數(shù)據(jù)包。netty提供了一系列的Decoder用于解決粘包/拆包的問題。比如特定分隔符、定長消息、長度+數(shù)據(jù)等等。