Netty快速入门(10)Reactor与Netty

Reactor模式

Reactor是1995年由道格拉斯提出的一种高性能网络编程模式。由于好多年了,当时的一些概念与现在略有不同,reactor模式在网络编程中是非常重要的,可以说是NIO框架的典型模式,一些经典的框架,比如Mina、Netty、Cindy都是此模式的实现。

我们来看看当年提出的通用模型:

上面的图形中:

1、Handle 可以理解为资源或者文件句柄,放在netty里面就是channel,就是我们实际要处理的东西

2、Event Handler和Concrete Event Handler 就是具体的事件处理器,对应netty中的handler接口和具体的handler

3、Synchronous Event Demultiplexer同步事件多路复用分发器,可以理解为nio中的select

4、Initiation Dispatcher,分发器,可以理解为nio中的循环,也就是netty中的EventLoop,处理各种事件

5、select(handlers)就是真正处理业务的地方

大家注意上面图形中的几个箭头,可以看出各个组件之间的关联关系。这个经典的模型当时并不是针对Java提出的,任何拥有这些组件的语言,都可以实现高性能的reactor模型。




单线程Reactor

基于Java,Doug Lea(Java并发包作者)提出了三种形式,单线程Reactor,多线程Reactor和Multiple Reactor。首先看一下基本的单线程模式:

单线程模型就是一个reactor(select+循环),客户端(client)注册进来由reactor接收注册事件,然后再由reactor分发(dispatch)出去,由下面的处理器(read、decode、compute等)去处理。我们前面复习nio代码的时候,程序就是这样的结构,只有一个select。





多线程Reactor

单线程的Reactor有明显的不足,只有一个线程,又要接收连接,又要处理io读写,还要处理计算和业务逻辑,如果是io密集型还行,如果是计算密集型效率会很慢。现在的机器都是多核的,只用一个线程也浪费机器资源,无法充分利用机器。多线程Reactor能解决这个问题,来看一下多线程Reactor模型:

在多线程Reactor中,注册接收事件都是由Reactor来做,其它的计算,编解码由一个线程池来做。单独一个线程接收请求,另一个线程池处理其它业务。这种模型的问题就是,使用线程池处理的时候,很多地方会有多次线程切换,上下文切换,导致效率比较低,有很多问题要处理,甚至光是接收和读写等请求一个线程也可能忙不过来,因此有了第三种模式,就是Multiple Reactor。





Multiple Reactor

这种模式特点是有多个Reactor,一个boss Reactor负责接收,另外几个worker  Reactor负责读写,把业务部分的处理还是放到线程池中来做。我们前面讨论的netty示例代码其实就是这样的模型:

netty中的handler默认没有启用线程池,如果我们定义用线程池去处理,那么就和上面的模型几乎一模一样了。上面的三种Reactor模式就是最基本的Java的三种Reactor模式。


网上关于Reactor的内容有很多,分的类型也更细一些,扩展了很多其它的形式,针对具体的场景有一些更加详细的模式,比如下面的主从Reactor模式:

在主从Reactor模式中,再次对Reactor进行细分,有一个主要的Reactor进行接收,里面可以做一些认证登录之类的事情,完了之后再分配到Sub Reactor下面去,再做具体的IO处理。

网上关于Reactor模型有很多,但是Java经典的三种最基本的一定要了解清楚,我们设计自己的架构的时候,不要被网上过多的五花八门的模型扰乱,从基本模型触发就可以。





Netty支持的Reactor形式

netty其实对三种Java基本的Reactor模式都是支持的。我们前面演示过,netty启动时,要在ServerBootstrap中配置bossGroup和childGroup两个EventLoopGroup,也就是说netty是可以灵活配置的。我们通过配置可以让netty分别实现对三种模式的支持。

先看一下对单线程reactor的配置:

在配置的时候,boss和worker两个group配置成一个,也就是说两个group的工作交给一个bossGroup(线程数为1)来完成。这样实际上就是第一个单线程reactor的模型。上面的代码就是对第一种模式的支持。

再来看一下对第二种多线程reactor模式的支持,其实第二种模式和第一种代码的配置是一样的,只是在handler中进行处理的时候,使用一个线程池处理所有业务,这样就是第二种多线程的reactor模式。

第三种Multiple Reactor模式是我们用的最多的模式,也是前面例子演示中的配置形式。boss为单线程,worker为多线程,在ServerBootstrap中同时配置boss和worker,下面是我们熟悉的代码:

EventLoopGroup如果没有配置线程数量,默认创建cpu个数的两倍,所以上面worker的线程数根据机器决定。但是现在如果要严格对应第三种模式,在handler中,还要加上线程池。如果计算不太复杂,一个workerGroup就可以了,如果需要很复杂的计算,建议在handler中加入线程池进行处理。尽量不要让IO线程池阻塞。 


在很多netty项目中,还有这样的写法:

boss和worker中的线程数都是多个,这种配置并没有对应前面提过的任何一种模式,那么会有这种需要使用多个boss线程的情况吗?我们知道accept只能保存到一个线程上,所以说bossGroup配置多个是没有用的,所以也有人问netty框架的作者,这种什么时候会用到,下面是作者的回答:

大致是说,这种配置不是必须的,但是它可能会非常有用,比如当多个ServerBootstrap共享一个NioEventLoopGroup的时候会非常有用,意思就是,每个ServerBootstrap都要注册一个NioServerSocketChannel,如图:

如果多个ServerBootstrap都使用一个bossGroup,这时候bossGroup初始化为1个线程,就意味着一个线程监听多个端口,这样显然不太好,这时候bossGroup就可以配置成多个,这样可以每个端口由一个线程去监听,提高效率。

但是,上面是想象中的使用情况,我们实际开发netty的时候,几乎没有看到有多个ServerBootstrap的情况,所以bossGroup配置成多个在现在看来几乎是没有用的,我们把bossGroup的参数直接写成1就可以。即使写成了8,实际执行的时候,也只会用到一个线程,ServerBootstrap只会使用一个,不会使用多个。


关于主从reactor模式,从目前netty看没有办法通过配置直接实现。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,539评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,911评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,337评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,723评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,795评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,762评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,742评论 3 416
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,508评论 0 271
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,954评论 1 308
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,247评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,404评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,104评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,736评论 3 324
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,352评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,557评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,371评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,292评论 2 352

推荐阅读更多精彩内容