Linux UDP 编程详解

徐锦洪  金牌会员 | 2025-1-20 22:31:13 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 980|帖子 980|积分 2940

一、引言

在网络编程领域，UDP（User Datagram Protocol，用户数据报协议）作为一种轻量级的传输层协议，具有独特的优势和适用场景。与 TCP（Transmission Control Protocol，传输控制协议）相比，UDP 不提供可靠的连接保证、数据顺序传递以及流量控制等功能，但它具有更低的开销和更高的传输效率，适用于对及时性要求较高、能容忍少量数据丢失的应用场景，如视频流传输、音频广播、在线游戏等。在 Linux 体系中，提供了丰富的函数库和工具来支持 UDP 编程，使得开辟者能够轻松构建基于 UDP 的网络应用。本文将深入探究 Linux 环境下的 UDP 编程，从基本概念、原理到具体的代码示例，帮助读者全面把握 UDP 编程技术。
二、UDP 协议基础

2.1 UDP 协议特点


  • 无连接性：UDP 在发送数据之前不必要像 TCP 那样创建连接，发送方可以直接将数据报发送给目标地点，吸收方随时准备吸收数据。这种特性使得 UDP 的传输过程更加简朴、快捷，减少了创建连接所需的时间和资源开销。
  • 不可靠性：UDP 不保证数据报一定能够正确、完整地到达吸收方，也不保证数据报的顺序。在网络传输过程中，数据报可能会由于网络拥塞、链路故障等缘故原由丢失或乱序。应用程序必要根据自身的需求来处理这些可能出现的题目，例如通过校验和、重传机制等方式来确保数据的完整性和正确性。
  • 面向数据报：UDP 以数据报为单元举行数据传输，每个数据报都是独立的，包含了目标地点、源地点和数据等信息。发送方每次调用发送函数（如sendto）发送的数据都会被封装成一个独立的数据报，吸收方通过吸收函数（如recvfrom）吸收一个个独立的数据报。
  • 头部开销小：UDP 的头部固定为 8 字节，相比 TCP 的 20 字节（不包含选项）头部开销更小，这使得 UDP 在传输大量小数据时具有更高的效率。UDP 头部包含源端口号、目标端口号、长度和校验和字段。
2.2 UDP 应用场景


  • 及时多媒体传输：如视频会议、在线直播、网络电话等应用对及时性要求极高，少量的数据丢失可能只会导致短暂的画面卡顿或声音不清晰，但不会对整体的用户体验造成严重影响。使用 UDP 可以制止 TCP 的重传机制带来的延迟，保证媒体流的流畅传输。
  • 网络监控与管理：在网络监控体系中，必要及时网络网络装备的状态信息、流量数据等。由于监控数据通常量较大且对及时性要求较高，使用 UDP 可以快速地将数据发送到监控中央，纵然部门数据丢失也不会影响对网络整体状态的判定。
  • 在线游戏：游戏中的及时状态更新、玩家操纵指令等数据必要及时传输给服务器和其他玩家。UDP 的低延迟特性使得游戏能够更及时地响应用户操纵，提供流畅的游戏体验。例如，在多人在线射击游戏中，玩家的移动、射击等操纵必要快速传输到服务器，UDP 能够满足这种及时性需求。
三、Linux UDP 编程基础函数

3.1 socket 函数

socket函数用于创建一个套接字形貌符，它是举行网络通信的基础。其函数原型如下：
  1. #include <sys/socket.h>
  2. int socket(int domain, int type, int protocol);
复制代码


  • domain参数指定协议族，对于 IPv4 网络，通常使用AF_INET；对于 IPv6 网络，使用AF_INET6。
  • type参数指定套接字类型，UDP 编程使用SOCK_DGRAM，表现数据报套接字。
  • protocol参数通常设置为 0，让体系根据domain和type选择默认的协议。对于 UDP，默认协议为 UDP 协议。
