来源：https://www.cnblogs.com/ivaneye/p/10129896.html

本文将探讨如下几个问题：

Event-Driven架构风格的约束
EDA风格对架构属性的影响
Reactor架构模式
Reactor所解决的问题
redis中的EventDriven

从观察者模式到EDA风格

GOF的23种设计模式中，有一个观察者模式！个人觉得叫「监听模式」更合理！

定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时, 所有依赖于它的对象都得到通知并被自动更新。

它和EDA风格有些类似！不过一个应用在代码关系层面；一个应用在架构上！

在EDA中，有三个必要组件：

事件生产组件：对应到观察者模式中，就是引起Subject状态变化的对象。它引起Subject状态变化的动作就是事件。
事件队列：对应到观察者模式中，就是Subject对象。事件生产者产生的事件，会到事件队列中。
事件处理组件：处理事件生产组件所产生的事件。对应到观察者模式中，就是Observer对象。

EDA风格的约束

「事件生产组件」产生事件，将其添加到「事件队列」中
「事件处理组件」监听「事件队列」
当「事件队列」中有自己能处理的事件时，「事件处理组件」将对该事件进行处理
「事件处理组件」处理完事件后，可以将处理结果返回给「事件生产组件」，也可以不返回
「事件生产组件」可以接收「事件处理组件」处理结果，也可以不接收

EDA风格可以细分为Mediator结构和Broker结构！

Mediator结构通过一个Mediator组件协调多个步骤间的关系和执行顺序
Broker结构则是通过松散的方式来组织多个步骤之间的关系和执行顺序

Mediator结构如下：

在Mediator结构中主要有四个组件：

事件队列(event queue)
事件中介(event mediator)
事件通道(event channel)
事件处理器(event processor)。

执行流程如下：

「事件生产组件」产生事件，将其添加到「事件队列」中
「事件中介」监听「事件队列」
当「事件队列」中有事件时，「事件中介」根据具体的事件，将其拆分/组合为一步步的具体步骤
将具体的步骤添加到对应的「事件通道」中
「事件处理器」从「事件通道」中获取到事件，进行处理

Broker结构如下：

Broker结构中主要包括两个组件:

Broker：Broker可被集中或相互关联在一起使用,此外,Broker中还可以包含所有事件流中使用的事件通道。
事件处理器

执行流程如下：

「事件生产组件」产生事件，将其添加到「Broker」中
「事件处理组件」监听「Broker」
当「Broker」中有自己能处理的事件时，「事件处理组件」将对该事件进行处理
「事件处理组件」处理完事件后，发送后续事件到「Broker」中
其它「事件处理组件」接收到自己能处理的事件后，对该事件进行处理，处理完后，可能继续发送事件到「Broker」中
当不再有后续事件时，所有步骤完成

EDA风格对架构属性的影响

性能：由于EDA是个异步架构，对于不需要返回值的请求，它能明显的提高用户可感知的性能。
扩展性：事件生产者和事件消费者松耦合，可以独立进化，可以方便的进行功能扩展。同时由于，可以方便的添加事件消费者，故而进一步提高了扩展性。
伸缩性：事件生产者和事件消费者松耦合及可以方便的添加事件消费者，使得EDA有很好的伸缩性
可维护性：事件生产者和事件消费者松耦合，且和一般的调用方式相比，在理解上有一定的难度，使得开发难度增加，但单元测试较方便。而由于EDA的异步性，使得集成测试比较麻烦。可维护性一般
可运维性：事件生产者和事件消费者松耦合，可独立部署，可运维性相对较容易
灵活性：高度可扩展，易于伸缩使得EDA有较高的灵活性

Reactor架构模式

Reactor架构模式，是EDA风格的一种实现！它是为了处理：

高并发IO请求
其中请求所包含的数据量不大
每个请求处理耗时不长

Reactor模型，有四个组件：

Acceptor：Acceptor接受Client连接。属于EDA「事件队列组件」。
Channel：接收IO事件。属于EDA「事件队列组件」。
Reactor：监听Channel和Acceptor，当发生连接事件或IO事件时，将其派发给对应的Handler。属于EDA「事件队列组件」。
Handler：和一个Client通讯的实体，进行实际的业务处理。对应EDA的「事件处理组件」。

