Netty

• 什么是零拷贝？

//封装Byte数组
public static ByteBuf wrappedBuffer(byte[]... arrays) {
        return wrappedBuffer(arrays.length, arrays);
    }
//封装ByteBuf
public static ByteBuf wrappedBuffer(ByteBuf... buffers) {
        return wrappedBuffer(buffers.length, buffers);
    }
//封装ByteBuffer
public static ByteBuf wrappedBuffer(ByteBuffer... buffers) {
        return wrappedBuffer(buffers.length, buffers);
    }

• Channel:
  • 基本的IO操作（bind()、connect()、read()、write()）依赖于底层网络传输所提供的原语。
  • channel提供了一系列API，降低了调用Socket的复杂性。
• EventLoop:
  • 用于处理连接的生命周期中所发生的事件。
  • 一个eventloop在他的生命周期只和一个thread绑定。
  • eventloop所处理的IO事件都在它专有的thread上被处理。
  • 一个channel只注册于一个eventloop，一个eventloop可能会被分配给多个channel
• ChannelFuture:
  • 由于netty中的IO都是异步的，因此netty提供了channelfuture用于确定一个不能立即返回结果的操作，在之后的某个时间点确定其结果的方法。

• Handler部分
  • 核心API

  入站Handler：

public interface ChannelInboundHandler extends ChannelHandler {

    /**
     当通道注册完成后，Netty会调用fireChannelRegistered()方法，触发通道注册事件，
     而在通道流水线注册过的入站处理器的channelRegistered()回调方法会被调用。
     */
    void channelRegistered(ChannelHandlerContext ctx) throws Exception;

    /**
     * 当通道激活完成后，Netty会调用fireChannelActive()方法，触发通道激活事件，
     而在通道流水线注册过的入站处理器的channelActive()回调方法会被调用。
     */
    void channelUnregistered(ChannelHandlerContext ctx) throws Exception;

     /**
     * 当通道激活完成后，Netty会调用fireChannelActive()方法，触发通道激活事件，
     而在通道流水线注册过的入站处理器的channelActive()回调方法会被调用。
     */
    void channelActive(ChannelHandlerContext ctx) throws Exception;

    /**
     * 当连接被断开或者不可用时，Netty会调用fireChannelInactive()方法
     ，触发连接不可用事件，
     而在通道流水线注册过的入站处理器的channelInactive()回调方法会被调用。
     */
    void channelInactive(ChannelHandlerContext ctx) throws Exception;

    /**
     当通道缓冲区可读时，Netty会调用fireChannelRead()方法，触发通道可读事件，
     而在通道流水线注册过的入站处理器的channelRead()回调方法会被调用，
     以便完成入站数据的读取和处理。
     */
    void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception;

    /**
     * 当通道缓冲区读完时，Netty会调用fireChannelReadComplete()方法，
     触发通道缓冲区读完事件，
     而在通道流水线注册过的入站处理器的channelReadComplete()回调方法会被调用。
     */
    void channelReadComplete(ChannelHandlerContext ctx) throws Exception;

    /**
     * 如果触发了用户事件，则被调用。
     */
    void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception;

    /**
     * 一旦Channel的可写状态改变，就会被调用。 
     可以使用Channel.isWritable()检查状态。
     */
    void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception;

    /**
     * 异常回调
     */
    @Override
    @SuppressWarnings("deprecation")
    void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception;
}

public interface ChannelOutboundHandler extends ChannelHandler {
    /**
    监听地址（IP+端口）绑定：完成底层Java IO通道的IP地址绑定。
    如果使用TCP传输协议，这个方法用于服务端。
     */
    void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) throws Exception;

    /**
      连接服务端：完成底层Java IO通道的服务端的连接操作。
      如果使用TCP传输协议，那么这个方法将用于客户端。
     */
    void connect(
            ChannelHandlerContext ctx, SocketAddress remoteAddress,
            SocketAddress localAddress, ChannelPromise promise) throws Exception;

    /**
     * 断开服务器连接：断开底层Java IO通道的socket连接。
     如果使用TCP传输协议，此方法主要用于客户端。
     *
     */
    void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
     * 主动关闭通道：关闭底层的通道，例如服务端的新连接监听通道。
     */
    void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
   从当前注册的EventLoop进行取消注册操作后调用。
     */
    void deregister(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception;

    /**
     * 从底层读数据：完成Netty通道从Java IO通道的数据读取。
     */
    void read(ChannelHandlerContext ctx) throws Exception;

    /**
    * 写数据到底层：完成Netty通道向底层Java IO通道的数据写入操作。此方法仅仅是触发一下操作，并不是完成实际的数据写入操作。
     */
    void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception;

    /**
     * 将底层缓存区的数据腾空，立即写出到对端。
     */
    void flush(ChannelHandlerContext ctx) throws Exception;
}

同理，使用时继承该类，并重写自己需要的方法。

ChannelInitialiazer通道初始化Handler：

一条Netty通道拥有一条Handler业务处理器流水线，负责装配自己的Handler业务处理器。装配Handler的工作发生在通道开始工作之前。

图中，ChannelInitializer，属于入站处理器的类型，继承了ChannelInboundHandlerAdapter。其中，InitChannel()为ChannelInitializer定义的抽象方法，需要开发人员自己实现.

/**
一旦Channel被注册，这个方法就会被调用。 
方法返回后，此实例将从Channel的ChannelPipeline中删除。
**/
protected abstract void initChannel(C ch) throws Exception;