文章目录

  • Reactor模式介绍
    • 什么是Reactor模式 ?
    • 为什么使用Reactor模式 ?
    • Reactor模式的演进过程
    • 单Reactor单线程
    • 单Reactor多线程
    • 多Reactor多线程
    • 在Netty中的应用

Reactor模式介绍

什么是Reactor模式 ?

Reactor模式一般翻译为反应器模式,也有人称为分发者模式。它是将客户端请求

提交到一个或者多个服务处理程序的设计模式。工作原理是由一个线程来接收所有请求,

然后派发这些请求到相关的工作线程中。

为什么使用Reactor模式 ?

在Java中,没有NIO出现之前都是使用socket编程。socket的接收请求是阻塞的,需要处理完一个请求才能处理下一个请求,所以在面对高并发的请求时,性能就会很差。

那有人会说使用多线程接收到一个请求,就创建一个线程处理,这样就不会阻塞了。实际上这样确实可以在提示性能上起到一定的作用,但是当请求很多的时候,就会创建大量的线程,维护线程需要资源的消耗,线程之间的切换也需要消耗性能。而且系统创建线程的数量也是有限的,所以当高并发时,会直接把系统拖垮。

由于以上的问题,提出了Reactor模式

基于Java,DougLea(Java并发包)提出了三种形式,单Reactor单线程,单Reactor多线程和多Reactor多线程。

Reactor模式的演进过程

Reactor: 负责响应事件,将事件分发到绑定了对应事件的Handler,如果是连接事件,则分发到Acceptor。

Handler: 事件处理器,负责执行对应事件对应的业务逻辑。

Acceptor: 绑定了connect事件,当客户端发起connect请求时,Reactor会将accept事件分发给Acceptor处理。

单Reactor单线程

工作流程

只有一个select循环接收请求,客户端(client)注册进来由Reactor接收注册事件,

然后再由reactor分发(dispatch)出去,由下面的处理器(Handler)去处理。

通俗解释

一个餐厅里只有一个既是前台也是服务员的人,负责接待客人,也负责把客人点的菜下达给厨师。

特点

单线程的问题非常明显。只要其中一个Handler方法阻塞了,那就会导致所有的client的Handelr都被阻塞了,也会导致注册事件也无法处理,无法接收新的请求。所以这种模式用的比较少,因为不能充分利用带多核的资源。

这种模式仅仅只能处理Handler比较快速完成的场景。

单Reactor多线程

工作流程

在多线程Reactor中,注册接收事件都是由Reactor来做,其它的计算,编解码由一个线程池

来做。从图中可以看出工作线程是多线程,监听注册事件的Reactor还是单线程。

通俗解释

相当于餐厅里有一个前台,多个服务员。前台负责接待客人,服务员只负责服务客人。

特点

对比单线程Reactor模型,多线程Reactor模式在Handler读写处理时,交给工作线程池处理。不会导致Reactor无法执行,因为Reactor分发和Handler处理时分开的,能充分利用资源。从而提升性能。

缺点: Reactor只在主线程运行,承担所有事件的监听和响应,如果短时间的高并发场景下,依然会造成性能瓶颈。

多Reactor多线程


工作流程

mainReactor负责监听客户端请求,专门处理新连接的建立,将建立好的连接注册到subReactor。

subReactor将分配的连接加入到队列进行监听,当有新的事件发生时,会调用连接相

对应的Handler进行处理。

通俗解释

相当于餐厅里多个前台和多个服务员,前台负责接待客人,服务员只负责服务客人。

特点

mainReactor主要是用于处理客户端请求连接建立的操作。subReactor主要做和建立起来的连接做数据交互和事件业务处理操作,每个subReactor一个线程来处理。

这样的模型使得每个模块更加专一,耦合度更低,能支持更高的并发量。许多框架也使用这种模式,例如Netty。

在Netty中的应用

这个架构实际上跟多Reactor多线程模型很像。

  • BossGroup相当于mainReactor,负责建立连接并且把连接注册到WorkGroup中。

WorkGroup负责处理连接对应的读写事件。

  • BossGroup和WorkGroup是两个线程池,里面有多个BioEventGroup(实际上是线程),默认BossGroup和WorkGroup里的线程数是cpu核数的两倍。

  • 每个NioEventGroup都是一个无限循环,负责监听相对应的事件。

  • Pipeline(通道)里包含多个ChannelHandler(业务处理),按顺序执行。

认BossGroup和WorkGroup里的线程数是cpu核数的两倍。

  • 每个NioEventGroup都是一个无限循环,负责监听相对应的事件。

  • Pipeline(通道)里包含多个ChannelHandler(业务处理),按顺序执行。

