1.netty能做什么

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

用netty編寫TCP的服務器/客戶端

1.可以自己設計數據傳輸協議如下面這樣：

2.可以自定義編碼規則和解碼規則

3.可以自定義客戶端與服務端的數據交互細節，處理socket流攻擊、TCP的粘包和拆包問題

2.Quick Start

創建一個普通的maven項目，不依賴任何的三方web服務器，用main方法執行即可。

加入POM依賴

 

io.netty
netty-all
4.1.6.Final

 

com.fasterxml.jackson.core
jackson-databind
2.9.7

 

log4j
log4j
1.2.17

設計一套基于TCP的數據傳輸協議

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進制表示協議的開始位和結束位，其中0x58代表開始，0x63代表結束，均用一個字節來進行表示。

TCP服務器的啟動類

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

}catch(InterruptedExceptione){
logger.info("啟動出現異常："+e);
}finally{
work.shutdownGracefully();
boss.shutdownGracefully();//出現異常后，關閉線程組
logger.info("tcp服務器已經關閉");
}

}

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

只要是基于netty的服務器，都會用到bootstrap 并用這個對象綁定工作線程組，channel的Class，以及用戶DIV的各種pipeline的handler類，注意在添加自定義handler的時候，數據的流動順序和pipeline中添加hanlder的順序是一致的。也就是說，從上往下應該為：底層字節流的解碼/編碼handler、業務處理handler。

編碼器

編碼器是服務器按照協議格式返回數據給客戶端時候調用的，繼承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("數據編碼成功："+out);
}else{
logger.info("不支持的數據協議："+msg.getClass()+"	期待的數據協議類是："+TcpProtocol.class);
}
}
}

解碼器

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

publicclassDecoderHandlerextendsByteToMessageDecoder{
//最小的數據長度：開頭標準位1字節
privatestaticintMIN_DATA_LEN=6;
//數據解碼協議的開始標志
privatestaticbytePROTOCOL_HEADER=0x58;
//數據解碼協議的結束標志
privatestaticbytePROTOCOL_TAIL=0x63;
privateLoggerlogger=Logger.getLogger(this.getClass());
protectedvoiddecode(ChannelHandlerContextctx,ByteBufin,List