Netty

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

使用场景：

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

Reactor主从多线程模型

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

stateDiagram    state "用户端" as Client {        [*] --> Client1 : 用户端 1        [*] --> Client2 : 用户端 2        [*] --> Client3 : 用户端 3    }        state "事件分离器" as EventDispatcher {        MainReactor : Main Reactor Acceptor Thread Pool        SubReactor : Sub Reactor IO Thread Pool        MainReactor --> SubReactor : 触发 IO 事件        MainReactor --> Auth : 认证 (Auth)        MainReactor --> SLA : 服务质量 (SLA)    }    state "Handlers" as Handlers {        [*] --> Handler1 : Handler 1        [*] --> Handler2 : Handler 2        [*] --> Handler3 : Handler 3    }    Client --> MainReactor : 发起事件    SubReactor --> Handlers : 分发到 Handler

特性

• 非阻塞网络调用使得我们可以不必等待一个操作的完成。完全异步的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 执行时，如果当前线程是 eventloop 所属的线程，则就直接执行了。如果当前线程不是 eventloop 所属的线程，则将任务放入到任务队列中，等待 eventloop 线程来执行

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

线程分配

单元测试

EmbeddedChannel

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