https://blog.csdn.net/lianghe_work/article/details/46551871

通過(guò)epoll實(shí)現(xiàn)tcp并發(fā)回執(zhí)服務(wù)器（客戶端給服務(wù)器發(fā)啥，服務(wù)器就給客戶端回啥）

代碼如下：

#include <string.h>

#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <sys/select.h>

#include <sys/time.h>

#include <sys/socket.h>

#include <netinet/in.h>

#include <arpa/inet.h>

#include <sys/epoll.h>

#include <errno.h>

#define OPEN_MAX 100

int main(int argc, char *argv[])

{

struct epoll_event event; // 告訴內(nèi)核要監(jiān)聽(tīng)什么事件

struct epoll_event wait_event; //內(nèi)核監(jiān)聽(tīng)完的結(jié)果

//1.創(chuàng)建tcp監(jiān)聽(tīng)套接字

int sockfd = socket(AF_INET, SOCK_STREAM, 0);

//2.綁定sockfd

struct sockaddr_in my_addr;

bzero(&my_addr, sizeof(my_addr));

my_addr.sin_family = AF_INET;

my_addr.sin_port = htons(8001);

my_addr.sin_addr.s_addr = htonl(INADDR_ANY);

bind(sockfd, (struct sockaddr *)&my_addr, sizeof(my_addr));

//3.監(jiān)聽(tīng)listen

listen(sockfd, 10);

//4.epoll相應(yīng)參數(shù)準(zhǔn)備

int fd[OPEN_MAX];

int i = 0, maxi = 0;

memset(fd,-1, sizeof(fd));

fd[0] = sockfd;

int epfd = epoll_create(10); // 創(chuàng)建一個(gè) epoll 的句柄，參數(shù)要大于 0， 沒(méi)有太大意義

if( -1 == epfd ){

perror ("epoll_create");

return -1;

}

event.data.fd = sockfd; //監(jiān)聽(tīng)套接字

event.events = EPOLLIN; // 表示對(duì)應(yīng)的文件描述符可以讀

//5.事件注冊(cè)函數(shù)，將監(jiān)聽(tīng)套接字描述符 sockfd 加入監(jiān)聽(tīng)事件

int ret = epoll_ctl(epfd, EPOLL_CTL_ADD, sockfd, &event);

if(-1 == ret){

perror("epoll_ctl");

return -1;

}

//6.對(duì)已連接的客戶端的數(shù)據(jù)處理

while(1)

{

// 監(jiān)視并等待多個(gè)文件（標(biāo)準(zhǔn)輸入，udp套接字）描述符的屬性變化（是否可讀）

// 沒(méi)有屬性變化，這個(gè)函數(shù)會(huì)阻塞，直到有變化才往下執(zhí)行，這里沒(méi)有設(shè)置超時(shí)

ret = epoll_wait(epfd, &wait_event, maxi+1, -1);

//6.1監(jiān)測(cè)sockfd(監(jiān)聽(tīng)套接字)是否存在連接

if(( sockfd == wait_event.data.fd )

&& ( EPOLLIN == wait_event.events & EPOLLIN ) )

{

struct sockaddr_in cli_addr;

int clilen = sizeof(cli_addr);

//6.1.1 從tcp完成連接中提取客戶端

int connfd = accept(sockfd, (struct sockaddr *)&cli_addr, &clilen);

//6.1.2 將提取到的connfd放入fd數(shù)組中，以便下面輪詢客戶端套接字

for(i=1; i<OPEN_MAX; i++)

{

if(fd[i] < 0)

{

fd[i] = connfd;

event.data.fd = connfd; //監(jiān)聽(tīng)套接字

event.events = EPOLLIN; // 表示對(duì)應(yīng)的文件描述符可以讀

//6.1.3.事件注冊(cè)函數(shù)，將監(jiān)聽(tīng)套接字描述符 connfd 加入監(jiān)聽(tīng)事件

ret = epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &event);

if(-1 == ret){

perror("epoll_ctl");

return -1;

}

break;

}

}

//6.1.4 maxi更新

if(i > maxi)

maxi = i;

//6.1.5 如果沒(méi)有就緒的描述符，就繼續(xù)epoll監(jiān)測(cè)，否則繼續(xù)向下看

if(--ret <= 0)

continue;

}

//6.2繼續(xù)響應(yīng)就緒的描述符

for(i=1; i<=maxi; i++)

{

if(fd[i] < 0)

continue;

if(( fd[i] == wait_event.data.fd )

&& ( EPOLLIN == wait_event.events & (EPOLLIN|EPOLLERR) ))

{

int len = 0;

char buf[128] = "";

//6.2.1接受客戶端數(shù)據(jù)

if((len = recv(fd[i], buf, sizeof(buf), 0)) < 0)

{

if(errno == ECONNRESET)//tcp連接超時(shí)、RST

{

close(fd[i]);

fd[i] = -1;

}

else

perror("read error:");

}

else if(len == 0)//客戶端關(guān)閉連接

{

close(fd[i]);

fd[i] = -1;

}

else//正常接收到服務(wù)器的數(shù)據(jù)

send(fd[i], buf, len, 0);

//6.2.2所有的就緒描述符處理完了，就退出當(dāng)前的for循環(huán)，繼續(xù)poll監(jiān)測(cè)

if(--ret <= 0)

break;

}

}

}

return 0;

}

運(yùn)行結(jié)果：

源碼下載：

總結(jié)

以上是生活随笔為你收集整理的Linux网络编程——tcp并发服务器（epoll实现）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。