Netty源码分析之二类的分层设计

本贴最后更新于 2770 天前,其中的信息可能已经天翻地覆

在netty中,有些类的职责非常丰富,比如NioEventLoop,既是一个单线程的任务调度器(自己维护一个任务队列),也可以注册channel,同时也具备Reactor线程模型的特性,处理I/O操作;一个类怎么能同时实现具备这么多的特性?其思路就是分层化解,将某些具体相关功能集中到一个类中,各个类各司其职,通过继承或实现的方式来形成一颗类继承树,最底层的类具备的职责最多。如下图:

classdesign

总体上来说,netty是利用多线程技术和多路复用器技术实现了高并发和高性能要求下的异步网络服务器端程序的开发框架。所以在netty中,重要的关键类都需要继承自jdk提供的线程池,并且要使用多路复用器技术,也需用引入jdk的Selector。
下面我们看看netty中的类是如何分层设计的,以transport模块为例。

 

  • EventExecutorGroup

netty里面的顶级类,负责提供一个EventExecutor(事件执行器),通过next方法,返回属于该group中所有事件执行器中的一个;
负责控制EventExecutor的整个生命周期;
是一个ScheduledExecutorService类型的线程池,定时任务调度;
是一个线程池;
一个迭代器(iterator方法,返回的是所有此group拥有的EventExecutor);
是EventExecutor的容器。

  • EventExecutor

继承自EventExecutorGroup,是一个特殊的EventExecutorGroup,通过parent()方法获取所属的EventExecutorGroup;
一个事件执行器,提供inEventLoop方法查看一个线程在事件处理环中是否被执行。

  • EventLoopGroup

继承自EventExecutorGroup,可以注册channel,提供注册接口方法register;
其next方法也是继承自EventExecutorGroup,但是返回类型为EventLoop,不再是EventExecutor,而EventLoop是继承自EventExecutor,所以如果需要修改父类的接口,那么可以通过修改其返回类型的继承关系实现。

  • EventLoop

继承自EventLoopGroup和EventExecutor,是一个事件处理环(或者叫做多路复用环),将会处理某个channel的所有I/O操作,当然前提是这个channel必须在这个环上注册过,一般一个eventloop会处理多于一个channel,这个主要依赖于其实现细节。感觉这个类就是一个为了使框架完整而存在的。

  • SingleThreadEventExecutor

 EventExecutor的抽象基类实现,用单线程方式执行所有提交的任务,自身维护一个任务队列。关于该任务队列的公共操作都抽取在该类中完成。需要子类完成的通过抽象方法实现。公共操作具体包括有:

execute()方法中,往队列中添加task
构造方法中,实现一个队列,存放task;其子类可以自定义该队列类型,覆盖newTaskQueue()
abstract run(),给继承类自己实现,负责运行具体task
  • SingleThreadEventLoop

继承自SingleThreadEventExecutor和EventLoop,以单线程方式执行所有提交的任务,该类是一个功能集的体现。

  • MultithreadEventExecutorGroup

直接继承自AbstractEventExecutorGroup(该类的目的其实就是为了避免某个接口其下的实现类实现过多不必要的方法而存在的),间接继承自EventExecutorGroup,其功能还不是很复杂,只是一个事件执行器的容器;
用多线程方式同时处理任务,其内部包括一个EventExecutor的数组,所有的事件执行器都存在该数组中(对于这种事件执行器的容器,其具体容器的选择由各个实现类自己决定),事件执行器就是SingleThreadEventExecutor。

  • NioEventLoopGroup

MultithreadEventExecutorGroup的间接实现类,会调用其包含的事件执行器进行操作,专注于NIO的Selector等公共操作抽取出来。

  • NioEventLoop

继承自SingleThreadEventLoop,功能集。
一个多路复用器操作类,用于轮询其上注册的所有channel。

从这个图上可以看出,抽象的公共集放置在顶端,其下的每个节点都具有各自特定的功能,而越往下,节点具有的功能集越多。
我们可以总结一些特点:

  • 抽取出公共功能放在顶端
  • 需要重写的使用抽象方法由具体实现类去实现
  • 将复杂的功能类进行分解,可以按照功能点来分解,由不同的类来负责单一职责,职责类之间可以关联,但是关系不能太复杂
  • 具有多功能的类通过继承单一职责类的方式实现
  • Netty

    Netty 是一个基于 NIO 的客户端-服务器编程框架,使用 Netty 可以让你快速、简单地开发出一个可维护、高性能的网络应用,例如实现了某种协议的客户、服务端应用。

    49 引用 • 33 回帖 • 20 关注
  • 继承
    5 引用 • 17 回帖
  • channel
    2 引用

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...

