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

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

在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 回帖 • 24 关注
  • 继承
    6 引用 • 17 回帖
  • channel
    2 引用

相关帖子

欢迎来到这里!

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

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

推荐标签 标签

  • 职场

    找到自己的位置,萌新烦恼少。

    127 引用 • 1706 回帖
  • MyBatis

    MyBatis 本是 Apache 软件基金会 的一个开源项目 iBatis,2010 年这个项目由 Apache 软件基金会迁移到了 google code,并且改名为 MyBatis ,2013 年 11 月再次迁移到了 GitHub。

    170 引用 • 414 回帖 • 387 关注
  • InfluxDB

    InfluxDB 是一个开源的没有外部依赖的时间序列数据库。适用于记录度量,事件及实时分析。

    2 引用 • 76 关注
  • C

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

    85 引用 • 165 回帖 • 2 关注
  • ReactiveX

    ReactiveX 是一个专注于异步编程与控制可观察数据(或者事件)流的 API。它组合了观察者模式,迭代器模式和函数式编程的优秀思想。

    1 引用 • 2 回帖 • 161 关注
  • Windows

    Microsoft Windows 是美国微软公司研发的一套操作系统,它问世于 1985 年,起初仅仅是 Microsoft-DOS 模拟环境,后续的系统版本由于微软不断的更新升级,不但易用,也慢慢的成为家家户户人们最喜爱的操作系统。

    223 引用 • 474 回帖
  • Notion

    Notion - The all-in-one workspace for your notes, tasks, wikis, and databases.

    7 引用 • 40 回帖
  • 安装

    你若安好,便是晴天。

    132 引用 • 1184 回帖 • 1 关注
  • Dubbo

    Dubbo 是一个分布式服务框架,致力于提供高性能和透明化的 RPC 远程服务调用方案,是 [阿里巴巴] SOA 服务化治理方案的核心框架,每天为 2,000+ 个服务提供 3,000,000,000+ 次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点。

    60 引用 • 82 回帖 • 604 关注
  • frp

    frp 是一个可用于内网穿透的高性能的反向代理应用,支持 TCP、UDP、 HTTP 和 HTTPS 协议。

    20 引用 • 7 回帖 • 2 关注
  • 思源笔记

    思源笔记是一款隐私优先的个人知识管理系统,支持完全离线使用,同时也支持端到端加密同步。

    融合块、大纲和双向链接,重构你的思维。

    23003 引用 • 92509 回帖 • 2 关注
  • Webswing

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

    1 引用 • 15 回帖 • 637 关注
  • Swift

    Swift 是苹果于 2014 年 WWDC(苹果开发者大会)发布的开发语言,可与 Objective-C 共同运行于 Mac OS 和 iOS 平台,用于搭建基于苹果平台的应用程序。

    36 引用 • 37 回帖 • 535 关注
  • Q&A

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

    8442 引用 • 38442 回帖 • 154 关注
  • LeetCode

    LeetCode(力扣)是一个全球极客挚爱的高质量技术成长平台,想要学习和提升专业能力从这里开始,充足技术干货等你来啃,轻松拿下 Dream Offer!

    209 引用 • 72 回帖
  • 笔记

    好记性不如烂笔头。

    308 引用 • 793 回帖
  • 生活

    生活是指人类生存过程中的各项活动的总和,范畴较广,一般指为幸福的意义而存在。生活实际上是对人生的一种诠释。生活包括人类在社会中与自己息息相关的日常活动和心理影射。

    230 引用 • 1454 回帖
  • Tomcat

    Tomcat 最早是由 Sun Microsystems 开发的一个 Servlet 容器,在 1999 年被捐献给 ASF(Apache Software Foundation),隶属于 Jakarta 项目,现在已经独立为一个顶级项目。Tomcat 主要实现了 JavaEE 中的 Servlet、JSP 规范,同时也提供 HTTP 服务,是市场上非常流行的 Java Web 容器。

    162 引用 • 529 回帖 • 5 关注
  • BND

    BND(Baidu Netdisk Downloader)是一款图形界面的百度网盘不限速下载器,支持 Windows、Linux 和 Mac,详细介绍请看这里

    107 引用 • 1281 回帖 • 34 关注
  • 禅道

    禅道是一款国产的开源项目管理软件,她的核心管理思想基于敏捷方法 scrum,内置了产品管理和项目管理,同时又根据国内研发现状补充了测试管理、计划管理、发布管理、文档管理、事务管理等功能,在一个软件中就可以将软件研发中的需求、任务、bug、用例、计划、发布等要素有序的跟踪管理起来,完整地覆盖了项目管理的核心流程。

    5 引用 • 15 回帖 • 102 关注
  • Android

    Android 是一种以 Linux 为基础的开放源码操作系统,主要使用于便携设备。2005 年由 Google 收购注资,并拉拢多家制造商组成开放手机联盟开发改良,逐渐扩展到到平板电脑及其他领域上。

    334 引用 • 323 回帖 • 3 关注
  • 面试

    面试造航母,上班拧螺丝。多面试,少加班。

    325 引用 • 1395 回帖
  • Vditor

    Vditor 是一款浏览器端的 Markdown 编辑器,支持所见即所得、即时渲染(类似 Typora)和分屏预览模式。它使用 TypeScript 实现,支持原生 JavaScript、Vue、React 和 Angular。

    354 引用 • 1823 回帖 • 1 关注
  • 又拍云

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

    21 引用 • 37 回帖 • 548 关注
  • ngrok

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

    7 引用 • 63 回帖 • 627 关注
  • 自由行
    4 关注
  • 京东

    京东是中国最大的自营式电商企业,2015 年第一季度在中国自营式 B2C 电商市场的占有率为 56.3%。2014 年 5 月,京东在美国纳斯达克证券交易所正式挂牌上市(股票代码:JD),是中国第一个成功赴美上市的大型综合型电商平台,与腾讯、百度等中国互联网巨头共同跻身全球前十大互联网公司排行榜。

    14 引用 • 102 回帖 • 354 关注