本文共 4448 字，大约阅读时间需要 14 分钟。

日报情况

今晚的会二组长去毕业典礼了，所以显得有点冷清啊。

哎，心塞。。。

我的进度

算了算了，说我的进度吧。

画了张进程间TCP通信的简单类图：

重点是对epoll模块的改装。

可以先看一下旧的epoll：

旧的epoll类图：

可以看出来这个epoll是非常之任务繁忙的，线程池也要，TCP通信也要，进程间通信也要，解压包也要，我以前写的那个项目，还要个日志类对象，真是，能者多劳啊。

但是，这样就很难拓展了，如果我要安插一个新的文件描述符，它代表一个全新的模块，那要改多少？来个对象，初始化对象，配置对象，然后再配置epoll属性，然后插入epoll监控表，麻烦，还容易出错。

于是我就苦思冥想，终于让我想到了：责任链模式。

于是类图就成这样了：

现在epoll就可以专心干自己的事情了。

于是代码实现就是这样：（为了更直观，我还写了客户端连接处理类）

//AbstractFront.h#pragma onceclass Abstract_Front{
   private:	Abstract_Front* nexthandle;	int fd;public:	void setNextHandle(Abstract_Front* h);	void HandleCommand(int fdd);	int get_fd();	void set_fd();		virtual int run() = 0;};

//AbstractFront.cpp#include "Abstract_Front.h"#include
   
    void Abstract_Front::setNextHandle(Abstract_Front* h) {
   	this->nexthandle = h;}int Abstract_Front::get_fd() {
   	return this->fd;}void Abstract_Front::HandleCommand(int fdd) {
   	if (fdd == this->fd || this->nexthandle == NULL)			this->run();	else		this->nexthandle->HandleCommand(fdd);}
   

//epoll.h#pragma once#include "Abstract_Front.h"#include 
   
    #include 
    
     #include 
     
      #include
      
       using namespace std;class Epoll{
   private:	Abstract_Front* Head;	struct epoll_event* retEvents;	int	maxEvent;	int	timeout;	int		epfd;	struct  epoll_event event;public:	Epoll(unsigned int maxEvent = 100, int timeout = -1);	~Epoll();	void Epoll_add(int fd);	void Epoll_del(int fd);	void Epoll_run(int nevent);	int Epoll_Wait();	void setFrontHead(Abstract_Front* h);};
      
     
    
   

//epoll.cpp#include "Epoll.h"Epoll::Epoll(unsigned int maxEvent = 100, int timeout = -1) {
       this->maxEvent = maxEvent;    this->timeout = timeout;    this->retEvents = new struct epoll_event[maxEvent];    this->epfd = epoll_create(this->maxEvent);    if (this->epfd < 0)    {
           perror("Epoll Create Error!");        return;    }}Epoll::~Epoll() {
       if (epfd != -1)    {
           close(this->epfd);        epfd = -1;    }    if (NULL != this->retEvents)    {
           delete[]this->retEvents;        this->retEvents = NULL;    }}void Epoll::Epoll_add(int fd) {
       this->event.events = EPOLLIN | EPOLLET;    this->event.data.fd = fd;    int ret = epoll_ctl(this->epfd, EPOLL_CTL_ADD, fd, &this->event);    if (ret < 0)    {
           perror("Epoll Add Event Error!");    }}void Epoll::Epoll_del(int fd) {
       this->event.events = EPOLLIN | EPOLLET;    this->event.data.fd = fd;    int ret = epoll_ctl(this->epfd, EPOLL_CTL_DEL, fd, &this->event);    if (ret < 0)    {
           perror("Epoll Delete Event Error!");    }}int Epoll::Epoll_Wait() {
       int nevent = epoll_wait(this->epfd, this->retEvents, this->maxEvent, -1);    if (nevent < 0)    {
           perror("epoll wait error!");    }    return nevent;}void Epoll::setFrontHead(Abstract_Front* h) {
       this->Head = h;}void Epoll::Epoll_run(int nevent) {
       //¿ªÊ¼ÔðÈÎÁ´    for (int i = 0; i < nevent; i++)    {
           if(this->Head)        if (!(retEvents + i)->events & EPOLLIN)            continue;        Head->HandleCommand((retEvents + i)->data.fd);            }}

//Socket.h#pragma once#include "Abstract_Front.h"#include "Epoll.h"class Socket :	public Abstract_Front{
   public:	Socket(Epoll* epp);		int run();	private:	Epoll* ep;	int listen_fd;};

//Socket.cpp#include "Socket.h"Socket::Socket(Epoll* epp) {
       this->ep = epp;    struct sockaddr_in  servaddr;//客户端地址及服务器地址    listen_fd = socket(AF_INET, SOCK_STREAM, 0);//1.创建文件描述符（用于监听）    //成功返回文件描述符，失败返回-1，并设置errno    ep->Epoll_add(listen_fd);   //凡是在外面使用ep的，都要上锁，这里等着被锁吧    bzero(&servaddr, sizeof(servaddr));//清零客户端地址结构体    servaddr.sin_family = AF_INET;//IPv4类型地址    servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//主机本地任意IP地址    servaddr.sin_port = htons(8000);//绑定端口号    bind(listen_fd, (struct sockaddr*) & servaddr, sizeof(servaddr));//将监听文件描述与IP地址绑定    listen(listen_fd, 20);//监听广播（查看是否有客户端发出连接请求）}int Socket::run() {
       struct sockaddr_in cliaddr;    socklen_t clilen = sizeof(cliaddr);    int connfd = accept(listen_fd, (struct sockaddr*) & cliaddr, &clilen);    ep->Epoll_add(connfd);  //同样，锁上}

转载地址：https://lion-wu.blog.csdn.net/article/details/106934618 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！