1.1 Netty簡介

Netty是最流行的NIO框架，他的健壯性、功能、性能、可定制性和可擴展性在同類框架都是首屈一指的。它已經得到成百上千的上也項目驗證，如Hadoop的RPC框架Avro、以及JMS框架，強大的RocketMQ,還有主流的分布式通信框架Dubbox等等。主要原因：簡單。

Netty是基于Java NIO的網絡應用框架

1.2 Netty架構組成

1.3 Netty特性

2.1  Netty初識

下載Netty包：http://netty.io/

Netty實現通信的步驟：

1、創建兩個的NIO線程組，一個專門用于網絡事件處理（接受客戶端的連接），另一個則進行網絡通信讀寫。

2、創建一個ServerBootstrap對象，配置Netty的一系列參數，例如接收傳出數據的緩存大小等等。

3、創建一個實際處理數據的類ChannelInitializer,進行初始化的準備工作，例如設置接收傳出數據的字符集、格式、已經實際處理數據的接口。

4、綁定端口，執行同步阻塞方法等待服務端啟動即可。

解讀netty示例：http://ifeve.com/netty5-user-guide/

代碼示例：Server端

package edu.sdut.netty;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
/**
 * Server端
 * @author Vision_TXG
 *
 */
public class Server {
	public static void main(String[] args) throws Exception {
		
		//1、第一個線程組是用于接收Client端的接收的
		EventLoopGroup bossGroup = new NioEventLoopGroup();
		//2、第二個線程組是用于實際的的業務處理操作的
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		
		//3、創建一個輔助類，對Server端進行一系列的配置
		ServerBootstrap b = new ServerBootstrap();
		//將兩個線程組加入進來
		b.group(bossGroup,workerGroup)
		//執行使用NioServerSocketChannel類型的通道
		.channel(NioServerSocketChannel.class)
		//一定要使用childHandler去保定具體的事件處理器
		.childHandler(new ChannelInitializer<SocketChannel>() {

			@Override
			protected void initChannel(SocketChannel sc) throws Exception {
				sc.pipeline().addLast(new ServerHandler());
			}
			
		})
		.option(ChannelOption.SO_BACKLOG,128)
		.option(ChannelOption.SO_SNDBUF, 32*1024)   //設置發送緩沖大小
		.option(ChannelOption.SO_RCVBUF, 32*1024)   //設置接收緩沖大小
		//保持連接
		.childOption(ChannelOption.SO_KEEPALIVE, true);
		
		//綁定指定的端口進行監聽，可以綁定多個端口
		ChannelFuture f = b.bind(8765).sync(); //異步的方法
		
		//相當于一個阻塞的一個作用，不能讓主程序停止
		f.channel().closeFuture().sync();
		workerGroup.shutdownGracefully();
		bossGroup.shutdownGracefully();
		
	}
}

ServerHandler類：

package edu.sdut.netty;

import java.util.Scanner;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.ReferenceCountUtil;

public class ServerHandler extends ChannelHandlerAdapter{

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		//((ByteBuf) msg).release();
		try {
			//do somoeting msg
			ByteBuf buf = (ByteBuf)msg;
			
			//根據buf中的數據大小初始化byte
			byte[] data = new byte[buf.readableBytes()];
			//將buf中的數據讀到byte中
			buf.readBytes(data);
			String request = new String(data,"gbk");
			System.out.println("Server : " + request);
			
			//發給客戶端
			String response = "I'm Server";
			Scanner cin = new Scanner(System.in);
			System.out.println("Server回: ");
			response = cin.nextLine();
			
			
			//在寫的同時是有返回對象的，返回的Future類型的
			ChannelFuture cf = ctx.write(Unpooled.copiedBuffer(response.getBytes()));
			//只要數據發送完之后，就回主動斷開連接,實現長連接和短連接
			cf.addListener(ChannelFutureListener.CLOSE);
			
			ctx.flush();
			
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			
			//讀數據的時候需要釋放，如果胡需要讀數據就不用釋放
			//用完釋放
			ReferenceCountUtil.release(msg);
		}
	}

	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		cause.printStackTrace();
		ctx.close();
	}

}

Client端：

package edu.sdut.netty;

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
/**
 * Client端
 * @author Vision_TXG
 *
 */
public class Client {

	public static void main(String[] args) throws Exception {
		
		EventLoopGroup group = new NioEventLoopGroup();
		Bootstrap b = new Bootstrap();
		b.group(group)
		.channel(NioSocketChannel.class)
		.handler(new ChannelInitializer<SocketChannel>() {

			@Override
			protected void initChannel(SocketChannel sc) throws Exception {
				
				sc.pipeline().addLast(new ClientHandler());
			}
			
		});
		//非阻塞的異步通道
		ChannelFuture cf1 = b.connect("127.0.0.1",8765).sync();
		
		//Unpooled.copiedBuffer("I'm String".getBytes())的作用是將字符串轉換為字節數組
		
		//客戶端進行寫數據
		cf1.channel().write(Unpooled.copiedBuffer("I'm String".getBytes()));
		cf1.channel().flush();
		
		cf1.channel().closeFuture().sync();
		group.shutdownGracefully();
	}
}

ClientHandler類：

package edu.sdut.netty;

import java.util.Scanner;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerAdapter;
import io.netty.channel.ChannelHandlerContext;
import io.netty.util.ReferenceCountUtil;

public class ClientHandler extends ChannelHandlerAdapter{

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		//((ByteBuf) msg).release();
		
		try {
			//do somoeting msg
			ByteBuf buf = (ByteBuf)msg;
			
			//根據buf中的數據大小初始化byte
			byte[] data = new byte[buf.readableBytes()];
			//將buf中的數據讀到byte中
			buf.readBytes(data);
			String response = new String(data,"gbk");
			System.out.println("Client : " + response);
			
			
			//發給服務器
			String res = "I'm Client";
			Scanner cin = new Scanner(System.in);
			System.out.println("Client回: ");
			res = cin.nextLine();
			ctx.write(Unpooled.copiedBuffer(res.getBytes()));
			ctx.flush();
			
		} catch (Exception e) {
			e.printStackTrace();
		}finally {
			//用完釋放
			ReferenceCountUtil.release(msg);
		}
	}

	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		cause.printStackTrace();
		ctx.close();
	}
	
}