函数成功时返回一个非负整数的套接字形貌符，失败时返回 -1，并设置errno错误码以指示错误缘故原由。例如
  1. int sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  2. if (sockfd == -1) {
  3.     perror("socket creation failed");
  4.     exit(EXIT_FAILURE);
  5. }
复制代码
3.2 bind 函数

bind函数用于将套接字绑定到一个特定的地点和端口上。其函数原型如下：
  1. #include <sys/socket.h>
  2. int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);
复制代码


  • sockfd是通过socket函数创建的套接字形貌符。
  • addr是一个指向struct sockaddr布局体的指针，该布局体包含了要绑定的地点信息。在 IPv4 中，通常使用struct sockaddr_in布局体来填充地点信息，然后将其强制转换为struct sockaddr类型。
  • addrlen参数指定addr布局体的长度。
对于 IPv4，struct sockaddr_in布局体的界说如下：
  1. struct sockaddr_in {
  2.     sa_family_t sin_family; /* 地址族，AF_INET */
  3.     in_port_t sin_port;     /* 端口号 */
  4.     struct in_addr sin_addr; /* 32位IPv4地址 */
  5.     char sin_zero[8];       /* 填充字节，使其与struct sockaddr大小相同 */
  6. };
  7. struct in_addr {
  8.     in_addr_t s_addr; /* 32位IPv4地址 */
  9. };
复制代码
在使用bind函数时，必要正确填充struct sockaddr_in布局体的各个字段。例如：
  1. struct sockaddr_in servaddr;
  2. memset(&servaddr, 0, sizeof(servaddr));
  3. servaddr.sin_family = AF_INET;
  4. servaddr.sin_port = htons(8080); // 绑定到8080端口，htons用于将主机字节序转换为网络字节序
  5. servaddr.sin_addr.s_addr = INADDR_ANY; // 绑定到所有可用的网络接口
  7. if (bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
  8.     perror("bind failed");
  9.     close(sockfd);
  10.     exit(EXIT_FAILURE);
  11. }
复制代码
3.3 sendto 函数

sendto函数用于向指定的目标地点发送数据报。其函数原型如下：
  1. #include <sys/socket.h>
  2. ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
  3.                const struct sockaddr *dest_addr, socklen_t addrlen);
复制代码


  • sockfd是要发送数据的套接字形貌符。
  • buf是指向要发送数据缓冲区的指针。
  • len是要发送数据的长度，以字节为单元。
  • flags参数通常设置为 0，用于指定一些额外的发送选项，如 MSG_DONTROUTE 表现不查找路由表。
  • dest_addr是一个指向目标地点布局体的指针，指定数据报的吸收方地点。
  • addrlen参数指定目标地点布局体的长度。
函数成功时返回实际发送的字节数，失败时返回 -1，并设置errno错误码。例如：
  1. char buffer[] = "Hello, UDP!";
  2. struct sockaddr_in cliaddr;
  3. memset(&cliaddr, 0, sizeof(cliaddr));
  4. cliaddr.sin_family = AF_INET;
  5. cliaddr.sin_port = htons(9090);
  6. inet_pton(AF_INET, "192.168.1.100", &cliaddr.sin_addr); // 设置目标IP地址
  8. ssize_t n = sendto(sockfd, buffer, sizeof(buffer) - 1, 0,
  9.                    (struct sockaddr *)&cliaddr, sizeof(cliaddr));
  10. if (n == -1) {
  11.     perror("sendto failed");
  12. }
复制代码
3.4 recvfrom 函数

recvfrom函数用于从套接字吸收数据报，并获取发送方的地点信息。其函数原型如下：
  1. #include <sys/socket.h>
  2. ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
  3.                  struct sockaddr *src_addr, socklen_t *addrlen);
