1.netty能做什么

首先netty是一款高性能、封裝性良好且靈活、基于NIO(真·非阻塞IO)的開源框架。可以用來(lái)手寫web服務(wù)器、TCP服務(wù)器等，支持的協(xié)議豐富，如：常用的HTTP/HTTPS/WEBSOCKET，并且提供的大量的方法，十分靈活，可以根據(jù)自己的需求量身DIV一款服務(wù)器。

用netty編寫TCP的服務(wù)器/客戶端

1.可以自己設(shè)計(jì)數(shù)據(jù)傳輸協(xié)議如下面這樣：

2.可以自定義編碼規(guī)則和解碼規(guī)則

3.可以自定義客戶端與服務(wù)端的數(shù)據(jù)交互細(xì)節(jié)，處理socket流攻擊、TCP的粘包和拆包問(wèn)題

2.Quick Start

創(chuàng)建一個(gè)普通的maven項(xiàng)目，不依賴任何的三方web服務(wù)器，用main方法執(zhí)行即可。

加入POM依賴

 

io.netty
netty-all
4.1.6.Final

 

com.fasterxml.jackson.core
jackson-databind
2.9.7

 

log4j
log4j
1.2.17

設(shè)計(jì)一套基于TCP的數(shù)據(jù)傳輸協(xié)議

publicclassTcpProtocol{
privatebyteheader=0x58;
privateintlen;
privatebyte[]data;
privatebytetail=0x63;

publicbytegetTail(){
returntail;
}

publicvoidsetTail(bytetail){
this.tail=tail;
}

publicTcpProtocol(intlen,byte[]data){
this.len=len;
this.data=data;
}

publicTcpProtocol(){
}

publicbytegetHeader(){
returnheader;
}

publicvoidsetHeader(byteheader){
this.header=header;
}

publicintgetLen(){
returnlen;
}

publicvoidsetLen(intlen){
this.len=len;
}

publicbyte[]getData(){
returndata;
}

publicvoidsetData(byte[]data){
this.data=data;
}
}

這里使用16進(jìn)制表示協(xié)議的開始位和結(jié)束位，其中0x58代表開始，0x63代表結(jié)束，均用一個(gè)字節(jié)來(lái)進(jìn)行表示。

TCP服務(wù)器的啟動(dòng)類

publicclassTcpServer{
privateintport;
privateLoggerlogger=Logger.getLogger(this.getClass());
publicvoidinit(){
logger.info("正在啟動(dòng)tcp服務(wù)器……");
NioEventLoopGroupboss=newNioEventLoopGroup();//主線程組
NioEventLoopGroupwork=newNioEventLoopGroup();//工作線程組
try{
ServerBootstrapbootstrap=newServerBootstrap();//引導(dǎo)對(duì)象
bootstrap.group(boss,work);//配置工作線程組
bootstrap.channel(NioServerSocketChannel.class);//配置為NIO的socket通道
bootstrap.childHandler(newChannelInitializer(){
protectedvoidinitChannel(SocketChannelch)throwsException{//綁定通道參數(shù)
ch.pipeline().addLast("logging",newLoggingHandler("DEBUG"));//設(shè)置log監(jiān)聽器，并且日志級(jí)別為debug，方便觀察運(yùn)行流程
ch.pipeline().addLast("encode",newEncoderHandler());//編碼器。發(fā)送消息時(shí)候用過(guò)
ch.pipeline().addLast("decode",newDecoderHandler());//解碼器，接收消息時(shí)候用
ch.pipeline().addLast("handler",newBusinessHandler());//業(yè)務(wù)處理類，最終的消息會(huì)在這個(gè)handler中進(jìn)行業(yè)務(wù)處理
}
});
bootstrap.option(ChannelOption.SO_BACKLOG,1024);//緩沖區(qū)
bootstrap.childOption(ChannelOption.SO_KEEPALIVE,true);//ChannelOption對(duì)象設(shè)置TCP套接字的參數(shù)，非必須步驟
ChannelFuturefuture=bootstrap.bind(port).sync();//使用了Future來(lái)啟動(dòng)線程，并綁定了端口
logger.info("啟動(dòng)tcp服務(wù)器啟動(dòng)成功，正在監(jiān)聽端口:"+port);
future.channel().closeFuture().sync();//以異步的方式關(guān)閉端口

}catch(InterruptedExceptione){
logger.info("啟動(dòng)出現(xiàn)異常："+e);
}finally{
work.shutdownGracefully();
boss.shutdownGracefully();//出現(xiàn)異常后，關(guān)閉線程組
logger.info("tcp服務(wù)器已經(jīng)關(guān)閉");
}

}

publicstaticvoidmain(String[]args){
newTcpServer(8777).init();
}
publicTcpServer(intport){
this.port=port;
}
}

只要是基于netty的服務(wù)器，都會(huì)用到bootstrap 并用這個(gè)對(duì)象綁定工作線程組，channel的Class，以及用戶DIV的各種pipeline的handler類，注意在添加自定義handler的時(shí)候，數(shù)據(jù)的流動(dòng)順序和pipeline中添加hanlder的順序是一致的。也就是說(shuō)，從上往下應(yīng)該為：底層字節(jié)流的解碼/編碼handler、業(yè)務(wù)處理handler。

編碼器

編碼器是服務(wù)器按照協(xié)議格式返回?cái)?shù)據(jù)給客戶端時(shí)候調(diào)用的，繼承MessageToByteEncoder代碼：

publicclassEncoderHandlerextendsMessageToByteEncoder{
privateLoggerlogger=Logger.getLogger(this.getClass());
protectedvoidencode(ChannelHandlerContextctx,Objectmsg,ByteBufout)throwsException{
if(msginstanceofTcpProtocol){
TcpProtocolprotocol=(TcpProtocol)msg;
out.writeByte(protocol.getHeader());
out.writeInt(protocol.getLen());
out.writeBytes(protocol.getData());
out.writeByte(protocol.getTail());
logger.debug("數(shù)據(jù)編碼成功："+out);
}else{
logger.info("不支持的數(shù)據(jù)協(xié)議："+msg.getClass()+"	期待的數(shù)據(jù)協(xié)議類是："+TcpProtocol.class);
}
}
}

解碼器

解碼器屬于比較核心的部分，自定義解碼協(xié)議、粘包、拆包等都在里面實(shí)現(xiàn)，繼承自ByteToMessageDecoder，其實(shí)ByteToMessageDecoder的內(nèi)部已經(jīng)幫我們處理好了拆包/粘包的問(wèn)題，只需要按照它的設(shè)計(jì)原則去實(shí)現(xiàn)decode方法即可：

publicclassDecoderHandlerextendsByteToMessageDecoder{
//最小的數(shù)據(jù)長(zhǎng)度：開頭標(biāo)準(zhǔn)位1字節(jié)
privatestaticintMIN_DATA_LEN=6;
//數(shù)據(jù)解碼協(xié)議的開始標(biāo)志
privatestaticbytePROTOCOL_HEADER=0x58;
//數(shù)據(jù)解碼協(xié)議的結(jié)束標(biāo)志
privatestaticbytePROTOCOL_TAIL=0x63;
privateLoggerlogger=Logger.getLogger(this.getClass());
protectedvoiddecode(ChannelHandlerContextctx,ByteBufin,List