6

Netty：

1、总体描述，

应用场景Netty是一个高性能、异步事件驱动的NIO框架。封装了Java NIO那些复杂的底层细节，给你提供简单好用的抽象概念来编程。应用场景：首先它是个框架，是个“半成品”，不能开箱即用，你必须得拿过来做点定制，利用它开发出自己的应用程序，然后才能运行（就像使用Spring那样）。 高性能基础通信组件。

2、Netty VS NIO

1）跨平台与兼容性：NIO算是底层的APIs需依赖系统的IO APIs。但Java NIO发现在不同系统平台会出现问题。 NIO2只支持JDK1.7+，而且没提供DatagramSocket，故NIO2不支持UDP协议。 而Netty提供统一接口，同一语句无论在JDK6.X 还是JDK7.X 都可运行，无需关心底层架构功能！2）JAVA NIO的ByteBuffer构造函数私有，无法扩展。Netty提供了自己的ByteBuffer实现，通过简单APIs对其进行构造、使用和操作，一此解决NIO的一些限制。

3）NIO对缓冲区的聚合与分散操作可能会导致内存泄漏。直到JDK1.7才解决此问题。

4）NIO的类库和API繁杂，使用麻烦，你需要熟练掌握Selector、ServerSocketChannel、SocketChannel、ByteBuffer等。

5）使用JAVA NIO需要具备其他的额外技能做铺垫，例如熟悉Java多线程编程。这是因为NIO编程涉及到Reactor模式，你必须对多线程和网路编程非常熟悉，才能编写出高质量的NIO程序。

6）可靠性能力补齐，工作量和难度都非常大。例如客户端面临断连重连、网络闪断、半包读写、失败缓存、网络拥塞和异常码流的处理等问题。7）JDK NIO的BUG，例如臭名昭著的epoll bug，它会导致Selector空轮询，最终导致CPU 100%。3、epoll bugJDK的NIO类库有一个epoll死循环bug，它会导致Selector空轮询，IO线程CPU达到100%，严重影响系统运行。

netty从api使用层面对该bug进行了规避解决：1）对Selector的select操作周期进行统计。每完成一次空的select操作进行一次计数。2）在某个周期内如果连续N次空轮询，则说明触发了JDK NIO的epoll死循环bug。3）创建新的Selector，将出现bug的Selector上的channel重新注册到新的Selector上。4）关闭bug的Selector，使用新的Selector进行替换。

5、启动Demo与线程池模型

EchoServer:

public void run() { 

 // 创建一个ServerBootstrap启动工具类 // 构造方法里传入NioServerSocketChannelFactory 

 ExecutorService boss = Executors.newCachedThreadPool(new NamedThreadFactory("NettyServerBoss", true));

 ExecutorService worker = Executors.newCachedThreadPool(new NamedThreadFactory("NettyServerWorker", true)); 

 ServerBootstrap bootstrap = new ServerBootstrap( 

 //构建一个创建NioServerSocketChannel的工厂类NioServerSocketChannelFactory 

 new NioServerSocketChannelFactory( boss, worker));

 // Set up the ChannelPipelineFactory.pipeline主要负责管理channel和netty之间消息的传递 

 bootstrap.setPipelineFactory(new ChannelPipelineFactory() {

 public ChannelPipeline getPipeline() throws Exception { 

 //传入echoServerHandler 

 return Channels.pipeline(new EchoServerHandler()); 

 } });

 // Bind and start to accept incoming connections. 

 bootstrap.bind(new InetSocketAddress(port));}

boss pool:处理Acceptor事件，负责连接的建立，连接建立后将交由worker pool处理，默认一个线程

worker pool:处理I/O读写事件，线程池默认大小，netty=处理器个数*2，dubbo=处理器个数 + 1

在真正的业务中，还应该添加自己的业务线程池，而不应该把业务处理放在netty的worker pool中。

NioEventLoopGroup:线程池

EventLoopGroup bossGroup = new NioEventLoopGroup(1);

EventLoopGroup workerGroup = new NioEventLoopGroup();

ServerBootstrap b = new ServerBootstrap();

b.group(bossGroup, workerGroup)

 .channel(NioServerSocketChannel.class) 

.option(ChannelOption.SO_BACKLOG, 100)

 .handler(new LoggingHandler(LogLevel.INFO)) 

.childHandler(new ChannelInitializer() { ..

ChannelPipeline:

ChannelPipline：包含一系列handler，如编解码handler处理器，addLast，利用事件传输机制，handler按顺序触发