复制代码


  • sockfd是吸收数据的套接字形貌符。
  • buf是用于存储吸收到数据的缓冲区。
  • len是缓冲区的长度，以字节为单元。
  • flags参数通常设置为 0，用于指定一些额外的吸收选项，如 MSG_PEEK 表现只是检察数据而不真正从吸收队列中移除。
  • src_addr是一个指向布局体的指针，用于存储发送方的地点信息。
  • addrlen是一个指向size_t类型变量的指针，用于指定src_addr布局体的长度，函数返回时会更新该变量为实际吸收到的地点长度。
函数成功时返回实际吸收到的字节数，失败时返回 -1，并设置errno错误码。例如：
  1. char buffer[1024];
  2. struct sockaddr_in cliaddr;
  3. socklen_t len = sizeof(cliaddr);
  4. ssize_t n = recvfrom(sockfd, buffer, sizeof(buffer) - 1, 0,
  5.                      (struct sockaddr *)&cliaddr, &len);
  6. if (n == -1) {
  7.     perror("recvfrom failed");
  8. } else {
  9.     buffer[n] = '\0';
  10.     printf("Received: %s\n", buffer);
  11. }
复制代码
四、Linux UDP 编程示例

4.1 UDP 服务器示例

下面是一个简朴的 UDP 服务器示例代码，该服务器绑定到指定的端口，吸收客户端发送的数据，并将吸收到的数据回显给客户端。
  1. #include <sys/socket.h>
  2. #include <netinet/in.h>
  3. #include <arpa/inet.h>
  4. #include <stdio.h>
  5. #include <stdlib.h>
  6. #include <string.h>
  7. #include <unistd.h>
  9. #define BUFFER_SIZE 1024
  11. void usage(const char *prog_name) {
  12.     printf("Usage: %s <listen_ip> <listen_port>\n", prog_name);
  13.     printf("Example: %s 127.0.0.1 8080\n", prog_name);
  14.     exit(EXIT_FAILURE);
  15. }
  17. int main(int argc, char *argv[]) {
  18.     int sockfd;
  19.     struct sockaddr_in servaddr, cliaddr;
  20.     socklen_t len;
  21.     char buffer[BUFFER_SIZE];
  22.     ssize_t n;
  24.     // 检查命令行参数数量是否正确
  25.     if (argc!= 3) {
  26.         usage(argv[0]);
  27.     }
  29.     // 创建 UDP 套接字
  30.     sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  31.     if (sockfd == -1) {
  32.         perror("socket creation failed");
  33.         exit(EXIT_FAILURE);
  34.     }
  36.     // 初始化服务器地址结构体
  37.     memset(&servaddr, 0, sizeof(servaddr));
  38.     servaddr.sin_family = AF_INET;
  39.     servaddr.sin_port = htons(atoi(argv[2]));
  40.     if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) {
  41.         perror("Invalid IP address");
  42.         close(sockfd);
  43.         exit(EXIT_FAILURE);
  44.     }
  46.     // 绑定套接字到服务器地址
  47.     if (bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
  48.         perror("bind failed");
  49.         close(sockfd);
  50.         exit(EXIT_FAILURE);
  51.     }
  52.     printf("UDP server is listening on %s:%d...\n", argv[1], atoi(argv[2]));
  54.     while (1) {
  55.         // 接收客户端数据
  56.         len = sizeof(cliaddr);
  57.         n = recvfrom(sockfd, buffer, BUFFER_SIZE - 1, 0,
  58.                     (struct sockaddr *)&cliaddr, &len);
  59.         if (n == -1) {
  60.             perror("recvfrom failed");
  61.             continue;
  62.         }
  63.         buffer[n] = '\0';
  64.         printf("Received from client (%s:%d): %s\n",
  65.                inet_ntoa(cliaddr.sin_addr), ntohs(cliaddr.sin_port), buffer);
  67.         // 将接收到的数据回显给客户端
  68.         n = sendto(sockfd, buffer, strlen(buffer), 0,
  69.                   (struct sockaddr *)&cliaddr, len);
  70.         if (n == -1) {
  71.             perror("sendto failed");
  72.         }
  73.     }
  75.     close(sockfd);
  76.     return 0;
  77. }
