本文共 4448 字,大约阅读时间需要 14 分钟。
今晚的会二组长去毕业典礼了,所以显得有点冷清啊。
还是先来盘点一下各位的日报。(第五工作日)1号 | https://blog.csdn.net/qq_43762191/article/details/106893729 |
---|---|
https://blog.csdn.net/qq_43762191/article/details/106915706 | |
3号 | https://blog.csdn.net/blackcamouflage/article/details/106935067 |
4号 | https://blog.csdn.net/luyaozhima/article/details/106934513 |
8号 | https://blog.csdn.net/qq_42151344/article/details/106934421 |
哎,心塞。。。
算了算了,说我的进度吧。
画了张进程间TCP通信的简单类图:
测试并修订了解压包模块,已经纪录在上面的第二篇日报中,收获还是蛮大的。重点是对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"#includevoid 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); //同样,锁上}