当前位置: 技术问答>linux和unix
做了一个简单的server,里面使用fork()创建子进程,但是导致不能通信,大家谁知道是怎么回事。
来源: 互联网 发布时间:2015-10-27
本文导语: 就是最简单的sock服务器,监听,然后连接,发送一些信息。 如果不创建子进程,直接往连接端发送就没问题,客户端就能收到,如果使用了fork创建了 子进程,则客户端就收不到。 难道说不能使用这种方式么?但是...
就是最简单的sock服务器,监听,然后连接,发送一些信息。
如果不创建子进程,直接往连接端发送就没问题,客户端就能收到,如果使用了fork创建了
子进程,则客户端就收不到。
难道说不能使用这种方式么?但是我是从网上找的代码,难道也是不对的?
如果不创建子进程,直接往连接端发送就没问题,客户端就能收到,如果使用了fork创建了
子进程,则客户端就收不到。
难道说不能使用这种方式么?但是我是从网上找的代码,难道也是不对的?
|
server端要不断的循环fork(),然后把accept放在child process中。估计就是那个原因,我这儿有个原代玛,希望对你有用。
SERVER:
#include
#include
#include
#include
#include
#include
#include
#include
#define MYPORT 3490 /* 监听的端口 */
#define BACKLOG 10 /* listen的请求接收队列长度 */
void main() {
int sockfd, new_fd; /* 监听端口,数据端口 */
struct sockaddr_in sa; /* 自身的地址信息 */
struct sockaddr_in their_addr; /* 连接对方的地址信息 */
int sin_size;
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror("socket");
exit(1);
}
sa.sin_family = AF_INET;
sa.sin_port = htons(MYPORT); /* 网络字节顺序 */
sa.sin_addr.s_addr = INADDR_ANY; /* 自动填本机IP */
bzero(&(sa.sin_zero), 8); /* 其余部分置0 */
if (bind(sockfd, (struct sockaddr *)&sa, sizeof(sa)) == -1) {
perror("bind");
exit(1);
}
if (listen(sockfd, BACKLOG) == -1) {
perror("listen");
exit(1);
}
/* 主循环 */
while(1) {
sin_size = sizeof(struct sockaddr_in);
new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size))
if (new_fd == -1) {
perror("accept");
continue;
}
printf(”Got connection from %sn", inet_ntoa(their_addr.sin_addr));
if (fork() == 0) {
/* 子进程 */
if (send(new_fd, "Hello, world! n", 14, 0) == -1)
perror("send");
close(new_fd);
exit(0);
}
close(new_fd);
/*清除所有子进程 */
while(waitpid(-1,NULL,WNOHANG) > 0);
}
}
CLIENT:
#include
#include
#include
#include
#include
#include
#include
#include
#define PORT 3490 /* Server的端口 */
#define MAXDATASIZE 100 /*一次可以读的最大字节数 */
int main(int argc, char *argv[])
{
int sockfd, numbytes;
char buf[MAXDATASIZE];
struct hostent *he; /* 主机信息 */
struct sockaddr_in their_addr; /* 对方地址信息 */
if (argc != 2) {
fprintf(stderr,"usage: client hostnamen");
exit(1);
}
/* get the host info */
if ((he=gethostbyname(argv[1])) == NULL) {
/* 注意:获取DNS信息时,显示出错需要用herror而不是perror */
herror("gethostbyname");
exit(1);
}
if ((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1) {
perror("socket");
exit(1);
}
their_addr.sin_family = AF_INET;
their_addr.sin_port = htons(PORT); /* short, NBO */
their_addr.sin_addr = *((struct in_addr *)he->h_addr);
bzero(&(their_addr.sin_zero), 8); /* 其余部分设成0 */
if (connect(sockfd, (struct sockaddr *)&their_addr, sizeof(struct sockaddr)) == -1) {
perror("connect");
exit(1);
}
if ((numbytes=recv(sockfd,buf,MAXDATASIZE,0))==-1) {
perror("recv");
exit(1);
}
buf[numbytes] = '';
printf("Received: %s",buf);
close(sockfd);
return 0;
}
SERVER:
#include
#include
#include
#include
#include
#include
#include
#include
#define MYPORT 3490 /* 监听的端口 */
#define BACKLOG 10 /* listen的请求接收队列长度 */
void main() {
int sockfd, new_fd; /* 监听端口,数据端口 */
struct sockaddr_in sa; /* 自身的地址信息 */
struct sockaddr_in their_addr; /* 连接对方的地址信息 */
int sin_size;
if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
perror("socket");
exit(1);
}
sa.sin_family = AF_INET;
sa.sin_port = htons(MYPORT); /* 网络字节顺序 */
sa.sin_addr.s_addr = INADDR_ANY; /* 自动填本机IP */
bzero(&(sa.sin_zero), 8); /* 其余部分置0 */
if (bind(sockfd, (struct sockaddr *)&sa, sizeof(sa)) == -1) {
perror("bind");
exit(1);
}
if (listen(sockfd, BACKLOG) == -1) {
perror("listen");
exit(1);
}
/* 主循环 */
while(1) {
sin_size = sizeof(struct sockaddr_in);
new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size))
if (new_fd == -1) {
perror("accept");
continue;
}
printf(”Got connection from %sn", inet_ntoa(their_addr.sin_addr));
if (fork() == 0) {
/* 子进程 */
if (send(new_fd, "Hello, world! n", 14, 0) == -1)
perror("send");
close(new_fd);
exit(0);
}
close(new_fd);
/*清除所有子进程 */
while(waitpid(-1,NULL,WNOHANG) > 0);
}
}
CLIENT:
#include
#include
#include
#include
#include
#include
#include
#include
#define PORT 3490 /* Server的端口 */
#define MAXDATASIZE 100 /*一次可以读的最大字节数 */
int main(int argc, char *argv[])
{
int sockfd, numbytes;
char buf[MAXDATASIZE];
struct hostent *he; /* 主机信息 */
struct sockaddr_in their_addr; /* 对方地址信息 */
if (argc != 2) {
fprintf(stderr,"usage: client hostnamen");
exit(1);
}
/* get the host info */
if ((he=gethostbyname(argv[1])) == NULL) {
/* 注意:获取DNS信息时,显示出错需要用herror而不是perror */
herror("gethostbyname");
exit(1);
}
if ((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1) {
perror("socket");
exit(1);
}
their_addr.sin_family = AF_INET;
their_addr.sin_port = htons(PORT); /* short, NBO */
their_addr.sin_addr = *((struct in_addr *)he->h_addr);
bzero(&(their_addr.sin_zero), 8); /* 其余部分设成0 */
if (connect(sockfd, (struct sockaddr *)&their_addr, sizeof(struct sockaddr)) == -1) {
perror("connect");
exit(1);
}
if ((numbytes=recv(sockfd,buf,MAXDATASIZE,0))==-1) {
perror("recv");
exit(1);
}
buf[numbytes] = '';
printf("Received: %s",buf);
close(sockfd);
return 0;
}
|
贴出代码来