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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
| #include <stdio.h>
#include <stdlib.h>
#include <sys/types.h> /* See NOTES */
#include <sys/socket.h>
#include <unistd.h>
#include <errno.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <arpa/inet.h>
#include <string.h>
#include <signal.h>
void handle(int sign)
{
printf("sign = %d\n", sign);
exit(EXIT_SUCCESS);
}
int main()
{
int listenfd;
struct sockaddr_in servaddr;//一个服务器的地址
//listenfd = socket(AF_INET, SOCK_STREAM, 0);
////和下面的一样,第三个参数为0表示自动获取协议。
listenfd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
if(listenfd < 0)
{
perror("创建scoket失败\n");
exit(EXIT_FAILURE);//退出程序
}
memset(&servaddr, 0, sizeof(servaddr));//初始化地址
servaddr.sin_family = AF_INET;//地址族
servaddr.sin_port = htons(5188);//端口号，网络字节序转化为主机字节序
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//表示绑定本机的任意地址(返回一个主机字节序)--->和下面的两个一样作用绑定IP地址
//servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");//(和上面的一样的意思)指定网络地址---> 真实的情况下表示本机的ip地址
//inet_aton("127.0.0.1", &servaddr.sin_addr);//绑定IP地址
int on = 1;
on = setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on));
if(on < 0)
{
printf("端口重复利用失败\n");
exit(EXIT_FAILURE);
}
if(bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)
{
perror("绑定本地地址到套接字失败\n");
exit(EXIT_FAILURE);
}
if(listen(listenfd, SOMAXCONN) < 0)
{
perror("绑定本地地址到套接字失败\n");
exit(EXIT_FAILURE);
}
struct sockaddr_in peeraddr;
socklen_t peerlen = sizeof(peeraddr);//必须有初始值，否则accept会失败
int conn = -1;
if((conn = accept(listenfd, (struct sockaddr *)&peeraddr, &peerlen) )< 0)
{
perror("接收连接失败\n");
exit(EXIT_FAILURE);
}
pid_t pid;
pid = fork();
if(pid < 0)
{
perror("创建进程失败\n");
exit(EXIT_FAILURE);
}
else if(pid == 0)//子进程发送数据
{
signal(SIGUSR1, handle);
char sendbuf[1024] = {0};
while(fgets(sendbuf, sizeof(sendbuf), stdin) != NULL)
{
write(conn, sendbuf, strlen(sendbuf));
memset(sendbuf, 0, sizeof(sendbuf));
}
}
else//父进程接收数据
{
char recvbuf[1024] = {0};
while(1)
{
fflush(stdin);
memset(recvbuf, 0, sizeof(recvbuf));
int ret = read(conn, recvbuf, sizeof(recvbuf));
if(ret == -1)
{
printf("获取客户端的数据失败\n");
break;
//exit(EXIT_FAILURE);
}
else if(ret == 0)
{
printf("客户端关闭连接\n");
break;
//exit(EXIT_SUCCESS);
}
printf("服务器接收到的数据:");
fputs(recvbuf, stdout);
//write(conn, recvbuf, ret);
}
close(conn);
printf("parent die\n");
kill(pid, SIGUSR1);
exit(EXIT_SUCCESS);
}
close(listenfd);
close(conn);
return 0;
}
|