C/S架构学习之基于UDP的本地通信（服务器）

• 基于UDP的本地通信（服务器）：
• 创建流程：
• 一、创建数据报式套接字（socket函数）：

		int sock_fd = socket(AF_UNIX,SOCK_DGRAM,0);
	    if(-1 == sock_fd)
	    {
	        perror("socket error");
	        exit(-1);
	    }
1
2
3
4
5
6

• 二、创建服务器和客户机的本地网络信息结构体并填充服务器本地网络信息结构体 （struct sockaddr_un）:
• 本地网络信息结构体：

	#include 
	struct sockaddr_un {
	    sa_family_t sun_family;               //AF_UNIX
	    char        sun_path[108];            //pathname
	};
1
2
3
4
5

		struct sockaddr_un serveraddr,clientaddr;
	    socklen_t serveraddr_len = sizeof(serveraddr);
	    socklen_t clientaddr_len = sizeof(clientaddr);
	
	    memset(&serveraddr,0,serveraddr_len);
	    memset(&clientaddr,0,clientaddr_len);
	
	    serveraddr.sun_family = AF_UNIX;
	    strcpy(serveraddr.sun_path,"./udpserver");
1
2
3
4
5
6
7
8
9

• 三、绑定数据报式套接字（bind函数）：、

		if(-1 == bind(sock_fd,(struct sockaddr *)&serveraddr,serveraddr_len))
	    {
	        perror("bind error");
	        exit(-1);
	    }
1
2
3
4
5

• 四、服务器端收发数据（recvfrom函数、sendto函数）：

            memset(buf,0,sizeof(buf));
	
	        int ret1 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&clientaddr,&clientaddr_len);
	        if(-1 == ret1)
	        {
	            perror("recvfrom error");
	            exit(-1);
	        }
	        printf("客户端[%s]发来消息[%s]\n",clientaddr.sun_path,buf);
	
	        //发送应答消息
	        strcat(buf,"---------k");
	
	        int ret2 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&clientaddr,clientaddr_len);
	        if(-1 == ret2)
	        {
	            perror("sendto error");
	            exit(-1);
	        }
	
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

• 五、关闭套接字（close函数）：

	close(sock_fd);
1

• 示例代码：

	#include 
	#include 
	#include 
	
	#include 
	#include 
	
	#include 
	#include 
	#include 
	
	#include 
	#include 
	
	int main(int argc, char const *argv[])
	{
	    //创建套接字
	    int sock_fd = socket(AF_UNIX,SOCK_DGRAM,0);
	    if(-1 == sock_fd)
	    {
	        perror("socket error");
	        exit(-1);
	    }
	    //填充网络信息结构体
	
	    struct sockaddr_un serveraddr,clientaddr;
	    socklen_t serveraddr_len = sizeof(serveraddr);
	    socklen_t clientaddr_len = sizeof(clientaddr);
	
	    memset(&serveraddr,0,serveraddr_len);
	    memset(&clientaddr,0,clientaddr_len);
	
	    serveraddr.sun_family = AF_UNIX;
	    strcpy(serveraddr.sun_path,"./udpserver");
	
	
	    //绑定套接字
	    if(-1 == bind(sock_fd,(struct sockaddr *)&serveraddr,serveraddr_len))
	    {
	        perror("bind error");
	        exit(-1);
	    }
	
	    printf("基于UDP的本地通信服务器启动!!!\n");
	
	    char buf[128] = {0};
	    //收发数据
	    while(true)
	    {
	        memset(buf,0,sizeof(buf));
	
	        int ret1 = recvfrom(sock_fd,buf,sizeof(buf),0,(struct sockaddr*)&clientaddr,&clientaddr_len);
	        if(-1 == ret1)
	        {
	            perror("recvfrom error");
	            exit(-1);
	        }
	        printf("客户端[%s]发来消息[%s]\n",clientaddr.sun_path,buf);
	
	        //发送应答消息
	        strcat(buf,"---------k");
	
	        int ret2 = sendto(sock_fd,buf,sizeof(buf),0,(struct sockaddr *)&clientaddr,clientaddr_len);
	        if(-1 == ret2)
	        {
	            perror("sendto error");
	            exit(-1);
	        }
	
	
	    }
	    //关闭套接字
	    close(sock_fd);
	
	    return 0;
	}


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

• 运行结果：

	基于UDP的本地通信服务器启动!!!
	客户端[./udpclient]发来消息[hello]
	客户端[./udpclient]发来消息[I Love China!!!]
	客户端[./udpclient]发来消息[miss U]
1
2
3
4

• 特别注意：
• strcpy(serveraddr.sun_path,"./udpserver");中udpserver文件是套接字文件；
• 如下所示：

	srwxrwxr-x 1 linux linux     0 11月 11 01:18 udpserver
1