Channel的生命周期

Channel包含4个状态：

ChannelHandler的生命周期

ChannelHandler接口定义了一系列生命周期操作：

ChannelInboundHandler接口

ChannelOutboundHandler接口

ChannelHandler适配器

资源管理

每当调用ChannelInboundHandler.channelRead()或者ChannelOutboundHandler.write()方法来处理数据时，都需要确保没有任何的资源泄漏。Netty使用引用计数来处理池化的ByteBuf.所以在完全使用某个ByteBuf之后，调整其引用计数是很重要的。
Netty提供了class ResourceLeakDetector，它可以对应用程序缓冲区分配做大约1%的采样率进行内存泄漏检测。相关的开销是非常的小的。

泄漏检测级别可以通过JVM启动选项来设置：
java -Dio.netty.leakDetectionLevel=ADVANCED

ChannelPipeline接口

ChannelPipeline是一个拦截流经Channel的入站和出站事件的ChannelHandler实例链。每一个新创建的Channel都会被分配给一个新的ChannelPipeline，这项关联式永久性的，Channel既不能附加另外一个ChannelPipeline，也不能分离其当前的。
根据事件的起源事件将会被分为ChannelInboundHandler或者ChannelOutboundHandler处理。

修改ChannelPipeline

ChannelPipeline可以通过添加、删除或者替换其它的ChannelHandler来实时地修改ChannelPipeline的布局。

ChannelPipeline还提供了访问ChannelHandler的操作：

触发事件

ChannelPipeline的API公开了用于调用入站和出站操作的附加方法。

ChannelHandlerContext接口

ChannelHandlerContext代表了ChannelHandler和ChannelPipeline之间的关联。每当有ChannelHandler添加到ChannelPipeline中时，都会创建ChannelHandlerContext。ChannelHandlerContext的主要功能就是管理它所关联的ChannelHandler和在同一ChannelPipeline中的其它ChannelHandler之间的交互。

异常处理

Netty提供了几种方式来处理入站和出站过程中出现的异常。

入站异常

如果需要处理入站异常，需要在对应的ChannelInboundHandler中重写exceptionCaught方法。

1
2
3
4
5
6
7
8

public class InboundExceptionHandler extends ChannelInboundHandlerAdapter{
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx,
	Throwable cause) {
		cause.printStackTrace();
		ctx.close();
	}
}

一般将异常处理的ChannelHandler放到ChannelPipeline的最后一个位置。这样在整个处理路链中无论哪个环节出了异常都可以得到处理。因为exceptionCaught()的默认实现是将异常转发给下一个HandlerHandler.

处理出站异常

处理出站异常基于以下的机制：

• 每个出站操作都会返回一个ChannelFuture，注册到ChannelFuture的ChannelFutureListener将在操作完成时痛殴之该操作时注册成功还是出错了
• 几乎所有的ChannelOutboundHandler上的方法都会传入一个ChannelPromise的实例，作为ChannelFuture的子类，ChannelPromise也可以被分配用于异步通知的监听器。但是，ChannelPromise还具有提供立即通知的可写方法。

处理方法：

1
2
3
4
5
6
7
8
9
10

ChannelFuture future = channel.write(someMessage);
future.addListener(new ChannelFutureListener() {
	@Override
	public void operationComplete(ChannelFuture f) {
		if (!f.isSuccess()) {
			f.cause().printStackTrace();
			f.channel().close();
		}
	}
});

另一种方法：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

public class OutboundExceptionHandler extends 	   ChannelOutboundHandlerAdapter {
	@Override
	public void write(ChannelHandlerContext ctx, Object msg,
		ChannelPromise promise) {
		promise.addListener(new ChannelFutureListener() {
			@Override
			public void operationComplete(ChannelFuture f) {
				if (!f.isSuccess()) {
					f.cause().printStackTrace();
					f.channel().close();
				}
			}
	});
	}
}