写在前边
本文是B站up主韦东山的4_8-3.UDP编程示例_哔哩哔哩_bilibili视频的笔记，其中有些部分博主也没有理解，希望各位辩证的看。
UDP协议简介
UDP 是一个简单的面向数据报的运输层协议，在网络中用于处理数据包，是一种无连接的协议。UDP 不提供可靠性的传输，它只是把应用程序传给 IP 层的数据报发送出去，但是并不能保证它们能到达目的地。由于 UDP 在传输数据报前不用在客户和服务器之间建立一个连接，且没有超时重发等机制，故而传输速度很快。
对于UDP网络编程步骤，这里借用韦山东老师的图：
图 3UDP 用户数据包模式
UDP相对于TCP编程来说简单了很多，因为UDP没有TCP那些可靠连接的东西，所以编程相对来说也简单了一些。
这里对于函数，只有发送和接受函数和之前有点区别：
sendto()
函数结构
#include <sys/types.h>#include <sys/socket.h>ssize_t sendto ( socket s , const void * msg, int len, unsigned int flags, conststruct sockaddr * to , int tolen ) ;描述
sendto() 用来将数据由指定的socket传给对方主机。
参数
- s
用于通信的通信描述符，对于服务器，就是指accept函数返回的通信描述符
- msg
指向一片应用缓存，用于存放要发送的数据，存放数据一般使用结构体变量。
- len
存放发送数据的缓存的大小。
- flags
一般设置为0，此时是阻塞发送的，阻塞发送是指发送数据不成功会一直阻塞，直到被某信号中断或发送成功为止，不过发送数据一般不阻塞。
- to
存放指定欲传送的网络地址，结构sockaddr请参考bind()。
- tolen
sockaddr的结构长度。
- 返回值
成功：返回发送的字节数，失败：返回-1
recvfrom()
函数结构
#include <sys/types.h>#include <sys/socket.h>ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);描述
它是一个系统调用，用于从套接字接收数据。该函数通常与无连接的数据报服务（如 UDP）一起使用，但也可以与其他类型的套接字使用。与简单的 recv() 函数不同，recvfrom() 可以返回数据来源的地址信息。
参数
- sockfd
一个已打开的套接字的描述符
- buf
指明一个缓冲区，该缓冲区用来存放recvfrom函数接收到的数据
- len
指明buf的长度。
- flags
传0 表示使用默认协议。
- src_addr
一个指针，指向一个 sockaddr 结构，用于保存发送数据的源地址，结构sockaddr请参考bind()。
- addrlen
src_addr的结构长度。当 recvfrom() 返回时，该值会被修改为实际地址的长度（以字节为单位）。
- 返回值
成功：成功执行时，返回接收到的字节数。，失败：返回-1。
剩下的函数请参考TCP中的函数：linux网络编程——TCP编程-CSDN博客
现在分别实现server 程序和client 程序。
server程序
在这个函数中参照server图进行编程，将图中所有函数挨个实现即可。
图 4server
具体实现看代码：
#include <sys/types.h> /* See NOTES */#include <sys/socket.h>#include <stdio.h>#include <stdlib.h>#include <errno.h>#include <string.h>#include <netinet/in.h>#include <sys/wait.h>#include <unistd.h>#include <arpa/inet.h>#include <pthread.h>/** 服务器端程序* socket* bind* sendto/recvfrom* close*/#define PORT 8888struct Param {int sockfd;char* buff;struct sockaddr* src_addr;};// 接收数据在子线程中处理void* Receive_data(void* Param1){struct Param Param2 = *(struct Param*)Param1;while (1){// 接收数据int addr_len = sizeof(Param2.src_addr);int iRecvLen = recvfrom(Param2.sockfd, Param2.buff, sizeof(Param2.buff), 0, Param2.src_addr, &addr_len);if (iRecvLen > 0){Param2.buff[iRecvLen] = '\0';// inet_ntoa(tSocketClientAddr.sin_addr)是将IP地址转换为字符串的函数printf("Get Msg From Client: %s: %s\n", inet_ntoa(((struct sockaddr_in*)Param2.src_addr)->sin_addr), Param2.buff);}}}int main(int argc, char** argv){int isocketfd;int Client_socketfd;int ret;struct sockaddr_in my_addr;struct sockaddr_in Client_addr;char send_buf[1024];char buff[1000];struct Param Param1;pthread_t ntid;// SOCK_DGRAM是UDP协议，AF_INET表示IPv4协议isocketfd = socket(AF_INET, SOCK_DGRAM, 0);if (-1 == isocketfd){printf("create socket failed!\n");return -1;}// 配置bind函数的地址信息my_addr.sin_family = AF_INET; //指定协议族为IPV4版本的TCP/IP协议族my_addr.sin_port = htons(PORT); //指定端口号（和客户端通信的端口号，两者必须一致）my_addr.sin_addr.s_addr = htonl(INADDR_ANY); //指定IP地址，这里设置为INADDR_ANY，表示可以接收任何来源的连接请求ret = bind(isocketfd, (const struct sockaddr*)&my_addr,sizeof(struct sockaddr));if (-1 == ret){printf("bind socket failed!\n");return -1;}Param1.sockfd = isocketfd;Param1.buff = buff;Param1.src_addr = (struct sockaddr*)&Client_addr;ret = pthread_create(&ntid, NULL, Receive_data, &Param1);if (ret){printf("create pthread failed!\n");return -1;}while (1){// 发送数据if (fgets(send_buf, sizeof(send_buf), stdin)){sendto(isocketfd, send_buf, strlen(send_buf), 0, (struct sockaddr*)&Client_addr, sizeof(Client_addr));}}close(isocketfd);return 0;}这里使用了多线程将发送和接收数据分开，实现发送和接收数据互不干涉，其中pthread_create()函数是创建一个线程，具体函数分析见pthread_create()章节，这里将接收数据放入了创建的子线程中，主函数中实现发送函数。
图 5服务器端测试结果
这里获得的数据，其中192.168.147.132的IP是客户端的数据。
client 程序
在客户端的程序中，基本思路还是和之前服务器的程序相同，都是使用多线程将接收数据放入了创建的子线程中，还是依照韦老师的图：
图 6client
依次实现如上函数即可，具体实现如下代码：
#include <sys/types.h> /* See NOTES */#include <sys/socket.h>#include <stdio.h>#include <stdlib.h>#include <errno.h>#include <string.h>#include <netinet/in.h>#include <sys/wait.h>#include <unistd.h>#include <arpa/inet.h>#include <pthread.h>/** UDP客户端程序* socket* send* close*/#define PORT 8888// 线程参数结构体struct Param {int sockfd;char* buff;struct sockaddr* src_addr;};// 接收数据在子线程中处理void* Receive_data(void* Param1){struct Param Param2 = *(struct Param*)Param1;while (1){// 接收数据int addr_len = sizeof(Param2.src_addr);int iRecvLen = recvfrom(Param2.sockfd, Param2.buff, sizeof(Param2.buff), 0, Param2.src_addr, &addr_len);if (iRecvLen > 0){Param2.buff[iRecvLen] = '\0';// inet_ntoa(tSocketClientAddr.sin_addr)是将IP地址转换为字符串的函数printf("Get Msg From Client: %s: %s\n", inet_ntoa(((struct sockaddr_in*)Param2.src_addr)->sin_addr), Param2.buff);}else if (iRecvLen == -1){perror("recvfrom failed");break;}}}int main(int argc, char** argv){int isocketfd;struct sockaddr_in client_addr;char send_buf[1024];struct Param Param1;pthread_t ntid;char reve_buff[1024];memset(send_buf, 0, sizeof(send_buf));if (argc < 2){printf("Usage: %s ip_address\n", argv[0]);return -1;}client_addr.sin_family = AF_INET; //指定协议族为IPV4版本的TCP/IP协议族client_addr.sin_port = htons(PORT); //指定端口号//指定IP地址，htons()函数是将一个本地字节序的short转为网络字节序的shortclient_addr.sin_addr.s_addr = inet_addr(argv[1]);isocketfd = socket(AF_INET, SOCK_DGRAM, 0);if (-1 == isocketfd){printf("create socket failed!\n");return -1;}Param1.sockfd = isocketfd;Param1.buff = reve_buff;Param1.src_addr = (struct sockaddr*)&client_addr;int ret = pthread_create(&ntid, NULL, Receive_data, &Param1);if (ret){printf("create pthread failed!\n");return -1;}while (1){if (fgets(send_buf, sizeof(send_buf), stdin)){sendto(isocketfd, send_buf, strlen(send_buf), 0, (struct sockaddr*)&client_addr, sizeof(client_addr));}}return 0;}
图 7客户端测试结果
连接成功后即可发送和接收数据。
pthread_create()
函数结构
#include <pthread.h>int pthread_create(pthread_t* restrict tidp,const pthread_attr_t* restrict_attr,void* (*start_rtn)(void*),void *restrict arg);描述
用来创建线程，并向线程函数传递参数。
参数
- tidp
事先创建好的pthread_t类型的参数。成功时tidp指向的内存单元被设置为新创建线程的线程ID。
- attr
用于定制各种不同的线程属性。通常直接设为NULL。
- start_rtn
新创建线程从此函数开始运行。无参数时arg设为NULL即可。
- arg
start_rtn函数的参数。无参数时设为NULL即可。有参数时输入参数的地址。当多于一个参数时应当使用结构体传入。
- 返回值
成功：返回0，失败：返回错误码。
