1 /** UDP并发服务器--server端程序**/
 2 #include <sys/types.h>
 3 #include <sys/socket.h>
 4 #include <netinet/in.h>
 5 #include <time.h>
 6 #include <string.h>
 7 #include <stdio.h>
 8 #define BUFFLEN 1024
 9 #define SERVER_PORT 12347
10 #define BACKLOG 5
11
12 static void handle_request(int s, struct sockaddr_in* from, char *buff)
13 {
14     time_t now;
15     int len = sizeof(*from);
16     memset(buff, 0, BUFFLEN);
17     now = time(NULL);
18     sprintf(buff, "%24s\r\n",ctime(&now));
19     sendto(s, buff, strlen(buff),0, (struct sockaddr*)from, len);/*发送数据*/
20 }
21
22 static void handle_connect(int s_s)
23 {
24     struct sockaddr_in from;    /*客户端地址*/
25     int len = sizeof(from);
26     int n = 0;
27     char buff[BUFFLEN];
28
29     /*主处理过程*/
30     while(1)
31     {
32         memset(buff, 0, BUFFLEN);
33         /*接收客户端连接*/
34         n = recvfrom(s_s, buff, BUFFLEN,0,(struct sockaddr*)&from, &len);/*接收发送方数据*/
35         if(n > 0 && !strncmp(buff, "TIME", 4))/*判断是否合法接收数据*/
36         {
37             /*创建进程进行数据处理*/
38             if(!fork())
39             {
40                 handle_request(s_s, &from, buff);/*处理连接请求*/
41                 return ;
42             }
43         }
44     }
45 }
46
47
48 int main(int argc, char *argv[])
49 {
50     int s_s;    /*服务器套接字文件描述符*/
51     struct sockaddr_in local;    /*本地地址*/
52
53     /*建立TCP套接字*/
54     s_s = socket(AF_INET, SOCK_STREAM, 0);
55
56     /*初始化地址接哦股*/
57     memset(&local, 0, sizeof(local));
58     local.sin_family = AF_INET;/*AF_INET协议族*/
59     local.sin_addr.s_addr = htonl(INADDR_ANY);/*任意本地地址*/
60     local.sin_port = htons(SERVER_PORT);/*服务器端口*/
61
62     /*将套接字文件描述符绑定到本地地址和端口*/
63     int err = bind(s_s, (struct sockaddr*)&local, sizeof(local));
64
65     /*处理客户端连接*/
66     handle_connect(s_s);
67
68     close(s_s);
69
70     return 0;
71 }

 1 /** TCP并发服务器--server端程序**/
 2 #include <sys/types.h>
 3 #include <sys/socket.h>
 4 #include <netinet/in.h>
 5 #include <time.h>
 6 #include <string.h>
 7 #include <stdio.h>
 8 #define BUFFLEN 1024
 9 #define SERVER_PORT 12347
10 #define BACKLOG 5
11
12 static void handle_request(int s_c)
13 {
14     time_t now;
15     char buff[BUFFLEN];
16     int n = 0;
17     memset(buff, 0, BUFFLEN);
18     n = recv(s_c, buff, BUFFLEN,0);/*接收发送方数据*/
19     if(n > 0 && !strncmp(buff, "TIME", 4))/*判断是否合法接收数据*/
20     {
21         memset(buff, 0, BUFFLEN);
22         now = time(NULL);
23         sprintf(buff, "%24s\r\n",ctime(&now));
24         send(s_c, buff, strlen(buff),0);/*发送数据*/
25     }
26     /*关闭客户端*/
27     close(s_c);
28 }
29
30 static void handle_connect(int s_s)
31 {
32     int s_c;    /*客户端套接字文件描述符*/
33     struct sockaddr_in from;    /*客户端地址*/
34     int len = sizeof(from);
35
36     /*主处理过程*/
37     while(1)
38     {
39         /*接收客户端连接*/
40         s_c = accept(s_s, (struct sockaddr*)&from, &len);
41         if(s_c > 0)/*客户端成功连接*/
42         {
43             /*创建进程进行数据处理*/
44             if(fork() > 0)/*父进程*/
45             {
46                 close(s_c);/*关闭父进程的客户端连接套接字*/
47             }
48             else
49             {
50                 handle_request(s_c);/*处理连接请求*/
51                 return ;
52             }
53         }
54     }
55 }
56
57
58 int main(int argc, char *argv[])
59 {
60     int s_s;    /*服务器套接字文件描述符*/
61     struct sockaddr_in local;    /*本地地址*/
62
63     /*建立TCP套接字*/
64     s_s = socket(AF_INET, SOCK_STREAM, 0);
65
66     /*初始化地址*/
67     memset(&local, 0, sizeof(local));
68     local.sin_family = AF_INET;/*AF_INET协议族*/
69     local.sin_addr.s_addr = htonl(INADDR_ANY);/*任意本地地址*/
70     local.sin_port = htons(SERVER_PORT);/*服务器端口*/
71
72     /*将套接字文件描述符绑定到本地地址和端口*/
73     int err = bind(s_s, (struct sockaddr*)&local, sizeof(local));
74     err = listen(s_s, BACKLOG);/*侦听*/
75
76     /*处理客户端连接*/
77     handle_connect(s_s);
78
79     close(s_s);
80
81     return 0;
82 }