linux c的udp server实现代码案例-DPDK中文网

下面是一个简单的 UDP 服务器的实现示例，使用 C 语言在 Linux 环境下编写。这个服务器会绑定到指定的端口并接收客户端发送的数据。

UDP Server 示例代码

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

#define PORT 8080
#define BUFFER_SIZE 1024

int main() {
    int sockfd;
    char buffer[BUFFER_SIZE];
    struct sockaddr_in servaddr, cliaddr;
    socklen_t len;

    // 创建 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 server is up and listening on port %d\n", PORT);

    while (1) {
        len = sizeof(cliaddr);  // 初始化客户端地址结构长度
        
        // 接收数据
        ssize_t n = recvfrom(sockfd, buffer, BUFFER_SIZE - 1, MSG_WAITALL,
                             (struct sockaddr *) &cliaddr, &len);
        buffer[n] = '\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_server.c。
使用以下命令编译：
```
gcc udp_server.c -o udp_server
```
在终端中运行程序：
```
./udp_server
```

客户端示例（可选）

为了测试 UDP 服务器，您可以使用以下简单的 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);

     close(sockfd);
     return 0;
}