复制代码
在这个示例中，服务器首先创建一个 UDP 套接字，然后将其绑定到指定的端口。通过一个无限循环，服务器不停调用recvfrom函数吸收客户端发送的数据，并在吸收到数据后调用sendto函数将数据回显给客户端。
4.2 UDP 客户端示例

以下是与上述服务器对应的 UDP 客户端示例代码，客户端向服务器发送数据，并吸收服务器回显的数据。
  1. #include <sys/socket.h>
  2. #include <netinet/in.h>
  3. #include <arpa/inet.h>
  4. #include <stdio.h>
  5. #include <stdlib.h>
  6. #include <string.h>
  7. #include <unistd.h>
  9. #define BUFFER_SIZE 1024
  11. void usage(const char *prog_name) {
  12.     printf("Usage: %s <server_ip> <port> <message>\n", prog_name);
  13.     printf("Example: %s 127.0.0.1 8080 "Hello, server!"\n", prog_name);
  14.     exit(EXIT_FAILURE);
  15. }
  17. int main(int argc, char *argv[]) {
  18.     int sockfd;
  19.     struct sockaddr_in servaddr;
  20.     char buffer[BUFFER_SIZE];
  21.     ssize_t n;
  22.     socklen_t len;
  24.     // 检查命令行参数数量是否正确
  25.     if (argc!= 4) {
  26.         usage(argv[0]);
  27.     }
  29.     // 创建 UDP 套接字
  30.     sockfd = socket(AF_INET, SOCK_DGRAM, 0);
  31.     if (sockfd == -1) {
  32.         perror("socket creation failed");
  33.         exit(EXIT_FAILURE);
  34.     }
  36.     // 初始化服务器地址结构体
  37.     memset(&servaddr, 0, sizeof(servaddr));
  38.     servaddr.sin_family = AF_INET;
  39.     servaddr.sin_port = htons(atoi(argv[2]));
  40.     if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0) {
  41.         perror("Invalid IP address");
  42.         close(sockfd);
  43.         exit(EXIT_FAILURE);
  44.     }
  46.     // 向服务器发送数据
  47.     n = sendto(sockfd, argv[3], strlen(argv[3]), 0,
  48.               (struct sockaddr *)&servaddr, sizeof(servaddr));
  49.     if (n == -1) {
  50.         perror("sendto failed");
  51.         close(sockfd);
  52.         exit(EXIT_FAILURE);
  53.     }
  54.     printf("Sent %ld bytes to server: %s\n", n, argv[3]);
  56.     // 接收服务器回显的数据
  57.     len = sizeof(servaddr);
  58.     n = recvfrom(sockfd, buffer, BUFFER_SIZE - 1, 0,
  59.                 (struct sockaddr *)&servaddr, &len);
  60.     if (n == -1) {
  61.         perror("recvfrom failed");
  62.         close(sockfd);
  63.         exit(EXIT_FAILURE);
  64.     }
  65.     buffer[n] = '\0';
  66.     printf("Received from server: %s\n", buffer);
  68.     close(sockfd);
  69.     return 0;
  70. }