Client属于EDA的「事件生产组件」！

Reactor可以分为：单线程模型，多线程模型和主从Reactor模型。

单线程模型

Reactor轮询到消息后，就直接委托给Handler去处理，处理完后，再进行后面的轮询，即一个Handler处理完之后，才能进行下一个Handler的处理！如果某个handler耗时较长，就会阻塞后续的handler的执行！

多线程模型

Reactor多线程模型就是将Handler中的IO操作和非IO操作分开，操作IO的线程称为IO线程，非IO操作的线程称为工作线程!这样的话，客户端的请求会直接被丢到线程池中，客户端发送请求就不会堵塞！

但是当用户进一步增加的时候，Reactor会出现瓶颈！因为Reactor既要处理IO操作请求，又要响应连接请求！为了分担Reactor的负担，所以引入了主从Reactor模型!

主从Reactor模型

主Reactor用于响应连接请求，从Reactor用于处理IO操作请求！

详细内容可参考之前的博文《高性能Server---Reactor模型》！

这里简单说下，为什么Reactor中，请求的数据量不能太大，请求处理时间为什么不能太长！

其实很好理解，如果请求数据量太大、处理时间很长！即使是主从Reactor模型，线程池也会被耗尽！耗尽后，导致后续的请求积压。

Reactor解决的是传统BIO模型下，Server并发处理请求的能力受限于系统所能创建的线程数的问题！

redis中的EventDriven

redis使用了「Event-driven programming」来处理指令，「Event-driven programming」是一种编程范式，也可以说是EDA的代码实现。redis中的实现，类似Reactor单线程模型！

事件驱动程序设计是一种计算机程序设计模型。与传统上一次等待一个完整的指令然后再做运行的方式不同，事件驱动程序模型下的系统，基本上的架构是预先设计一个事件循环所形成的程序，这个事件循环程序不断地检查目前要处理的信息，根据要处理的信息运行一个触发函数进行必要的处理。其中这个外部信息可能来自一个目录夹中的文件，可能来自键盘或鼠标的动作，或者是一个时间事件。

简单的看一下代码：

// server.cint main(int argc, char **argv) {......aeMain(server.el);  // 进入事件监听轮询，轮询注册上来的文件句柄......
}// ae.cvoid aeMain(aeEventLoop *eventLoop) {eventLoop->stop = 0;          // eventLoop相当于Reactor模式中的Reactor组件while (!eventLoop->stop) {if (eventLoop->beforesleep != NULL)eventLoop->beforesleep(eventLoop);aeProcessEvents(eventLoop, AE_ALL_EVENTS|AE_CALL_AFTER_SLEEP);}
}int aeProcessEvents(aeEventLoop *eventLoop, int flags)
{......numevents = aeApiPoll(eventLoop, tvp);// select,epoll,evport,kqueue底层实现，获取事件......// 将事件委托给具体的Handler去处理for (j = 0; j < numevents; j++) {aeFileEvent *fe = &eventLoop->events[eventLoop->fired[j].fd];int mask = eventLoop->fired[j].mask;int fd = eventLoop->fired[j].fd;int fired = 0; int invert = fe->mask & AE_BARRIER;if (!invert && fe->mask & mask & AE_READABLE) {fe->rfileProc(eventLoop,fd,fe->clientData,mask);fired++;}if (fe->mask & mask & AE_WRITABLE) {if (!fired || fe->wfileProc != fe->rfileProc) {fe->wfileProc(eventLoop,fd,fe->clientData,mask);fired++;}}if (invert && fe->mask & mask & AE_READABLE) {if (!fired || fe->wfileProc != fe->rfileProc) {fe->rfileProc(eventLoop,fd,fe->clientData,mask);fired++;}}processed++;}......
}// ae.h
// aeFileEvent的结构如下，在构建时，就将处理程序赋给了其中的aeFileProc
// 在上面的轮询中，直接取出来执行即可
typedef struct aeFileEvent {int mask; /* one of AE_(READABLE|WRITABLE|BARRIER) */aeFileProc *rfileProc;aeFileProc *wfileProc;void *clientData;
} aeFileEvent;

