我们一起聊聊Netty核心模块

常用的方法：,常用的方法：,Channel channel() 返回当前正在进行IO操作的通道 ChannelFuture sync() 等待异步操作执行完毕。,NioSocketChannel,异步的客户端TCP Socket连接 NioServerSocketChannel，异步的服务端TCP Socket连接 NioDatagramChannel，异步的UDP连接 NioSctpChannel，异步的客户端Sctp连接 NioSctpServerChannel，异步的Sctp服务器端连接，这些通道涵盖了UDP和TCP网络IO以及文件IO。,Netty基于Selector对象实现IO多路复用，通过Selector一个线程可以监听多个连接的Channel事件。,当向一个Selector中注册Channel后，Selector内部会轮询这些Channel是否有已就绪的IO事件（如可读、可写、网络连接完成等），这样程序就可以很简单地使用一个线程高效管理多个Channel。,,ChannelInboundHandler 用于处理入站IO事件 ChannelOutboundHandler 用于处理出站IO事件。,public void channelActive(ChannelHandlerContext ctx) 通道就绪事件 public void channelInactive(ChannelHandlerContext ctx) 通道关闭事件 public void channelRead(ChannelHandlerContext ctx, Object msg) 读取数据事件 public void channelReadComplete(ChannelHandlerContext ctx) 数据读取完毕事件 public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) 抛出异常事件。,ChannelPipeline是一个重点：,,一个Channel包含了一个ChannelPipeline，而ChannelPipeline中又维护了一个由ChannelHandlerContext组成的双向链表，并且每个ChannelHandlerContext中又关联着一个ChannelHander 入站事件和出站事件在一个双向链表中，入站事件会从链表head往后传递到最后一个入站的handler，出站事件会从链表tail往前传递到最前一个出站的handler，两种类型的handler互不干扰。,常用方法,ChannelPipeline addLast(ChannelHandler… handlers); 把一个业务处理类（handler）添加到链表的第一个位置 ChannelPipeline addFirst(ChannelHandler… handlers); 把一个业务处理类（handler）添加到链表的最后一个位置。,保存Channel相关的所有上下文信息，同时关联一个ChannelHandler对象。,ChannelHandlerContext中包含一个具体的事件处理器ChannelHandler，同时也绑定了对应的pipeline和Channel，方便对ChannelHandler进行调用。,常用方法,ChannelFuture close(); 关闭当前通道 ChannelHandlerContext flush(); 刷新数据 ChannelFuture writeAndFlush(Object msg); 将数据写到ChannelPipeline中，并开始出站处理。,Netty在创建Channel实例后，一般都需要设置ChannelOption参数。,ChannelOption参数如下：,ChannelOption.SO_BACKLOG 对应TCP/IP协议listen函数中的backlog参数，用来初始化服务器可用队列大小。服务端处理客户端连接请求是顺序处理的ChannelOption.SO_KEEPALIVE 保持连接活动状态,BossEventLoopGroup通常是一个单线程的EventLoop，EventLoop维护着一个注册了ServerSocketChannel的Selector实例，BossEventLoop不断轮询Selector将连接事件分离出来。通常是OP_ACCEPT事件，然后将接收到的SocketChannel交给WorkerEventLoopGroupWorkerEventLoopGroup会由next选择其中一个EventLoop来将这个SocketChannel注册到其维护的Selector并对其后续的IO事件进行处理。,常用方法：,public NioEventLoopGroup(int nThreads)，构造函数，可以指定线程数，如果没有指定就是CPU核心数的两倍 public Future\ shutdownGracefully() 断开连接，关闭线程。,Netty提供一个专门用来操作缓冲区（Netty数据容器）的工具类。,常用方法：,public static ByteBuf copiedBuffer(CharSequence string, Charset charset)。,