新手编程出现关于fork()的小疑点
新手编程出现关于fork()的小问题
代码很简单,就是TCP网络通讯
先上代码好了
Server:
Client:
之后的输出结果:
0, Recevoir un message de: 127.0.0.1
0, Bonjour! Je suis client
代码很简单,就是TCP网络通讯
先上代码好了
Server:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<arpa/inet.h>
#include<netdb.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<unistd.h>
//Vous pouvez changer les paramètres suivantes
#define MAX_MSG_SIZE 10000
#define SERVER_PORT 50001
#define CLIENT_PORT 50002
#define SERVER_ADDR 127.0.0.1
//Le nombre Maximum de connexions arrivées
#define BACKLOG 5
int main(void)
{
int ser_sockfd,cli_sockfd;
struct sockaddr_in ser_addr;
struct sockaddr_in cli_addr;
char msg[MAX_MSG_SIZE];
pid_t fpid;
//Créer le socket d'écoute
ser_sockfd=socket(AF_INET,SOCK_STREAM, 0);
if(ser_sockfd<0)
{
perror("Socket");
exit(1);
}
int addrlen=sizeof(struct sockaddr_in);
memset(&ser_addr, 0, addrlen);
ser_addr.sin_family=AF_INET;
ser_addr.sin_addr.s_addr=htonl(INADDR_ANY);
ser_addr.sin_port=htons(SERVER_PORT);
if(bind(ser_sockfd, (struct sockaddr*)&ser_addr, sizeof(struct sockaddr_in))<0)
{
perror("Bind");
exit(1);
}
if(listen(ser_sockfd,BACKLOG)<0)
{
perror("Listen");
close(ser_sockfd);
exit(1);
}
while(1)
{
cli_sockfd=accept(ser_sockfd, (struct sockaddr*)&cli_addr, &addrlen);
if(cli_sockfd<=0)
perror("Accept");
else
{
fpid=fork();
if(fpid<0)
{
printf("Erreur de processus fils");
exit(1);
}
else if(fpid==0)
{
recv(cli_sockfd,msg,MAX_MSG_SIZE,0);
printf("%d, Recevoir un message de: %s\n", fpid, inet_ntoa(cli_addr.sin_addr));
printf("%d, %s\n", fpid, msg);
strcpy(msg,"Bonjour! Je suis server!");
send(cli_sockfd, msg, sizeof(msg), 0);
close(cli_sockfd);
}
}
}
close(ser_sockfd);
}
Client:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<arpa/inet.h>
#include<netdb.h>
#include<netinet/in.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<unistd.h>
#define MAX_MSG_SIZE 10000
#define SERVER_PORT 50001
#define CLIENT_PORT 50002
#define SERVER_ADDR 127.0.0.1
//int main(void)
int main(int argc, char *argv[])
{
int cli_sockfd;
int addrlen;
char seraddr[14];
struct hostent *hostp;
struct sockaddr_in ser_addr, cli_addr;
char msg[MAX_MSG_SIZE];
if(argc<2){
printf("usage: %s hostname port \n", argv[0]);
exit(1);
}
cli_sockfd=socket(AF_INET, SOCK_STREAM, 0);
if(cli_sockfd<0){
perror("Socket");
exit(1);
}
addrlen=sizeof(struct sockaddr_in);
memset(&ser_addr, 0, addrlen);
cli_addr.sin_family=AF_INET;
cli_addr.sin_addr.s_addr=htonl(INADDR_ANY);
cli_addr.sin_port=htons(CLIENT_PORT);
if(bind(cli_sockfd, (struct sockaddr*)&cli_addr, addrlen)<0){
perror("Bind");
exit(1);
}
memset(&ser_addr, 0, addrlen);
ser_addr.sin_family=AF_INET;
hostp=(struct hostent *)gethostbyname(argv[1]);
//ser_addr.sin_addr.s_addr=inet_addr("127.0.0.1");
ser_addr.sin_addr=*(struct in_addr *) (hostp->h_addr_list[0]);
//ser_addr.sin_port=htons(SERVER_PORT);
ser_addr.sin_port=htons(atoi(argv[2]));
if(connect(cli_sockfd, (struct sockaddr*)&ser_addr, addrlen)<0){
perror("Connection");
close(cli_sockfd);
exit(1);
}
strcpy(msg,"Bonjour! Je suis client");
send(cli_sockfd,msg,sizeof(msg),0);
recv(cli_sockfd,msg,MAX_MSG_SIZE,0);
printf("%s\n",msg);
close(cli_sockfd);
}
之后的输出结果:
0, Recevoir un message de: 127.0.0.1
0, Bonjour! Je suis client