Netty-Hello-World（一）

Netty简介

Netty是一个NIO client-server框架，使用Netty可以快速开发网络应用，例如服务器和客户端协议。Netty提供了一种新的方式来开发网络应用程序，这种新的方式使得它容易使用和有很强的扩展性。Netty的内部实现很复杂，但是Netty提供了简单易用的api从网络处理代码中解耦业务逻辑。Netty是完全基于NIO实现，所以整个Netty都是异步的。网络应用程序通常需要有较高的可扩展性，无论是Netty还是其他的基于Java NIO的框架，都会提供可扩展的解决方案。Netty中一个关键的组成部分是它的异步特性。

Netty架构组成

Hello World

回顾NIO通信步骤：

1. 创建ServerSocketChannel，为他配置非阻塞模式。
2. 绑定监听，配置TCP参数，录入backlog大小等。
3. 创建一个独立的IO线程，用于轮询多路复用器Selector。
4. 创建Selector，将之前的ServletSocketChannel注册到Selector上，并配置监听标识位SelectionKey.ACCEPT。
5. 启动IO线程，在循环体中执行Selector.select()方法，轮询就绪的通道。
6. 当轮询到处于就绪的通道时，需要进行判断操作位，如果是ACCEPT状态，说明是新的客户端接入，则调用accept方法接受新的客户端。
7. 设置新接入客户端的一些参数，如非阻塞，并将其通道继续注册到Selector之中，设置监听标识位等。
8. 如果轮询的通道操作位是READ，则进行读取，构造Buffer对象等。
9. 更细节的还有数据没发送完成继续发送的问题…

一个简单的NIO服务端程序就是如此复杂，我们来看看Netty完成这件事情需要的步骤。Netty实现通信的步骤：

1. 创建两个NIO线程组，一个专门用于网络时间处理（接受客户端的连接），另一个则进行网络通信的读写。
2. 创建一个ServerBootstrap对象，配置Netty的一系列参数，例如接受传出数据的缓存大小等待。
3. 创建一个实际处理数据的类ChannelInitializer，进行初始化的准备工作，比如设置接受传出数据的字符集、格式、已经实际处理数据的接口。
4. 绑定端口，执行同步阻塞方法等待服务器启动即可。

public class Server {

	public static void main(String[] args) throws InterruptedException {
		//1.第一个线程组是用于接收Client连接的
		EventLoopGroup bossGroup = new NioEventLoopGroup(); 
		//2.第二个线程组是用于实际的业务处理操作的
		EventLoopGroup workerGroup = new NioEventLoopGroup();
		//3.声明一个启动NIO服务的辅助启动类，就是对我们的Server端进行一系列的配置
		ServerBootstrap b = new ServerBootstrap();
		//将两个工作线程组加入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());
			}
		})
		//设置指定通道实现的配置参数，也就是设置tcp缓冲区
		.option(ChannelOption.SO_BACKLOG, 128)
		//保持连接
		.option(ChannelOption.SO_KEEPALIVE, true);

		//绑定指定端口，进行监听
		ChannelFuture f = b.bind(8765).sync();
		
		//Thread.sleep(Integer.MAX_VALUE);
		f.channel().closeFuture().sync();
		
		bossGroup.shutdownGracefully();
		workerGroup.shutdownGracefully();
	}
}

public class ServerHandler extends ChannelHandlerAdapter{

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		//((ByteBuf) msg).release();
		try{
			// do something msf
			ByteBuf buf = (ByteBuf) msg;
			byte[] data = new byte[buf.readableBytes()];
			buf.readBytes(data);
			String request = new String(data,"utf-8");
			System.out.println("Server: " + request);
			
		} finally {
			ReferenceCountUtil.release(msg);
		}
	}

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

public class Client {

	public static void main(String[] args) throws InterruptedException {
		EventLoopGroup workgroup = new NioEventLoopGroup();
		Bootstrap b = new Bootstrap();
		b.group(workgroup)
		.channel(NioSocketChannel.class)
		.handler(new ChannelInitializer<SocketChannel>() {
			@Override
			protected void initChannel(SocketChannel sc) throws Exception {
				sc.pipeline().addLast(new ClientHandler());
			}
		});
		
		ChannelFuture cf = b.connect("127.0.0.1", 8765).sync();
		
		//向服务端写数据
		cf.channel().write(Unpooled.copiedBuffer("hell world".getBytes()));
		cf.channel().flush();
		
		cf.channel().closeFuture().sync();
		workgroup.shutdownGracefully();
	}
}

public class ClientHandler extends ChannelHandlerAdapter{

	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
		((ByteBuf) msg).release();
	}

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