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

通過epoll實現tcp并發回執服務器（客戶端給服務器發啥，服務器就給客戶端回啥）

代碼如下：

#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; // 告訴內核要監聽什么事件

struct epoll_event wait_event; //內核監聽完的結果

//1.創建tcp監聽套接字

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.監聽listen

listen(sockfd, 10);

//4.epoll相應參數準備

int fd[OPEN_MAX];

int i = 0, maxi = 0;

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

fd[0] = sockfd;

int epfd = epoll_create(10); // 創建一個 epoll 的句柄，參數要大于 0， 沒有太大意義

if( -1 == epfd ){

perror ("epoll_create");

return -1;

}

event.data.fd = sockfd; //監聽套接字

event.events = EPOLLIN; // 表示對應的文件描述符可以讀

//5.事件注冊函數，將監聽套接字描述符 sockfd 加入監聽事件

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

if(-1 == ret){

perror("epoll_ctl");

return -1;

}

//6.對已連接的客戶端的數據處理

while(1)

{

// 監視并等待多個文件（標準輸入，udp套接字）描述符的屬性變化（是否可讀）

// 沒有屬性變化，這個函數會阻塞，直到有變化才往下執行，這里沒有設置超時

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

//6.1監測sockfd(監聽套接字)是否存在連接

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數組中，以便下面輪詢客戶端套接字

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

{

if(fd[i] < 0)

{

fd[i] = connfd;

event.data.fd = connfd; //監聽套接字

event.events = EPOLLIN; // 表示對應的文件描述符可以讀

//6.1.3.事件注冊函數，將監聽套接字描述符 connfd 加入監聽事件

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 如果沒有就緒的描述符，就繼續epoll監測，否則繼續向下看

if(--ret <= 0)

continue;

}

//6.2繼續響應就緒的描述符

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接受客戶端數據

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

{

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

{

close(fd[i]);

fd[i] = -1;

}

else

perror("read error:");

}

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

{

close(fd[i]);

fd[i] = -1;

}

else//正常接收到服務器的數據

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

//6.2.2所有的就緒描述符處理完了，就退出當前的for循環，繼續poll監測

if(--ret <= 0)

break;

}

}

}

return 0;

}

運行結果：

源碼下載：

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。