Netty

Netty是由JBOSS提供的一个java开源框架。Netty提供异步的、事件驱动的网络应用程序框架和工具，用以快速开发高性能、高可靠性的网络服务器和客户端程序。

使用场景：

• 高性能领域
• 多线程并发领域
• 异步通信领域

Reactor主从多线程模型

• 处理高并发
• 一组线程接收请求，一组线程处理IO

特性

• 非阻塞网络调用使得我们可以不必等待一个操作的完成。完全异步的I/O正是基于这个特性构建的，并且更进一步：异步方法会立即返回，并且在它完成时，会直接或者在稍后的某个时间点通知用户。
• 选择器使得我们能够通过较少的线程便可监视许多连接上的事件。

核心组件

• 回调
  • netty使用回调来将事件处理交给程序
• Future
  • netty的实现：ChannelFuture
  • ChannelFutureListener
    • 回调的更精细版本
• 事件与ChannelHandler

组件和设计

Channel

它代表一个到实体（如一个硬件设备、一个文件、一个网络套接字或者一个能够执行一个或者多个不同的I/O操作的程序组件）的开放连接，如读操作和写操作

• EmbeddedChannel；
• LocalServerChannel；
• NioDatagramChannel；
• NioSctpChannel；
• NioSocketChannel。

EventLoop

一个EventLoop在它的生命周期内只和一个Thread绑定 这个Thread会处理EventLoop所有的IO事件

一个Channel对应一个EventLoop 一个EventLoop有一个或多个Channel

ChannelFuture

提供了另一种在操作完成时通知应用程序的方式。这个对象可以看作是一个异步操作的结果的占位符；它将在未来的某个时刻完成，并提供对其结果的访问。

属于同一个Channel的操作都能保证按调用的顺序执行

ChannelHandler

ChannelHandler 为 Netty 中最核心的组件，它充当了所有处理入站和出站数据的应用程序逻辑的容器。ChannelHandler 主要用来处理各种事件，这里的事件很广泛，比如可以是连接、数据接收、异常、数据转换等

classDiagram
  ChannelHandler <-- ChannelInboundHandler: 继承
  ChannelHandler <-- ChannelHandlerAdapter: 继承
  ChannelHandler <-- ChannelOutboundHandler: 继承
  ChannelInboundHandler <.. ChannelInboundHandlerAdapter: 实现
  ChannelHandlerAdapter <-- ChannelInboundHandlerAdapter: 继承
  ChannelHandlerAdapter <-- ChannelOutboundHandlerAdapter: 继承
  ChannelOutboundHandler <.. ChannelOutboundHandlerAdapter: 实现

ChannelPipeline

ChannelPipeline 为 ChannelHandler 链提供了一个容器并定义了用于沿着链传播入站和出站事件流的 API

在netty中，有两种消息发送方式

• Channel: 消息会从头开始传递
• ChannelHandlerContext 消息会从某一个Handler开始传递

编码器解码器

• xxxDecoder
• xxxEncoder

ServerBootStrap

• 使用服务器的ServerBootStrap，用于接受客户端的连接以及为已接受的连接创建子通道。
• 用于客户端的BootStrap，不接受新的连接，并且是在父通道类完成一些操作。

Server端需要两组EventLoop

异常处理

• 入站异常
  • ChannelHnadler.exceptionCaught
• 出站异常
  • ChannelFutureListener
  • ChannelFuture

线程模型

线程模型确定了代码的执行方式

线程池模型

不能消除由上下文切换所带来的开销

EventLoop

for (;;) {
    Runnable task = takeTask();
    if (task != null) {
        task.run();
        updateLastExecutionTime();
    }

    if (confirmShutdown()) {
        break;
    }
}

一个EventLoop 由 永远都不会变动的一个 Thread 驱动

任务调度

• JDK自带的ScheduleExecutorService
• netty 自带的调度

Channel ch = ...
ScheduledFuture<?> future = ch.eventLoop().schedule(  ← --  创建一个Runnable以供调度稍后执行
　　new Runnable() { 
　　@Override
　　public void run() {  ← --  要执行的代码
　　　　System.out.println("60 seconds later");　
　　}
}, 60, TimeUnit.SECONDS);　 ← --  调度任务在从现在开始的60 秒之后执行

线程管理

所以一定不能将一个长时间运行的任务放入到执行队列中 否则EventLoop会被阻塞

线程分配

• 异步传输

• 阻塞传输

单元测试

EmbeddedChannel

EmbeddedChannel channel = new EmbeddedChannel(new EchoServerHandler());

channel.writeInbound("hello"); // 入站数据
assertTrue(channel.finish()); // 标记为完成
String outData = channel.readOutbound(); // 出站数据
assertEquals("hello",outData);