1_netty基础组件

Netty是一个异步的事件驱动网络应用框架。

1. 核心组件

• Channels
  Java NIO的一个基础构造。可以认为它就是入站或者出站的一个载体。因此，它可以被打开或者关闭，连接或者断开。
• Callback
  也就是回调。这里的回调也就是一个方法，提供给其它方法作为一个参数。Netty在处理时间的时候使用到了callback。当一个callback触发时，相关的事件可以由ChannelHandler接口的实现类处理。代码如下：

public class ConnectHandler extends ChannelInboundHandlerAdapter {
  @Override
 public void channelActive(ChannelHandlerContext ctx)
                throws Exception {
      System.out.println(
               "Client " + ctx.channel().remoteAddress() + " connected");
  }
 }

• Future
  Future提供了另外一种操作完成时通知应用的方式。Jdk提供的future只能允许你手动检查操作是否完成或者一直阻塞直到操作完成。所以Netty提供了自己的实现-ChannelFuture，用于异步操作。
  ChannelFuture提供了额外的方法允许我们注册一个或者多个ChannelFutureListener监听器实例。监听器的callback方法operationComplete()在操作完成时会被调用。
  内一个Netty的出站I/O操作都会返回一个ChannelFuture;意味着不会被阻塞。也就是勤勉说的，Netty完完全全就是一个异步事件驱动框架。

Channel channel = ...;
//非阻塞
//异步连接
ChannelFuture future = channel.connect(
          new InetSocketAddress("192.168.0.1",25));

Channel channel = ...;
//非阻塞
//异步连接
ChannelFuture future = channel.connect(
        new InetSocketAddress("192.168.0.1",25));
//注册一个ChannelFutureListener，一旦操作完成就会执行operationComplete
future.addListener(new ChannelFutureListener(){
  public void operationComplete(ChannelFuture future){
  //检查操作状态  
  if(future.isSuccess()){
      //如果操作成功，创建一个ByteBuf来保存数据
       ByteBuf buffer = Unpooled.copiedBuffer(
              "Hello",Charset.defaultCharset());
        //异步发送数据
        ChannelFuture wf = future.channel()
                        .writeAndFlush(buffer);
         ....
    }else{
        Throwable cause = future.cause();
        cause.printStackTrace();
    }
  }
})

• Event 和handler

下图就是入站和出站的事件在ChannelHandlers中流向