基于多反应堆的高并发服务器【C/C++/Reactor】（中）Dispatcher模块的实现思路

（四）Dispatcher模块的实现思路

关于dispatcher，它应该是反应堆模型里边的核心组成部分，因为如果说这个反应堆模型里边有事件需要处理，或者说有事件需要检测，那么是需要通过这个poll、epoll 或者 select来完成的。dispatcher有三个组成部分，它们并不是互相依存的，而是互斥的。就是我们在选择的时候，只能任选其一。不管使用哪一个，都可以往这个模型里边添加一个新的待检测事件，或者说把一个已经检测的事件从这个检测模型里边删掉。还有一种情况，就是把一个已经被检测得到文件描述符它的事件进行修改，比如原来是读事件，现在改成读写。也就是说这三种处理方式，每一种处理方式它们都对应一套处理函数，它们都对应一套处理函数。需要解决的问题：如果我们在程序中使用后，在调用这些接口的时候，是不是需要做一个判断？就是在程序中判断

if(使用的模型是poll){
    调用处理方式
}

else if(使用的模型是epoll){
    调用处理方式
}

else if(使用的模型是select){
    调用处理方式
}

因为这三种处理方式对应的是一套函数，所以在调用添加函数的时候需要做这样的一个的判断；在做删除的时候也需要做这样的一个判断，在做修改操作的时候，也需要做这样的判断。也就意味着咱们编写的程序是非常的冗余。

if() {
    ...
}
else if() {
    ...
}
else if() {
    ...
}

怎么去精简呢？有没有一种解决方案可以让代码写起来非常精简呢？

• 对应的解决方案就是使用回调函数

Dispatcher提供了一系列的接口：

1. init():做数据初始化
2. add():添加一个事件节点
3. remove():删除一个事件节点
4. modify():修改一个事件节点

dispatch():用于事件检测的，对于poll来说，就是调用poll函数，对于epoll来说，就是调用epoll_wait函数，对于select来说，就是调用select函数。通过调用dispatch函数就能够知道检测的这一系列的文件描述符集合里边到底是哪一个文件描述符它所对应的事件被触发了，找到了这个被触发事件的文件描述符，就需要基于它的事件去调用文件描述符注册号的读函数或者是写函数了。

clear():内存释放。第一部分：对文件描述符的关闭，第二部分：对申请的堆内存的释放。可以把Dispatcher设计成是一个结构体，里边有六个成员，类型都是函数指针。函数指针指向的是函数的地址，它指向了这个函数的地址之后，就可以对地址对应的函数进行调用了。首先保存一个函数的地址，然后在适当的时机去调用这个地址对应的函数。因为函数名就是地址。

• 假设说我们把这个函数指针已经做了初始化，什么时候进行调用呢？比如说客户端和服务器新建立了连接，那么就得到了一个用于通信的文件描述符。得到了通信的文件描述符，就需要调用add方法。这个add方法它是一个函数指针，它肯定指向一个对应的处理函数，那么这个任务函数动作是什么我就执行对应的那个动作。
• 假设说某一个通信的文件描述符客户端断开了连接，那么就需要把这个文件描述符从检测的模型上删除（poll、epoll、select），remove也是一个函数指针，指向一个实际的函数，只要能够找到这个函数，就可以调用这个函数，把对应的文件描述符从检测的模型上删除。

关于poll，也是一样的，分别是pollInit,pollAdd,pollDelete,pollModify,pollDispatch,pollClear。这些函数它们还是函数指针吗？就不是了吧，这是实实在在的函数，但是这个函数的函数原型也就是它的返回值以及参数。需要和上边dispatch这个模型，里边定义的函数，指针的类型是相同的，这样的话呢，咱们才能够让这个指针指向这个函数的地址吧。也就说呢，下边这一系列函数主要是给谁呢？给上边的这个dispatch结构体里边的函数指针进行实例化的吧。就是做初始化的。关于epoll，也是一样的，分别是epollInit,epollAdd,epollDelete,epollModify,epollDispatch,epollClear。select呢，也一样的，只不过是前缀不一样，当咱们把下边的这三个模型里边的函数分别实现了之后。就看用户的选择了，如果用户选择epoll，那么我们就使用epoll的这组函数去给上面的函数指针进行初始化。如果用户选择select，那么就用这组函数的地址去给这个函数值呢？进行初始化，如果用户选择poll，那么就用这组函数的函数名或者是函数地址啊，其实都是一样的。给上面的函数指针做初始化。初始化好了之后，我们在上层调用的时候呢，只需要使用dispatch这个结构体里边的这些函数指针的名字，就可以对下边这些已经实现了的函数进行。调用了吧？处理思路说明白之后，咱们再来看一个细节。对于poll这个模型来说，如果他要处理一系列的文件描述符，?前提条件是需要先把它们存储起来，存储到哪儿呢？是不是要存储到一个结构体里边啊？在调用poll函数的时候，需要用到一个结构体类型

#include <poll.h>
int poll(struct pollfd *fds, nfds_t nfds, int timeout);

