Netty

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

使用场景:

Reactor主从多线程模型

Reactor主从多线程模型

特性

批注 2020-07-04 091702

核心组件

批注 2020-07-04 092924

组件和设计

Channel

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

EventLoop

批注 2020-07-05 094441

一个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中,有两种消息发送方式

编码器解码器

ServerBootStrap

Server端需要两组EventLoop

批注 2020-07-05 100502

异常处理

线程模型

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

线程池模型

批注 2020-07-08 111409

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

EventLoop

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

    if (confirmShutdown()) {
        break;
    }
}

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

任务调度

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

线程管理

批注 2020-07-08 112901

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

线程分配

批注 2020-07-08 113146

批注 2020-07-08 113208

单元测试

EmbeddedChannel

批注 2020-07-10 105859

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

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