Reactor模式!相关推荐

  1. Reactor模式与Proactor模式

    博主一脚刚踏进分布式的大门(看<分布式Java应用>,如果大家有啥推荐的书欢迎留言~),发现书中对NIO采用的Reactor模式.AIO采用的Proactor模式一笔带过,好奇心趋势我找了 ...

  2. 高性能IO设计中的Reactor模式与Proactor模式

    为什么80%的码农都做不了架构师?>>>    在高性能的IO设计中,有两个比较著名的模式Reactor和Proactor模式,其中Reactor模式用于同步I/O,而Proacto ...

  3. 高性能IO之Reactor模式

    讲到高性能IO绕不开Reactor模式,它是大多数IO相关组件如Netty.Redis在使用的IO模式,为什么需要这种模式,它是如何设计来解决高性能并发的呢? 最最原始的网络编程思路就是服务器用一个w ...

  4. swing的gui是通过何种模式进行事件响应与监听_【Vert.x准备篇2】C10K问题与Reactor模式...

    C10K问题是1999年一个叫Dan Kegel的美国人提出的概念,其中C为concurrently, 10K指的是1万个网络连接, 结合起来意为如何能够做到并发处理1万个连接. 这里首先要澄清一下, ...

  5. 高性能IO -Reactor模式的实现

    2019独角兽企业重金招聘Python工程师标准>>> 在了解Reactor模式之前, 首先了解什么是NIO. java.nio全称java non-blocking IO 即非阻塞 ...

  6. 【Netty】反应器 Reactor 模式 ( 单反应器 Reactor 单线程 | 单反应器 Reactor 多线程 )

    文章目录 一. 反应器 ( Reactor ) 模式 二. 反应器 ( Reactor ) 模式两大组件 三. 单反应器 ( Reactor ) 单线程 四. 单反应器 ( Reactor ) 单线程 ...

  7. 【Netty】Netty 简介 ( 原生 NIO 弊端 | Netty 框架 | Netty 版本 | 线程模型 | 线程 阻塞 IO 模型 | Reactor 模式引入 )

    文章目录 一. NIO 原生 API 弊端 二. Netty 简介 三. Netty 架构 四. Netty 版本 五. Netty 线程模型 六. 阻塞 IO 线程模型 七. 反应器 ( React ...

  8. Java进阶(五)Java I/O模型从BIO到NIO和Reactor模式

    本文介绍了Java中的四种I/O模型,同步阻塞,同步非阻塞,多路复用,异步阻塞.同时将NIO和BIO进行了对比,并详细分析了基于NIO的Reactor模式,包括经典单线程模型以及多线程模式和多Reac ...

  9. libevent之Reactor模式详解

    转自:http://blog.csdn.net/sparkliang/article/details/4957667 前面讲到,整个libevent本身就是一个Reactor,因此本节将专门对Reac ...

  10. ACE - Reactor模式源码剖析及具体实现(大量源码慎入)

    原文出自http://www.cnblogs.com/binchen-china,禁止转载. 在之前的文章中提到过Reactor模式和Preactor模式,现在利用ACE的Reactor来实现一个基于 ...

最新文章

  1. python经典例题图形_Python 入门经典100实例:实例23 菱形
  2. Android常用控件之Fragment仿Android4.0设置界面
  3. 超级可靠、超低成本——BCH的雄心
  4. 【观点】开发人员的测试悖论
  5. android html 换行_Android中Strings资源加空格,换行符,@等方法示例
  6. learnpython_LearnPython_week1
  7. 说说 Spring AOP 原理
  8. c#语言 修改xml文件路径,C#对XML操作:编辑XML文件内容-.NET教程,C#语言
  9. 谈判如何在谈判中_如何避免通过工资谈判把钱留在桌上
  10. r语言导入ggplot2_R语言教程:数据结构+导入数据!
  11. Objective-C 的 self 和 super 详解
  12. 一学就会之ado.net(一)
  13. subclipse同步冲突问题A conflict in the working copy obstructs the current operation
  14. python中iter方法_Python中的迭代器(iter())函数。
  15. python回文字符串编程_P086 回文字符串
  16. Excel Pearson相关系数
  17. SGX 是什么技术?
  18. 【R语言】高维数据可视化| ggplot2中会“分身术”的facet_wrap()与facet_grid()姐妹花
  19. HTML表格竖边框线,Table表格横竖线实现Css
  20. 【内网安全】——数据库提权姿势

热门文章

  1. 印象笔记不能同步(其他浏览器可以上网,IE不能上网)
  2. Linux 开起启动Supervisor 安装配置
  3. office 打开wps乱_wps文档用word打开排版不对怎么办
  4. c语言如何比较字符串的大小
  5. 【Java实现链表操作】 万字肝爆 !链表的图文解析(包含链表OJ练习解析)
  6. 判断链表是否为【回文结构】
  7. 微信支付APP支付完全攻略
  8. 【附源码】计算机毕业设计java在线学习系统设计与实现
  9. 为什么心跳包(HeartBeat)是必须的?
  10. 用Python进行多元线性回归分析(附代码)