网站自适应手机代码,网络服务机构的网站,网址导航该如何推广,编写微信小程序用什么软件Netty 整体架构脉络 Netty 的逻辑处理架构为典型网络分层架构设计#xff0c;共分为网络通信层、事件调度层、服务编排层#xff0c;每一层各司其职。 网络通信层 网络通信层的职责是执行网络 I/O 的操作。它支持多种网络协议和 I/O 模型的连接操作。当网络数据读取到内核缓冲… Netty 整体架构脉络 Netty 的逻辑处理架构为典型网络分层架构设计共分为网络通信层、事件调度层、服务编排层每一层各司其职。 网络通信层 网络通信层的职责是执行网络 I/O 的操作。它支持多种网络协议和 I/O 模型的连接操作。当网络数据读取到内核缓冲区后会触发各种网络事件这些网络事件会分发给事件调度层进行处理。 网络通信层的核心组件包含BootStrap、ServerBootStrap、Channel三个组件。 BootStrap Bootstrap 是“引导”的意思它主要负责整个 Netty 程序的启动、初始化、服务器连接等过程它相当于一条主线串联了 Netty 的其他核心组件。 Netty 中的引导器共分为两种类型 一个为用于客户端引导的 Bootstrap。 另一个为用于服务端引导的 ServerBootStrap它们都继承自抽象类 AbstractBootstrap。 Bootstrap 和 ServerBootStrap 十分相似两者非常重要的区别在于: 客户端 Bootstrap 可用于连接远端服务器只绑定一个 EventLoopGroup。 而 ServerBootStrap 则用于服务端启动绑定本地端口会绑定两个 EventLoopGroup这两个 EventLoopGroup 通常称为 Boss 和 Worker。 为什么客户端的BootStrap要绑定一个EventLoopGroup呢 因为服务器端发送消息给客户端,客户端也是需要一个EventLoopGroup处理。 ServerBootStrap 中的 Boss 和 Worker 是什么角色呢它们之间又是什么关系 这里的 Boss 和 Worker 可以理解为“老板”和“员工”的关系。 每个服务器中都会有一个 Boss也会有一群做事情的 Worker。 Boss 会不停地接收新的连接然后将连接分配给一个个 Worker 处理连接。 Channel 比如ServerSocketChannel NioSocketChannel。 Channel 的字面意思是“通道”它是网络通信的载体。 Channel提供了基本的 API 用于网络 I/O 操作 如 register:注册到eventloop、bind:绑定端口、connect:连接服务器端、read、write、flush 等。 Netty 自己实现的 Channel 是以 JDK的NIOChannel 为基础的相比较于 JDK NIONetty 的 Channel 提供了更高层次的抽象同时屏蔽了底层 Socket 的复杂性赋予了 Channel 更加强大的功能你在使用 Netty 时基本不需要再与 Java Socket 类直接打交道。 下图是 Channel 家族的图谱。AbstractChannel 是整个家族的基类派生出 AbstractNioChannel、 AbstractOioChannel、AbstractEpollChannel 等子类每一种都代表了不同的 I/O 模型和协议类型。 常用的 Channel 实现类有 NioServerSocketChannel 异步TCP服务端。可以监听接入TCP连接的通道。 NioSocketChannel 异步TCP客户端。客户端跟服务端进行通信的。是连接到TCP网络socket(套接字)的通道 OioServerSocketChannel 同步 TCP 服务端。 OioSocketChannel 同步 TCP 客户端。 NioDatagramChannel 异步 UDP 连接。 OioDatagramChannel 同步 UDP 连接。 当然 Channel 会有多种状态如连接建立、连接注册、数据读写、连接销毁等。随着状态的变化Channel 处于不同的生命周期每一种状态都会绑定相应的事件回调下面的表格我列举了 Channel 最常见的状态所对应的事件回调。 事件 说明 channelRegistered Channel 创建后被注册到EventLoop上 channelUnregistered Channel 创建后从EventLoop取消注册 channelActive Channel 处于就绪状态,可以被读写 channelInactive Channel 处于非就绪状态 channelRead Channel 可以从远端读取到数据 channelReadComplete Channel 读取数据完成 BootStrap 和 ServerBootStrap 分别负责客户端和服务端的启动它们是非常强大的辅助工具类 Channel 是网络通信的载体提供了与底层 Socket 交互的能力。 那么 Channel 生命周期内的事件都是如何被处理的呢 那就是 Netty 事件调度层的工作职责了。 事件调度层 事件调度层的职责是通过 Reactor 线程模型对各类事件进行聚合处理通过 Selector 主循环线程集成多种事件( I/O 事件、信号事件、定时事件等)实际的业务处理逻辑是交由服务编排层中相关的 Handler 完成。 事件调度层的核心组件包括 EventLoopGroup、EventLoop。 EventLoopGroup EventLoopGroup 本质是一个线程池主要负责接收 I/O 请求并分配线程执行处理请求。 在下图中我为你讲述了 EventLoopGroups、EventLoop 与 Channel 的关系。 EventLoopGroup、EventLoop、Channel的关系 从上图中我们可以总结出 EventLoopGroup、EventLoop、Channel 的几点关系。 EventLoop和线程绑定 一个 EventLoopGroup 往往包含一个或者多个 EventLoop。EventLoop 同一时间会与一个线程绑定每个EventLoop负责处理多个 Channel 1个EventLoop可以理解为1个线程 ,EventLoop 用于处理 Channel 生命周期内的所有 I/O 事件。 如 accept、connect、read、write 等 I/O 事件。 1个EventLoop处理N个Channel 1个channel绑定1个EventLoop 每新建一个 ChannelEventLoopGroup 会选择一个 EventLoop 与其绑定。 该 Channel 在生命周期内都可以对 EventLoop 进行多次绑定和解绑。 下图是 EventLoopGroup 的家族图谱。可以看出 Netty 提供了 EventLoopGroup 的多种实现而且 EventLoop 则是 EventLoopGroup 的子接口所以也可以把 EventLoop 理解为 EventLoopGroup但是它只包含一个 EventLoop 。 EventLoop的实现类是 NioEventLoop。 EventLoopGroup 的实现类是 NioEventLoopGroup。 NioEventLoopGroup 也是 Netty 中最被推荐使用的线程模型。 NioEventLoopGroup 继承于 MultiThreadEventLoopGroup是基于 NIO 模型开发的可以把 NioEventLoopGroup 理解为一个线程池NioEventLoop理解为1个线程。 每个线程负责处理多个 Channel而同一个 Channel 只会对应一个线程。 EventLoopGroup 是 Netty 的核心处理引擎那么 EventLoopGroup和之前所提到的 Reactor 线程模型到底是什么关系呢 其实 EventLoopGroup 是 Netty Reactor 线程模型的具体实现方式Netty 通过创建不同的 EventLoopGroup 参数配置就可以支持 Reactor 的三种线程模型 单线程模型EventLoopGroup 只包含一个 EventLoopBoss 和 Worker 使用同一个EventLoopGroup 多线程模型EventLoopGroup 包含多个 EventLoopBoss 和 Worker 使用同一个EventLoopGroup 主从多线程模型EventLoopGroup 包含多个 EventLoopBoss 是主 ReactorWorker 是从 Reactor它们分别使用不同的 EventLoopGroup主 Reactor 负责接受新的网络连接 Channel 创建然后把 Channel 注册到从 Reactor。从 Reactor负责监听读写事件。 服务编排层 服务编排层的职责是负责组装各类服务它是 Netty 的核心处理链用以实现网络事件的动态编排和有序传播。 服务编排层的核心组件包括 ChannelPipeline、ChannelHandler、ChannelHandlerContext。 handler方法和childHandler方法 java 在基类AbstractBootstrap有handler方法目的是添加一个handler监听Bootstrap的动作客户端的Bootstrap中继承了这一点。 在服务端的ServerBootstrap中增加了一个方法childHandler它的目的是添加handler用来监听已经连接的客户端的Channel的动作和状态。 handler()和childHandler()的主要区别是handler()是发生在初始化的时候。初始化指的是accept接收到请求,对客户端socketChannel进行初始化。 childHandler()是发生在客户端连接之后。 也就是说如果需要在客户端连接前的请求进行handler处理则需要配置在handler()方法中处理,如果是处理客户端连接之后的handler,则需要配置在childHandler()。 通过handler添加的handlers是对bossGroup线程组起作用通过childHandler添加的handlers是对workerGroup线程组起作用客户端Bootstrap只有handler()方法因为客户端只需要一个事件线程组( b.childHandler(new ChannelInitializerSocketChannel() { Override public void initChannel(SocketChannel ch) throws Exception { ChannelPipeline p ch.pipeline(); p.addLast(new LoggingHandler(LogLevel.INFO)); p.addLast(serverHandler); } }); pipeline是伴随Channel的存在而存在的交互信息通过它进行传递我们可以addLast(或者addFirst)多个handler第一个参数是名字无具体要求如果填写null系统会自动命名。 ChannelPipeline ChannelPipeline 是 Netty 的核心编排组件负责组装各种 ChannelHandler实际数据的编解码以及加工处理操作都是由 ChannelHandler 完成的。 ChannelPipeline 可以理解为ChannelHandler 的实例列表——内部通过双向链表将不同的 ChannelHandler 链接在一起。当 I/O 读写事件触发时ChannelPipeline 会依次调用 ChannelHandler 列表对 Channel 的数据进行拦截和处理。 ChannelPipeline 是线程安全的因为每一个新的 Channel 都会对应绑定一个新的 ChannelPipeline。 一个 ChannelPipeline 关联一个 EventLoop一个 EventLoop 仅会绑定一个线程。 ChannelPipeline、ChannelHandler 都是高度可定制的组件。 开发者可以通过这两个核心组件掌握对 Channel 数据操作的控制权。下面我们看一下 ChannelPipeline 的结构图 从上图可以看出ChannelPipeline 中包含入站 ChannelInboundHandler 和出站 ChannelOutboundHandler 两种处理器我们结合客户端和服务端的数据收发流程来理解 Netty 的这两个概念。 客户端和服务端都有各自的 ChannelPipeline。 以客户端为例数据从客户端发向服务端该过程称为出站反之则称为入站。 数据入站会由一系列 服务器端的InBoundHandler 处理然后再以相反方向的 服务器端的OutBoundHandler 处理后完成出站。 我们经常使用的编码 Encoder 是出站操作解码 Decoder 是入站操作。 服务端接收到客户端数据后需要先经过 Decoder 入站处理后再通过 Encoder 出站通知客户端。 所以客户端和服务端一次完整的请求应答过程可以分为4个步骤 客户端出站(编码请求数据)、 服务端入站(解码数据并执行业务逻辑)、 服务端出站(编码响应结果) 客户端入站(解码响应数据,执行业务逻辑)。 ChannelHandlerChannelHandlerContext 数据的编解码工作以及其他转换工作实际都是通过 ChannelHandler 处理的。 站在开发者的角度最需要关注的就是 ChannelHandler我们很少会直接操作 Channel都是通过 ChannelHandler 间接完成。 下图描述了 Channel 与 ChannelPipeline 的关系从图中可以看出每创建一个 Channel 都会绑定一个新的 ChannelPipelineChannelPipeline 中每加入一个 ChannelHandler ,ChannelHandler都会绑定一个 ChannelHandlerContext。 ChannelPipeline、ChannelHandlerContext、ChannelHandler 三个组件的关系是密切相关的那么你一定会有疑问每个 ChannelHandler 绑定ChannelHandlerContext 的作用是什么呢 ChannelHandlerContext 用于保存 ChannelHandler 上下文通过 ChannelHandlerContext 我们可以知道 ChannelPipeline 和 ChannelHandler 的关联关系。 ChannelHandlerContext 可以实现 ChannelHandler 之间的交互ChannelHandlerContext 包含了 ChannelHandler 生命周期的所有事件如 connect、bind、read、flush、write、close 等。 ChannelHandler 中又持有ChannelPipeline 。 此外你可以试想这样一个场景。 如果每个 ChannelHandler 都有一些通用的逻辑需要实现没有 ChannelHandlerContext 这层模型抽象你是不是需要写很多相同的代码呢 每个新建的 Channel 会绑定一个新的ChannelPipeline每一个 ChannelPipeline 都包含多个 ChannelHandlerContext所有 ChannelHandlerContext 之间组成了双向链表。 又因为每个 ChannelHandler 都对应一个 ChannelHandlerContext所以实际上 ChannelPipeline 维护的是它与 ChannelHandlerContext 的关系。 以上便是 Netty 的逻辑处理架构可以看出 Netty 的架构分层设计得非常合理屏蔽了底层 NIO 以及框架层的实现细节对于业务开发者来说只需要关注业务逻辑的编排和实现即可。 组件关系梳理 当你了解每个 Netty 核心组件的概念后。你会好奇这些组件之间如何协作结合客户端和服务端的交互流程我画了一张图为你完整地梳理一遍 Netty 内部逻辑的流转。 Netty整体流程 java 服务端 启动初始化时有 Boss EventLoopGroup 和 Worker EventLoopGroup 两个组件其中 Boss-EventLoopGroup负责监听网络连接事件。当有新的网络连接事件到达时则创建Channel并将 Channel 注册到 Worker-EventLoopGroup。 Worker-EventLoopGroup 会被分配一个 EventLoop 负责处理该 Channel 的读写事件。每个 EventLoop 都是单线程的通过 Selector 进行事件循环。每一个 nioeventloop 的 selector 对应的是同一个对象这两个对象是一一对应的。 当客户端发起 I/O 读写事件时会通过selector绑定EventLoop , 服务端 EventLoop 会进行数据的读取然后通过 Pipeline 触发各种监听器进行数据的加工处理。 客户端数据会被传递到 ChannelPipeline 的第一个 ChannelInboundHandler 中数据处理完成后将加工完成的数据传递给下一个 ChannelInboundHandler。 当数据写回客户端时会将处理结果在 ChannelPipeline 的 ChannelOutboundHandler 中传播最后到达客户端。 以上便是 Netty 各个组件的整体交互流程你只需要对每个组件的工作职责有所了解心中可以串成一条流水线即可具体每个组件的实现原理后续我们会深入介绍。 视频学习链接:https://www.bilibili.com/video/BV19g4y1H7iy?p3vd_source2fe0aba0a7e0c99e9d0d910556f2b12f