复制代码
客户端同样先创建一个 UDP 套接字，然后初始化服务器的地点信息。通过sendto函数向服务器发送数据，接着使用recvfrom函数吸收服务器回显的数据。
代码解释



  • 服务器端代码：

    • socket(AF_INET, SOCK_DGRAM, 0)：创建一个 UDP 套接字。AF_INET 表现使用 IPv4 地点族，SOCK_DGRAM 表现使用数据报套接字类型，0 表现使用默认协议（对于 AF_INET 和 SOCK_DGRAM 组合，即为 UDP 协议）。
    • memset(&servaddr, 0, sizeof(servaddr))：将 servaddr 布局体的内存清零，确保其成员变量初始化为零。
    • servaddr.sin_family = AF_INET：设置地点族为 IPv4。
    • servaddr.sin_port = htons(PORT)：将端口号转换为网络字节序并存储在 sin_port 中。
    • servaddr.sin_addr.s_addr = INADDR_ANY：将套接字绑定到所有可用的网络接口。
    • bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr))：将套接字绑定到本地地点和端口，使得服务器可以吸收发送到该端口的数据。
    • recvfrom(sockfd, buffer, BUFFER_SIZE - 1, 0, (struct sockaddr *)&cliaddr, &len)：从客户端吸收数据，存储在 buffer 中，并将发送方的地点存储在 cliaddr 中。
    • sendto(sockfd, buffer, strlen(buffer), 0, (struct sockaddr *)&cliaddr, len)：将吸收到的数据发送回客户端。

  • 客户端代码解释：

    • socket(AF_INET, SOCK_DGRAM, 0)：创建一个 UDP 套接字，与服务器端相同。
    • memset(&servaddr, 0, sizeof(servaddr))：将 servaddr 布局体的内存清零。
    • servaddr.sin_family = AF_INET：设置地点族为 IPv4。
    • servaddr.sin_port = htons(PORT)：将端口号转换为网络字节序。
    • inet_pton(AF_INET, SERVER_IP, &servaddr.sin_addr)：将服务器的 IP 地点字符串转换为二进制格式存储在 sin_addr 中。
    • sendto(sockfd, msg, strlen(msg), 0, (struct sockaddr *)&servaddr, sizeof(servaddr))：向服务器发送数据。
    • recvfrom(sockfd, buffer, BUFFER_SIZE - 1, 0, (struct sockaddr *)&servaddr, &len)：吸收服务器回显的数据。

五、编译指令和测试过程

5.1 编译

  1. gcc udp_server.c -o udp_server
  2. gcc udp_client.c -o udp_client
复制代码
5.2 测试过程

启动服务端 监听端口
  1. ./udp_server 127.0.0.1 8080
复制代码
客户端发送数据
  1. ./udp_client 127.0.0.1 8080 helloworld123
复制代码

六、UDP 编程中的常见题目与办理方案

6.1 数据丢失题目

由于 UDP 的不可靠性，数据在传输过程中可能会丢失。为相识决这个题目，可以在应用层实现数据校验和重传机制。例如，发送方在每个数据报中添加一个校验和字段，吸收方在吸收到数据报后计算校验和并与发送方发送的校验和举行比力，如果不同等则请求发送方重传该数据报。另外，可以设置一个重传定时器，当发送方在一定时间内未收到吸收方简直认消息时，主动重传数据报。
6.2 数据报大小限制

UDP 数据报的大小受到网络 MTU（Maximum Transmission Unit，最大传输单元）的限制。在 IPv4 网络中，MTU 通常为 1500 字节（不包括链路层头部），UDP 数据报的总长度（包括头部）不能凌驾 MTU。如果必要发送的数据凌驾 MTU 大小，必要将数据举行拆分，分成多个较小的数据报举行发送。吸收方在吸收到多个数据报后，必要按照正确的顺序举行重组。
6.3 网络拥塞题目

虽然 UDP 没有像 TCP 那样的拥塞控制机制，但在网络拥塞严重的环境下，大量的数据报可能会被丢弃。为了减轻网络拥塞对 UDP 应用的影响，可以在应用层实现一些简朴的拥塞控制策略，如根据网络状态动态调整发送数据的速率。例如，当发现丢包率增长时，适当降低发送速率；当网络状态良好时，渐渐提高发送速率。
6.4 可能碰到的题目及办理方法



  • 权限题目：如果在运行时碰到权限题目，可能是由于使用了低端口号（小于 1024），可以使用 sudo 命令来运行可执行文件，或者将端口号修改为大于 1024 的端口。
  • 地点冲突：如果服务器绑定的端口已被其他程序占用，会导致绑定失败，可以修改服务器的端口号。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

徐锦洪

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

AI 运维 CIO 存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表