头文件

 #ifndef SERVER_H #define SERVER_H  #include  #include  #include  #include  #include  #include  #include  #include  #include  #include  #include  #include  #include  using namespace std;  #ifdef __cplusplus extern "C" { #endif  // 初始化监听的文件描述符 int initlistenFd(unsigned short port);  // 启动 epoll 模型 int epollrun(unsigned short port);  // 建立新连接 int acceptConn(int lfd, int epfd);  // 接收 HTTP 请求 int recvHttprequest(int cfd, int epfd);  // 解析请求行 int parserequestline(const char *requline, int cfd);  // 发送头信息 int sendHeadmsg(int cfd, int status, const char *descr, const char *type, int length);  //发送目录 int senddir(int cfd,char*dirname);  // 发送文件 int sendFile(int cfd, const char *file);  // 断开连接 int disconnect(int cfd, int epfd);   #ifdef __cplusplus } #endif  #endif // SERVER_H 

 服务器端： sever.cpp

#include"sever.h" //初始化监听套接字 int initlistenFd(unsigned short port) {     //1.创建监听的套接字     int lfd=socket(AF_INET,SOCK_STREAM,0);     if(lfd==-1){         perror("socket");         return -1;     }      //2. 端口复用     //如果服务器主动断开链接，那么将会进入TIME_WAIT 状态，等待2msl，这个时间太长了，所以就设置端口复用，继续使用端口复用，使客户端用这个端口链接，但是上一个仍处于TIME_WAIT      int opt=1;     int ret = setsockopt(lfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));     if(ret==-1){         perror("ret");     }      //3.绑定     //设置文件描述符的地址ip端口     struct sockaddr_in addr;     addr.sin_family=AF_INET;//IPV4     addr.sin_port=htons(port);     addr.sin_addr.s_addr=INADDR_ANY; //0地址          ret=bind(lfd,(sockaddr*)&addr,sizeof(addr));     if(ret==-1){         perror("bind");         return -1;     }      //4.设置监听     ret=listen(lfd,128);      if(ret==-1){         perror("listen");         return -1;     }          //5.返回可用的监听的套接字     return lfd;  }  //启动epoll模型 int epollrun(unsigned short port){     //初始化epoll模型     int epfd=epoll_create(1000);//创建epoll树     if(epfd==-1){         perror("create");         return -1;     }      //初始化epoll树,将监听lfd添加上树     int lfd=initlistenFd(port);      struct epoll_event ev;//事件结构体     ev.events=EPOLLIN;//检查读事件     ev.data.fd=lfd;//将lfd添加属性中     //添加上树     int ret=epoll_ctl(epfd,EPOLL_CTL_ADD,lfd,&ev);     if(ret==-1){         perror("epoll_ctl-add");         return -1;     }      //检测，循环检测，边沿ET模式，epoll非阻塞     struct epoll_event evs[1024];     int size=sizeof(evs)/sizeof(int);     int flag =0;     while (1)     {         if(flag==1){             break;         }         int num=epoll_wait(epfd,evs,size,0);//非阻塞进行         //遍历发生可读事件的变化的数组         for (int  i = 0; i < num; i++)         {             int curfd=evs[i].data.fd;//临时变量找到变化的文件描述符             if(curfd==lfd)//如果使监听套接字发生变化，一定是客户端请求链接             {                 //建立链接               int ret= acceptConn(curfd,epfd);               if(ret==-1){                 //建立链接失败直接终止程序                 flag=1;                 break;               }              }             else{                 //通信//接受http请求                 recvHttprequest(curfd,epfd);             }                      }              }            return 0; }  //和客户端建立新连接，并且将通信文件描述符设置成非阻塞属性 int acceptConn(int lfd,int epfd){      //建立链接     int cfd=accept(lfd,NULL,NULL);     if(cfd==-1){         perror("accept");         return -1;     }      //设置通信文案描述属性为非阻塞     int flag=fcntl(cfd,F_GETFL);     flag|=O_NONBLOCK;     fcntl(cfd,F_SETFL,flag);      //通信套接字添加到epoll模型上     struct epoll_event ev;     ev.data.fd=cfd;     ev.events=EPOLLIN | EPOLLET;//事件为边沿属性，检查读缓冲区；     int ret =epoll_ctl(epfd,EPOLL_CTL_ADD,cfd,&ev);     if(ret==-1){         perror("epoll_ctl");         return -1;     }  }  //和客户端断开新链接 int disconnect(int cfd,int epfd){      //将节点从epoll模型删除     int ret =epoll_ctl(epfd,EPOLL_CTL_DEL,cfd,NULL);//删除操作最后一个制空     if(ret==-1){         perror("epoll_ctl_del");         return -1;     }     //关闭通信套接字     close(cfd);     return 0; } //接受客户端http的请求消息 int recvHttprequest(int cfd,int epfd){     //因为是边沿非阻塞模型，所以要一次性循环读      char tmp[1024];//每次读1k数据     char buf[4096];//每次把读的数据存到这个缓冲区里面     //循环读数据     int len,total=0;//total 是当前的buf的数据     //客户端申请的都是静态资源，请求的资源内容，在请求行的第二部分     //只需将请求完整的保存下来就可以     //不需要解析请求头的数据，因此接受到之后不储存也是没问题的      while((len=recv(cfd,tmp,sizeof(tmp),0))>0){         if(len+total这里只需两个键值对     //content-type /content-length   https://tool.oschina.net/commons去这里查      sprintf(buf + strlen(buf), "Content-Type: %s\r\n", type);     sprintf(buf + strlen(buf), "Content-Length: %d\r\n\r\n", length);      // 空行     //拼接完成之后发送     send(cfd,buf,strlen(buf),0);//非阻塞       return 0;  }  int sendFile(int cfd,const char *file){      //读文件，发送给客户端     //在发送内容之前应该有状态+消息包头，+空行+文件内容     //这四部分数据组织好之后再发送数据吗？     //不是 为什么，因为传输层默认人是tcp的     //面向连接的流式传输协议-》只有最后全部发送完就可以      int fd=open(file,O_RDONLY);//只读     while (1)     {         char buf[1024];         int len=read(fd,buf,sizeof(buf));         if(len>0){             //发送读出的数据             send(cfd,buf,len,0);         }         else if(len==0){             //文件读完了             break;         }         else{             perror("read");             return -1;         }              }       return 0; }