我想用父进程发送，子进程只做接收。
我的代码给你看看，我是新手，希望您可以帮我下，谢谢。
#include
#include
#include
#include
#include
#include
#include
#define PORT 1500
#define BACKLOG 1
#define MAXDATASIZE 100
void process_recv(int connectfd, struct sockaddr_in client);
void process_send(FILE *fp,int connectfd);
char* getMessage(char* sendbuf,int len,FILE* fp);
main()
{
int listenfd,connetfd;
pid_t pid;
struct sockaddr_in server;
struct sockaddr_in clinet;
socklen_t addrlen;
if((listenfd = socket(AF_INET,SOCK_STREAM,0)) == -1)
{
perror("socket() error.");
exit(1);
}
int opt = SO_REUSEADDR;
setsockopt(listenfd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
bzero(&server,sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(PORT);
server.sin_addr.s_addr = htonl(INADDR_ANY);
if (bind(listenfd,(struct sockaddr *)&server,sizeof(server)) == -1)
{
perror("Bind() error.");
exit(1);
}
if (listen(listenfd,BACKLOG) == -1)
{
perror("listen() error.\n");
exit(1);
}
addrlen = sizeof(clinet);
if ((connetfd = accept(listenfd,(struct sockaddr*)&clinet,&addrlen)) == -1)
{
perror("accept() error.\n");
exit(1);
}
if ((pid = fork())>0)
{
process_send(stdin,connetfd);
}
else if (pid = 0)
{
process_recv(connetfd,clinet);
}
else
{
printf("fork() error\n");
exit(0);
}
close(connetfd);
close(listenfd);
}
void process_recv(int connectfd,struct sockaddr_in client)
{
int num;
char recvbuf[MAXDATASIZE],sendbuf[MAXDATASIZE],cli_name[MAXDATASIZE];
printf("You got a connection from %s.",inet_ntoa(client.sin_addr));
if(num == 0)
{
close(connectfd);
printf("Client disconnected.\n");
return;
}
cli_name[num-1]='\0';
printf("Client's name is %s.\n",cli_name);
while(num =recv(connectfd,recvbuf,MAXDATASIZE,0))
{
recvbuf[num] = '\0';
printf("Receive client (%s) message: %s",cli_name,recvbuf);
}
}
void process_send(FILE *fp,int connectfd)
{
char sendbuf[MAXDATASIZE];
while (getMessage(sendbuf,MAXDATASIZE,fp) != NULL)
{
send(connectfd,sendbuf,strlen(sendbuf),0);
}
printf("\nExit.\n");
}
char* getMessage(char* sendbuf,int len,FILE* fp)
{
printf("Input string to server:");
printf(fgets(sendbuf,MAXDATASIZE,fp));
}
这是一个服务器程序 （我是想让服务器和客户端自由聊天，服务器上的父进程用来发送信息。同时产生的子进程用来接收客户端发来的信息并显示出来）现在的情况是出现
fork() error 我不明的为什么会建不成功
还有一个客户端，因为字数不够，我就发到另个问题上了，
这是客户端程序：
http://zhidao.baidu.com/question/209826351.html
|