下面以我们启动redis-server和redis-cli这个流程，来简单的说明下redis的执行流程：

//redis-server启动后，进入轮询状态，等待事件
//启动时构建了一个tcpHandler，用于处理客户端连接// server.c
for (j = 0; j < server.ipfd_count; j++) {if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE,acceptTcpHandler,NULL) == AE_ERR){serverPanic("Unrecoverable error creating server.ipfd file event.");}
}//redis-cli启动后,eventLoop轮询到连接事件，触发tcpHandler，根据获取到的文件句柄，构建aeFileEvent，同时设置readQueryFromClient Handler，用于处理后续的客户端的指令
client *createClient(int fd) {......if (aeCreateFileEvent(server.el,fd,AE_READABLE,readQueryFromClient, c) == AE_ERR){close(fd);zfree(c);return NULL;}......
}// 客户端发送指令后，触发readQueryFromClient Handler，来处理指令
// 处理完后，等待下一个指令

参考资料

Event-driven architecture
Event-driven architecture
Reactor pattern
《Software Architecture Patterns》Mark Richards
Event-driven programming
Redis源码
《恰如其分的软件架构》

EDA风格与Reactor模式相关推荐

架构风格 VS 架构模式
热爱实践而又不讲求科学的人,就好像一个水手进了一只没有舵或罗盘的船,他从来不肯定他往那里走. --达芬奇首先,在维基百科中是这样介绍的,"有些人将架构模式和架构风格视为相同的,有些人将风格 ...
Java进阶知识点5：服务端高并发的基石 - NIO与Reactor模式以及AIO与Proactor模式
一.背景要提升服务器的并发处理能力,通常有两大方向的思路. 1.系统架构层面.比如负载均衡.多级缓存.单元化部署等等. 2.单节点优化层面.比如修复代码级别的性能Bug.JVM参数调优.IO优化等等 ...
Reactor模式与Proactor模式
博主一脚刚踏进分布式的大门(看<分布式Java应用>,如果大家有啥推荐的书欢迎留言~),发现书中对NIO采用的Reactor模式.AIO采用的Proactor模式一笔带过,好奇心趋势我找了 ...
高性能IO设计中的Reactor模式与Proactor模式
为什么80%的码农都做不了架构师?>>> 在高性能的IO设计中,有两个比较著名的模式Reactor和Proactor模式,其中Reactor模式用于同步I/O,而Proacto ...
高性能IO之Reactor模式
讲到高性能IO绕不开Reactor模式,它是大多数IO相关组件如Netty.Redis在使用的IO模式,为什么需要这种模式,它是如何设计来解决高性能并发的呢? 最最原始的网络编程思路就是服务器用一个w ...
swing的gui是通过何种模式进行事件响应与监听_【Vert.x准备篇2】C10K问题与Reactor模式...
C10K问题是1999年一个叫Dan Kegel的美国人提出的概念,其中C为concurrently, 10K指的是1万个网络连接, 结合起来意为如何能够做到并发处理1万个连接. 这里首先要澄清一下, ...
高性能IO -Reactor模式的实现
2019独角兽企业重金招聘Python工程师标准>>> 在了解Reactor模式之前, 首先了解什么是NIO. java.nio全称java non-blocking IO 即非阻塞 ...
【Netty】反应器 Reactor 模式 ( 单反应器 Reactor 单线程 | 单反应器 Reactor 多线程 )
文章目录一. 反应器 ( Reactor ) 模式二. 反应器 ( Reactor ) 模式两大组件三. 单反应器 ( Reactor ) 单线程四. 单反应器 ( Reactor ) 单线程 ...
【Netty】Netty 简介 ( 原生 NIO 弊端 | Netty 框架 | Netty 版本 | 线程模型 | 线程阻塞 IO 模型 | Reactor 模式引入 )
文章目录一. NIO 原生 API 弊端二. Netty 简介三. Netty 架构四. Netty 版本五. Netty 线程模型六. 阻塞 IO 线程模型七. 反应器 ( React ...

EDA风格与Reactor模式