推荐标签 标签

  • Logseq

    Logseq 是一个隐私优先、开源的知识库工具。

    Logseq is a joyful, open-source outliner that works on top of local plain-text Markdown and Org-mode files. Use it to write, organize and share your thoughts, keep your to-do list, and build your own digital garden.

    4 引用 • 55 回帖 • 6 关注
  • 又拍云

    又拍云是国内领先的 CDN 服务提供商,国家工信部认证通过的“可信云”,乌云众测平台认证的“安全云”,为移动时代的创业者提供新一代的 CDN 加速服务。

    21 引用 • 37 回帖 • 505 关注
  • JWT

    JWT(JSON Web Token)是一种用于双方之间传递信息的简洁的、安全的表述性声明规范。JWT 作为一个开放的标准(RFC 7519),定义了一种简洁的,自包含的方法用于通信双方之间以 JSON 的形式安全的传递信息。

    20 引用 • 15 回帖 • 18 关注
  • 博客

    记录并分享人生的经历。

    270 引用 • 2386 回帖
  • DNSPod

    DNSPod 建立于 2006 年 3 月份,是一款免费智能 DNS 产品。 DNSPod 可以为同时有电信、网通、教育网服务器的网站提供智能的解析,让电信用户访问电信的服务器,网通的用户访问网通的服务器,教育网的用户访问教育网的服务器,达到互联互通的效果。

    6 引用 • 26 回帖 • 518 关注
  • CSS

    CSS(Cascading Style Sheet)“层叠样式表”是用于控制网页样式并允许将样式信息与网页内容分离的一种标记性语言。

    180 引用 • 446 回帖 • 3 关注
  • WebComponents

    Web Components 是 W3C 定义的标准,它给了前端开发者扩展浏览器标签的能力,可以方便地定制可复用组件,更好的进行模块化开发,解放了前端开发者的生产力。

    1 引用 • 25 关注
  • wolai

    我来 wolai:不仅仅是未来的云端笔记!

    1 引用 • 11 回帖
  • C

    C 语言是一门通用计算机编程语言,应用广泛。C 语言的设计目标是提供一种能以简易的方式编译、处理低级存储器、产生少量的机器码以及不需要任何运行环境支持便能运行的编程语言。

    83 引用 • 165 回帖 • 61 关注
  • 书籍

    宋真宗赵恒曾经说过:“书中自有黄金屋,书中自有颜如玉。”

    76 引用 • 390 回帖 • 1 关注
  • JavaScript

    JavaScript 一种动态类型、弱类型、基于原型的直译式脚本语言,内置支持类型。它的解释器被称为 JavaScript 引擎,为浏览器的一部分,广泛用于客户端的脚本语言,最早是在 HTML 网页上使用,用来给 HTML 网页增加动态功能。

    710 引用 • 1173 回帖 • 193 关注
  • Chrome

    Chrome 又称 Google 浏览器,是一个由谷歌公司开发的网页浏览器。该浏览器是基于其他开源软件所编写,包括 WebKit,目标是提升稳定性、速度和安全性,并创造出简单且有效率的使用者界面。

    60 引用 • 287 回帖
  • ngrok

    ngrok 是一个反向代理,通过在公共的端点和本地运行的 Web 服务器之间建立一个安全的通道。

    7 引用 • 63 回帖 • 598 关注
  • Webswing

    Webswing 是一个能将任何 Swing 应用通过纯 HTML5 运行在浏览器中的 Web 服务器,详细介绍请看 将 Java Swing 应用变成 Web 应用

    1 引用 • 15 回帖 • 634 关注
  • RESTful

    一种软件架构设计风格而不是标准,提供了一组设计原则和约束条件,主要用于客户端和服务器交互类的软件。基于这个风格设计的软件可以更简洁,更有层次,更易于实现缓存等机制。

    30 引用 • 114 回帖 • 8 关注
  • 微服务

    微服务架构是一种架构模式,它提倡将单一应用划分成一组小的服务。服务之间互相协调,互相配合,为用户提供最终价值。每个服务运行在独立的进程中。服务于服务之间才用轻量级的通信机制互相沟通。每个服务都围绕着具体业务构建,能够被独立的部署。

    96 引用 • 155 回帖 • 1 关注
  • Q&A

    提问之前请先看《提问的智慧》,好的问题比好的答案更有价值。

    6364 引用 • 28600 回帖 • 265 关注
  • 智能合约

    智能合约(Smart contract)是一种旨在以信息化方式传播、验证或执行合同的计算机协议。智能合约允许在没有第三方的情况下进行可信交易,这些交易可追踪且不可逆转。智能合约概念于 1994 年由 Nick Szabo 首次提出。

    1 引用 • 11 回帖 • 5 关注
  • golang

    Go 语言是 Google 推出的一种全新的编程语言,可以在不损失应用程序性能的情况下降低代码的复杂性。谷歌首席软件工程师罗布派克(Rob Pike)说:我们之所以开发 Go,是因为过去 10 多年间软件开发的难度令人沮丧。Go 是谷歌 2009 发布的第二款编程语言。

    491 引用 • 1383 回帖 • 371 关注
  • Bug

    Bug 本意是指臭虫、缺陷、损坏、犯贫、窃听器、小虫等。现在人们把在程序中一些缺陷或问题统称为 bug(漏洞)。

    76 引用 • 1738 回帖 • 2 关注
  • 旅游

    希望你我能在旅途中找到人生的下一站。

    83 引用 • 894 回帖
  • SSL

    SSL(Secure Sockets Layer 安全套接层),及其继任者传输层安全(Transport Layer Security,TLS)是为网络通信提供安全及数据完整性的一种安全协议。TLS 与 SSL 在传输层对网络连接进行加密。

    69 引用 • 190 回帖 • 501 关注
  • Kafka

    Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是现代系统中许多功能的基础。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。

    35 引用 • 35 回帖
  • Maven

    Maven 是基于项目对象模型(POM)、通过一小段描述信息来管理项目的构建、报告和文档的软件项目管理工具。

    185 引用 • 318 回帖 • 353 关注
  • 阿里巴巴

    阿里巴巴网络技术有限公司(简称:阿里巴巴集团)是以曾担任英语教师的马云为首的 18 人,于 1999 年在中国杭州创立,他们相信互联网能够创造公平的竞争环境,让小企业通过创新与科技扩展业务,并在参与国内或全球市场竞争时处于更有利的位置。

    43 引用 • 221 回帖 • 254 关注
  • WebClipper

    Web Clipper 是一款浏览器剪藏扩展,它可以帮助你把网页内容剪藏到本地。

    3 引用 • 9 回帖 • 3 关注
  • Ant-Design

    Ant Design 是服务于企业级产品的设计体系,基于确定和自然的设计价值观上的模块化解决方案,让设计者和开发者专注于更好的用户体验。

    17 引用 • 23 回帖