`
huangxx
  • 浏览: 322690 次
  • 来自: ...
社区版块
存档分类
最新评论

反应器(Reactor):用于事件多路分离和分派的体系结构模式

阅读更多
    通常的,对一个文件描述符指定的文件或设备, 有两种工作方式: 阻塞与非阻塞。所谓阻塞方式的意思是指, 当试图对该文件描述符进行读写时, 如果当时没有东西可读,或者暂时不可写, 程序就进入等待状态, 直到有东西可读或者可写为止。而对于非阻塞状态, 如果没有东西可读, 或者不可写, 读写函数马上返回, 而不会等待。 

    在前面的章节中提到的Tcp通信的例子中,就是采用的阻塞式的工作方式:当接收tcp数据时,如果远端没有数据可以读,则会一直阻塞到读到需要的数据为止。这种方式的传输和传统的被动方法的调用类似,非常直观,并且简单有效,但是同样也存在一个效率问题,如果你是开发一个面对着数千个连接的服务器程序,对每一个客户端都采用阻塞的方式通信,如果存在某个非常耗时的读写操作时,其它的客户端通信将无法响应,效率非常低下。 

    一种常用做法是:每建立一个Socket连接时,同时创建一个新线程对该Socket进行单独通信(采用阻塞的方式通信)。这种方式具有很高的响应速度,并且控制起来也很简单,在连接数较少的时候非常有效,但是如果对每一个连接都产生一个线程的无疑是对系统资源的一种浪费,如果连接数较多将会出现资源不足的情况。 

    另一种较高效的做法是:服务器端保存一个Socket连接列表,然后对这个列表进行轮询,如果发现某个Socket端口上有数据可读时(读就绪),则调用该socket连接的相应读操作;如果发现某个Socket端口上有数据可写时(写就绪),则调用该socket连接的相应写操作;如果某个端口的Socket连接已经中断,则调用相应的析构方法关闭该端口。这样能充分利用服务器资源,效率得到了很大提高。

 

     系统I/O方式可分为阻塞,非阻塞同步和非阻塞异步三类,三种方式中,非阻塞异步模式的扩展性和性能最好。主要是讲了两种IO多路复用模式:Reactor和Proactor,并对它们进行了比较。

两种I/O多路复用模式:Reactor和Proactor

     一般地,I/O多路复用机制都依赖于一个事件多路分离器(Event Demultiplexer)。分离器对象可将来自事件源的I/O事件分离出来,并分发到对应的read/write事件处理器(Event Handler)。开发人员预先注册需要处理的事件及其事件处理器(或回调函数);事件分离器负责将请求事件传递给事件处理器。两个与事件分离器有关的模式是Reactor和Proactor。Reactor模式采用同步IO,而Proactor采用异步IO。

      在Reactor中,事件分离器负责等待文件描述符或socket为读写操作准备就绪,然后将就绪事件传递给对应的处理器,最后由处理器负责完成实际的读写工作。

      而在Proactor模式中,处理器--或者兼任处理器的事件分离器,只负责发起异步读写操作。IO操作本身由操作系统来完成。传递给操作系统的参数需要包括用户定义的数据缓冲区地址和数据大小,操作系统才能从中得到写出操作所需数据,或写入从socket读到的数据。事件分离器捕获IO操作完成事件,然后将事件传递给对应处理器。比如,在windows上,处理器发起一个异步IO操作,再由事件分离器等待IOCompletion事件。典型的异步模式实现,都建立在操作系统支持异步API的基础之上,我们将这种实现称为“系统级”异步或“真”异步,因为应用程序完全依赖操作系统执行真正的IO工作。

 举个例子,将有助于理解Reactor与Proactor二者的差异,以读操作为例(类操作类似)。
 在Reactor中实现读:
 - 注册读就绪事件和相应的事件处理器
 - 事件分离器等待事件
 - 事件到来,激活分离器,分离器调用事件对应的处理器。
 - 事件处理器完成实际的读操作,处理读到的数据,注册新的事件,然后返还控制权。


 与如下Proactor(真异步)中的读过程比较:
 - 处理器发起异步读操作(注意:操作系统必须支持异步IO)。在这种情况下,处理器无视IO就绪事件,它关注的是完成事件。
 - 事件分离器等待操作完成事件
 - 在分离器等待过程中,操作系统利用并行的内核线程执行实际的读操作,并将结果数据存入用户自定义缓冲区,最后通知事件分离器读操作完成。
 - 事件分离器呼唤处理器。
 - 事件处理器处理用户自定义缓冲区中的数据,然后启动一个新的异步操作,并将控制权返回事件分离器。
  

 Java NIO非堵塞应用通常适用用在I/O读写等方面,我们知道,系统运行的性能瓶颈通常在I/O读写,包括对端口和文件的操作上,过去,在打开一个I/O通道后,read()将一直等待在端口一边读取字节内容,如果没有内容进来,read()也是傻傻的等,这会影响我们程序继续做其他事情,那么改进做法就是开设线程,让线程去等待,但是这样做也是相当耗费资源的。

Java NIO非堵塞技术实际是采取Reactor模式,或者说是Observer模式为我们监察I/O端口,如果有内容进来,会自动通知我们,这样,我们就不必开启多个线程死等,从外界看,实现了流畅的I/O读写,不堵塞了。

Java NIO出现不只是一个技术性能的提高,你会发现网络上到处在介绍它,因为它具有里程碑意义,从JDK1.4开始,Java开始提高性能相关的功能,从而使得Java在底层或者并行分布式计算等操作上已经可以和C或Perl等语言并驾齐驱。


NIO主要原理和适用。

NIO 有一个主要的类Selector,这个类似一个观察者,只要我们把需要探知的socketchannel告诉Selector,我们接着做别的事情,当有事件发生时,他会通知我们,传回一组SelectionKey,我们读取这些Key,就会获得我们刚刚注册过的socketchannel,然后,我们从这个Channel中读取数据,放心,包准能够读到,接着我们可以处理这些数据。

Selector内部原理实际是在做一个对所注册的channel的轮询访问,不断的轮询(目前就这一个算法),一旦轮询到一个channel有所注册的事情发生,比如数据来了,他就会站起来报告,交出一把钥匙,让我们通过这把钥匙来读取这个channel的内容。


模式参见 http://www.jdon.com/concurrent/reactor.htm

 

分享到:
评论

相关推荐

    ACE技术论文集(已翻译为中文)

    第 7 章 ACE 反应器(Reactor)的设计和使用:用于事件多路分离的面向对象框架 第 8 章 前摄器(Proactor):用于为异步事件多路分离和分派处理器的对象行为模式 第 9 章 接受器-连接器(Acceptor-Connector):...

    ACE反应器(Reactor)模式的深入分析

    反应器(Reactor):用于事件多路分离和分派的体系结构模式通常的,对一个文件描述符指定的文件或设备, 有两种工作方式: 阻塞与非阻塞。所谓阻塞方式的意思是指, 当试图对该文件描述符进行读写时, 如果当时没有东西...

    ACE Reactor服务端简单范例

    `ACE_Reactor::handle_input()`、`handle_output()`和`handle_exception()`方法用于处理读、写和异常事件。 **四、服务器端实现** 在"Reactor_Server"这个文件中,我们可以预期包含以下关键步骤: 1. 创建`ACE_...

    基于Java NIO反应器模式设计与实现

    在反应器模式中,有一个或多个输入源(例如,连接、数据流)和相应的事件处理器,这些事件处理器将输入源产生的事件进行分派和处理。 Java NIO的反应器模式设计与实现,首先涉及到理解Java NIO的基本概念,如通道...

    ObjectArx永久反应器(加入到模型空间)例子

    总的来说,"ObjectArx永久反应器(加入到模型空间)例子"是学习ObjectArx API和AutoCAD事件处理机制的一个实用案例。通过这个例子,开发者可以学习如何创建和管理反应器,以及如何在模型空间中实现动态交互效果,这...

    Reactor模式和NIO

    主要用于解决高并发场景下的系统设计问题,而Java的NIO(Non-blocking Input/Output,非阻塞I/O)是Java平台提供的一种I/O模型,它支持基于事件的多路复用,为实现Reactor模式提供了基础。 Reactor模式的核心思想是...

    tpd_reactor_proactor.pdf

    Reactor 和 Proactor 模式是两种常见的事件处理模式,在网络编程中广泛应用于设计高效、可靠的并发和网络应用程序。在本文中,我们将详细介绍 Reactor 和 Proactor 模式的概念、特点、优缺点,以及在网络编程中的...

    一个windows下基于select多路分离器的Reactor模型

    2.该Reactor模型不排除在同一个socket上投递多个eventhandler.一个eventhandler只针对一个socket事件处理(可读,可写.当然事件可以用掩码,本例没有采用这种做法.) 3.采用VS2005编译.工程携带了一个测试server和一个...

    20120815_Reactor模式及在DSS中的体现1

    在操作系统层面,Reactor模式通常与操作系统提供的I/O多路复用器结合使用。例如,在Linux上,可以选择select、poll或epoll等系统调用作为事件分离器,它们能在一组句柄(如文件描述符或Socket句柄)上等待事件的发生...

    reactor-siemens.pdf

    - **处理流程:** 日志服务器使用Reactor模式处理这些请求,其中事件处理器专门用于处理连接请求和日志记录。 **具体实现:** - **初始化调度器:** 管理连接请求和日志记录的事件处理器。 - **同步事件分派器:** ...

    reactor模式源码

    2. **Event Handler**:事件处理器接口,用于定义具体的事件处理逻辑。每个I/O事件源都有对应的事件处理器,当Reacttor接收到事件后,会将事件传递给对应的处理器进行处理。 3. **Event Demuxer(事件分离器)**:...

    Reactor反应器的实现方法详解

    大多数应用都会使用ACE_Reactor::instance()提供的默认反应器实例。但是你也可以选择自己的反应器,这是因为ACE使用了Bridge模式(使用两个不同的类:一个是编程接口,另一个是实现,第一个类会把各个操作传给第二个...

    Reactor Pattern (一)

    3. **解耦合**:事件处理与事件分发分离,有利于代码的维护和扩展。 **ReactorPattern.java文件可能包含的内容:** 这个文件可能是Reactor模式的一个简单实现,包括了Reactor类、Handler接口和具体处理器类。代码...

    Reactor:Linux上由C ++ 11实现的Reactor实现

    4. **Reactor本身**:作为核心调度器,它管理事件多路复用器和事件处理器,接收事件并进行分发。 在Linux环境下,我们可以利用epoll作为事件多路复用器。epoll的优点在于其高性能和可扩展性,能处理大量并发连接。...

    ace_reactor:王牌React堆服务器

    Ace是AT&T实验室开发的一个跨平台、事件驱动的C++网络编程框架,而Ace Reactor是其核心组件,用于处理异步事件和网络I/O。在本文中,我们将深入探讨Ace Reactor的原理、功能以及如何与HTML结合使用。 Ace Reactor的...

    Observer and Reactor 观察者和recator的比较

    "Observer(观察者)"和"Reactor(反应器)"是两种广泛应用于并发和事件驱动编程的设计模式。 Observer模式的核心在于定义了一对多的依赖关系,当一个对象(主题)的状态发生改变时,所有依赖于它的对象都会被自动...

    reactor(翻译)1

    Reactor模式的设计使得服务的扩展和改进变得简单,因为服务的具体实现与通用的事件多路分解和调度机制是分离的。这意味着添加新服务或优化现有服务时,只需要修改特定的事件处理程序,而不必改动整个系统架构。此外...

Global site tag (gtag.js) - Google Analytics