一、基本的udp socket编程1. UDP编程框架
2. UDP程序设计常用函数
#include
#include
int socket(int domain, int type, int protocol);
参数domain:用于设置网络通信的域，socket根据这个参数选择信息协议的族
Name Purpose
AF_UNIX, AF_LOCAL Local communication
AF_INET IPv4 Internet protocols //用于IPV4
AF_INET6 IPv6 Internet protocols //用于IPV6
AF_IPX IPX - Novell protocols
AF_NETLINK Kernel user interface device
AF_X25 ITU-T X.25 / ISO-8208 protocol
AF_AX25 Amateur radio AX.25 protocol
AF_ATMPVC Access to raw ATM PVCs
AF_APPLETALK AppleTalk
AF_PACKET Low level packet interface
AF_ALG Interface to kernel crypto API小插曲：PF_XXX和AF_XXXSOCK_STREAMProvides sequenced, reliable, two-way, connection-based byte streams. //用于TCPSOCK_DGRAMSupports datagrams (connectionless, unreliable messages ). //用于UDPSOCK_RAWProvides raw network protocol access. //RAW类型，用于提供原始网络访问
#include
#include
ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
const struct sockaddr *dest_addr, socklen_t addrlen);第一个参数sockfd:正在监听端口的套接口文件描述符鸟哥的linux私房菜，通过socket获得第二个参数buf：发送缓冲区，往往是使用者定义的数组，该数组装有要发送的数据第三个参数len:发送缓冲区的大小，单位是字节第四个参数flags:填0即可第五个参数dest_addr:指向接收数据的主机地址信息的结构体，也就是该参数指定数据要发送到哪个主机哪个进程第六个参数addrlen:表示第五个参数所指向内容的长度
#include
#include
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
struct sockaddr *src_addr, socklen_t *addrlen);第一个参数sockfd:正在监听端口的套接口文件描述符，通过socket获得第二个参数buf：接收缓冲区，往往是使用者定义的数组，该数组装有接收到的数据第三个参数len:接收缓冲区的大小，单位是字节第四个参数flags:填0即可第五个参数src_addr:指向发送数据的主机地址信息的结构体，也就是我们可以从该参数获取到数据是谁发出的第六个参数addrlen:表示第五个参数所指向内容的长度
#include
#include
int bind(int sockfd, const struct sockaddr* my_addr, socklen_t addrlen);
第一个参数sockfd:正在监听端口的套接口文件描述符linux使用socket通信，通过socket获得第二个参数my_addr:需要绑定的IP和端口第三个参数addrlen：my_addr的结构体的大小
#include
int close(int fd);3. 搭建UDP通信框架
server：
1 #include
2 #include
3 #include
4 #include
5 #include
6
7 #define SERVER_PORT 8888
8 #define BUFF_LEN 1024
9
10 void handle_udp_msg(int fd)
11 {
12 char buf[BUFF_LEN]; //接收缓冲区，1024字节
13 socklen_t len;
14 int count;
15 struct sockaddr_in clent_addr; //clent_addr用于记录发送方的地址信息
16 while(1)
17 {
18 memset(buf, 0, BUFF_LEN);
19 len = sizeof(clent_addr);
20 count = recvfrom(fd, buf, BUFF_LEN, 0, (struct sockaddr*)&clent_addr, &len); //recvfrom是拥塞函数，没有数据就一直拥塞
21 if(count == -1)
22 {
23 printf("recieve data fail!n");
24 return;
25 }
26 printf("client:%sn",buf); //打印client发过来的信息
27 memset(buf, 0, BUFF_LEN);
28 sprintf(buf, "I have recieved %d bytes data!n", count); //回复client
29 printf("server:%sn",buf); //打印自己发送的信息给
30 sendto(fd, buf, BUFF_LEN, 0, (struct sockaddr*)&clent_addr, len); //发送信息给client，注意使用了clent_addr结构体指针
31
32 }
33 }
34
35
36 /*
37 server:
38 socket-->bind-->recvfrom-->sendto-->close
39 */
40
41 int main(int argc, char* argv[])
42 {
43 int server_fd, ret;
44 struct sockaddr_in ser_addr;
45
46 server_fd = socket(AF_INET, SOCK_DGRAM, 0); //AF_INET:IPV4;SOCK_DGRAM:UDP
47 if(server_fd < 0)
48 {
49 printf("create socket fail!n");
50 return -1;
51 }
52
53 memset(&ser_addr, 0, sizeof(ser_addr));
54 ser_addr.sin_family = AF_INET;
55 ser_addr.sin_addr.s_addr = htonl(INADDR_ANY); //IP地址，需要进行网络序转换，INADDR_ANY：本地地址
56 ser_addr.sin_port = htons(SERVER_PORT); //端口号，需要网络序转换
57
58 ret = bind(server_fd, (struct sockaddr*)&ser_addr, sizeof(ser_addr));
59 if(ret < 0)
60 {
61 printf("socket bind fail!n");
62 return -1;
63 }
64
65 handle_udp_msg(server_fd); //处理接收到的数据
66
67 close(server_fd);
68 return 0;
69 }
client：
1 #include
2 #include
3 #include
4 #include
5 #include
6
7 #define SERVER_PORT 8888
8 #define BUFF_LEN 512
9 #define SERVER_IP "172.0.5.182"
10
11
12 void udp_msg_sender(int fd, struct sockaddr* dst)
13 {
14
15 socklen_t len;
16 struct sockaddr_in src;
17 while(1)
18 {
19 char buf[BUFF_LEN] = "TEST UDP MSG!n";
20 len = sizeof(*dst);
21 printf("client:%sn",buf); //打印自己发送的信息
22 sendto(fd, buf, BUFF_LEN, 0, dst, len);
23 memset(buf, 0, BUFF_LEN);
24 recvfrom(fd, buf, BUFF_LEN, 0, (struct sockaddr*)&src, &len); //接收来自server的信息
25 printf("server:%sn",buf);
26 sleep(1); //一秒发送一次消息
27 }
28 }
29
30 /*
31 client:
32 socket-->sendto-->revcfrom-->close
33 */
34
35 int main(int argc, char* argv[])
36 {
37 int client_fd;
38 struct sockaddr_in ser_addr;
39
40 client_fd = socket(AF_INET, SOCK_DGRAM, 0);
41 if(client_fd
49 //ser_addr.sin_addr.s_addr = inet_addr(SERVER_IP);
50 ser_addr.sin_addr.s_addr = htonl(INADDR_ANY); //注意网络序转换
51 ser_addr.sin_port = htons(SERVER_PORT); //注意网络序转换
52
53 udp_msg_sender(client_fd, (struct sockaddr*)&ser_addr);
54
55 close(client_fd);
56
57 return 0;
58 }server端：
client端：
server端：
client端：
二、高级udp socket编程1. udp的connect函数未连接的UDP套接字已连接的UDP套接字连接套接字输出第一个数据报断开套接字连接连接套接字输出第二个数据报断开套接字连接连接套接字输出第一个数据报输出第二个数据报
void udp_handler(int s, struct sockaddr* to)
{
char buf[1024] = "TEST UDP !";
int n = 0;
connect(s, to, sizeof(*to);
n = write(s, buf, 1024);
read(s, buf, n);
}2. udp报文丢失问题使用信号SIGALRM为recvfrom设置超时。首先我们为SIGALARM建立一个信号处理函数，并在每次调用前通过alarm设置一个5秒的超时。如果recvfrom被我们的信号处理函数中断了linux使用socket通信，那就超时重发信息；若正常读到数据了linux定时器，就关闭报警时钟并继续进行下去。使用select为recvfrom设置超时
设置select函数的第五个参数即可。3. udp报文乱序问题4. udp流量控制问题
