udp epoll的代码案例-DPDK中文网

下面是一个使用 epoll 的 UDP 服务器示例。该示例展示了如何使用 epoll 来处理多个客户端的请求。

UDP Epoll Server 示例代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/epoll.h>

#define PORT 8080
#define MAX_EVENTS 10
#define BUFFER_SIZE 1024

int main() {
    int sockfd, epoll_fd;
    struct sockaddr_in servaddr, cliaddr;
    char buffer[BUFFER_SIZE];
    struct epoll_event ev, events[MAX_EVENTS];

    // 创建 socket
    if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
        perror("Socket creation failed");
        exit(EXIT_FAILURE);
    }

    // 填充服务器信息
    memset(&servaddr, 0, sizeof(servaddr));
    
    servaddr.sin_family = AF_INET;           // IPv4
    servaddr.sin_addr.s_addr = INADDR_ANY;  // 任意地址
    servaddr.sin_port = htons(PORT);          // 指定端口

    // 将 socket 与地址结构绑定
    if (bind(sockfd, (const struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) {
        perror("Bind failed");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    printf("UDP epoll server is up and listening on port %d\n", PORT);

    // 创建 epoll 实例
    if ((epoll_fd = epoll_create1(0)) == -1) {
        perror("Epoll create failed");
        close(sockfd);
        exit(EXIT_FAILURE);
    }

    // 注册 socket 文件描述符到 epoll 实例中
    ev.events = EPOLLIN;
    ev.data.fd = sockfd;

    if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, sockfd, &ev) == -1) {
        perror("Epoll ctl failed");
        close(sockfd);
        close(epoll_fd);
        exit(EXIT_FAILURE);
    }

    while (1) {
        int n = epoll_wait(epoll_fd, events, MAX_EVENTS, -1);

        for (int i = 0; i < n; i++) {
            if (events[i].events & EPOLLIN) {
                socklen_t len = sizeof(cliaddr);
                ssize_t received_len = recvfrom(sockfd, buffer, BUFFER_SIZE - 1,
                                                 MSG_WAITALL,
                                                 (struct sockaddr *)&cliaddr,
                                                 &len);
                
                if (received_len > 0) {
                    buffer[received_len] = '\0'; // 确保以 null 字符结尾
                    
                    printf("Received message from client: %s\n", buffer);

                    // 可选：可以向客户端发送响应（如果需要）
                    sendto(sockfd, "Message received", strlen("Message received"),
                           MSG_CONFIRM, (const struct sockaddr *) &cliaddr,
                           len);

                    printf("Response sent to client.\n");
                }
            }
        }
    }

   close(sockfd);
   return 0;
}

编译与运行

将上述代码保存为 udp_epoll_server.c。

使用以下命令编译：


gcc udp_epoll_server.c -o udp_epoll_server

在终端中运行程序：
```
./udp_epoll_server
```

客户端示例（可选）

您可以使用之前提供的 UDP 客户端代码，或者使用以下简单的客户端进行测试：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>

#define PORT 8080
#define SERVER_IP "127.0.0.1" // 修改为你的服务器 IP 如果需要

int main() {
    int sockfd;
    
char *message = "Hello from UDP client!";
    
struct sockaddr_in servaddr;

     // 创建 socket 
if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { 
perror("Socket creation failed"); 
exit(EXIT_FAILURE); 
}

memset(&servaddr, 0,sizeof(servaddr));

servaddr.sin_family=AF_INET;            // IPv4 
servaddr.sin_port=htons(PORT);           // 指定端口
 
// 将 IP 地址转换为二进制形式，并填充到服务地址结构中 
if(inet_pton(AF_INET,SERVER_IP,&servaddr.sin_addr)<=0){ 
perror("Invalid address / Address not supported"); 
exit(EXIT_FAILURE); 
}

// 向服务器发送消息并接收响应  
sendto(sockfd,message,strlen(message),MSG_CONFIRM,(const struct sockaddr*)&servaddr,sizeof(servaddr)); 

printf("Message sent to server: %s\n",message);

// 接收服务器的响应  
char buffer[1024]; 
socklen_t len=sizeof(servaddr);   
recvfrom(sockfd,buffe r,sizeof(buffer),MSG_WAITALL,(struct sockaddr*)&serv addr,&len); 

printf("Server response: %s\n",buffer); 

close(sockfd); return 0; 
}