struct pollfd {
    int fd; /* file descriptor */
    short events; /* requested events */
    short revents; /* returned events */
};

fds是struct pollfd类型，这个参数啊，是一个传入传出参数。我们在调用这个函数之前，需要先把结构体定义出来，然后对结构体进行初始化，告诉他我要检测的文件描述符的值是什么，以及要检测这个文件描述符的。什么事件当我们通过poll函数委托内核去检测这一系列的文件描述符集合的时候，内核检测到了某些文件，描述符对应的这个事件被触发了。那么，它就会把这个事件写入到revents里边，那么为什么有一个events了，还有一个revents呢？是这个样子的啊，比如说这个events，它里边委托内核要检测文件描述符的读写事件。现在只有读事件触发了，所以在revents里边呢，就只有读事件。如果对应的写事件触发了，那么这里边，就只有写事件，如果读写事件都触发了，那么在这个revents里边，就是读写。所以通过这个结构体的revents成员就能够非常清晰的知道这个文件描述符它的什么事件被触发了。知道什么事件被触发了，咱们就可以做对应的动作处理了。

#include <sys/epoll.h>
int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);

在epoll里边调用了epoll_wait就能够委托内核帮助我们去检测一系列的文件描述的集合，它所对应的事件是不是触发了？如果这些事件被触发了，那么他就会给我们返回数据，这个数据是保存到了第二个参数里边，第二个参数是一个epoll_event类型的结构体数组的地址。这个返回值，是告诉我们epoll树上有多少个待检测的文件描述符，它对应的时间被激活了。

#include <sys/select.h>
int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout);

在调用select这个函数的时候用到的那些数据成员吧。再来查一下。在调用select函数的时候，有三个存储文件描述符集合的参数分别是readfds。writefds以及exceptfds第三个是异常的集合，关于异常的集合，可以不去检测。我们主要关心的是它的读集合和写集合类型，是fdset，其实它也是传入传出参数。我们在传入的时候需要往fdset里边设置一些合适的值告诉select，你需要委托内核帮助我们去检测哪些文件描述符的什么事件？如果咱们把这些文件描述符设置给了readfds，就是检测它的读事件，如果咱们把这些文件描述符设置给了writefds，那么就是检测这些文件描述符的写事件。关于这个fdset，你可以把它看成是一个整形的数组，它里边，一共有1024个标志位。这个fdset这种类型，它里边儿一共有1024个标志位，这1024个标志位，就对应select能够检测的那1024个文件描述符。

一个Dispatcher模型，它对应一个DispatcherData

在我们要实现的这个多反应堆服务器模型里边儿，Dispatcher一共有多少个？是一个还是多个呢？来看一下在这个EventLoop里边，?其实就有Dispatcher，这个Dispatcher就是事件分发器，这个事件分发器其实就是要编写的那个poll、 epoll 和select模块，我们在实现Dispatcher它底层的这三个模型里边，任意一个的时候都需要一个DispatcherData。现在再来思考，刚才提问的那个问题，在这个多反应堆模型里边儿需要多少个Dispatcher呢？一个还是n个呢？其实是n个吧,在咱们项目里边儿有多少个反应堆模型，它就有多少个EventLoop，那么底层就有多少个Dispatcher。一个Dispatcher，它对应的有三块，一块是epoll ，一块是poll，一块是select。虽然有三块，前面也说了这三块呢，并不是同时发挥作用，而是三选一。既然这个Dispatcher有很多块，那么,这个DispatcherData就有多少个。

所以，需要给底层的这个IO多路转接模型提供对应的数据块，有多少个多路lO转接模型，咱们就需要提供多少个DispatcherData。举一个例子，比如在我们项目中有三个EventLoop，那么就有三个epoll、三个poll、三个select。那么对应的DispatcherData有多少个呢？三三得九，是九个。但是对于每一组来说，我们只能从里边选择一个来使用，那么另外两个就用不到了。既然用不到，那么我们需要对它的DispatcherData进行初始化吗？也就不需要了吧，也就是说，虽然有九个，但是你选择了用这个epoll，那么我就给这个epoll的data呢，做初始化;如果你选择了用poll，那么我就给这个poll的data呢，做初始化;如果你选择了用select。那么我就给这个select对应的data做初始化，这是一个EventLoop，剩下的两个EventLoop也是做同样的选择。

所以，在这个项目中有三个EventLoop，那么实际被初始化的DispatcherData有多少个呢？三个，现在就能搞清楚在Dispatcher这个结构体里边对应的这个回调函数Init()它是用来干什么的？就是用来初始化epoll或者是select或者是poll对应的那个数据块。要通过这个函数去初始化一个数据块，最后要把这个数据块的内存地址给到函数的调用者。所以它的返回值肯定是一个指针，另外poll、 epoll 和select他们需要的数据块对应的内存类型一样吗？不一样，如果想要一种类型来兼容三种不同的类型，怎么做到呢？在C语言里就是使用泛型，故返回值类型为void*。

未完待续~