求高手解答 linux实现服务器转发信息，让每个客户端自由通信！！！【linux编程吧】

本人写的服务器：
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <errno.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>
#include <netdb.h>
void sig_handler(int signo)
{     pid_t pid;
     int stat;
     pid=waitpid(-1,&stat,WNOHANG);
     while(pid>0){
         printf("child process terminated (PID: %ld)\n",(long)getpid());
         pid=waitpid(-1,&stat,WNOHANG);
     }
     return;
}
int main(int argc,char *argv[])
{
     socklen_t clt_addr_len;
     int listen_fd;
     int com_fd;
     int ret;
     int i;
     static char recv_buf[1024];
     int len;
     int port;
     pid_t pid;
     struct sockaddr_in clt_addr;
     struct sockaddr_in srv_addr;
     if(argc!=2){
         printf("Usage: %s port\n",argv[0]);
         return 1;
     }
     port=atoi(argv[1]);
     if(signal(SIGCHLD,sig_handler)<0){
         perror("cannot set the signal");
         return 1;
     }
     listen_fd=socket(PF_INET,SOCK_STREAM,0);
     if(listen_fd<0){
         perror("cannot create listening socket");
         return 1;
     }
     memset(&srv_addr,0,sizeof(srv_addr));
     srv_addr.sin_family=AF_INET;
     srv_addr.sin_addr.s_addr=htonl(INADDR_ANY);
     srv_addr.sin_port=htons(port);
     ret=bind(listen_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
     if(ret==-1){
         perror("cannot bind server socket");
         close(listen_fd);
         return 1;
     }
     ret=listen(listen_fd,5);
     if(ret==-1){
         perror("cannot listen the client connect request");
         close(listen_fd);
         return 1;

     }
         while(1){
         len=sizeof(clt_addr);
         com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);
         if(com_fd<0){
             if(errno==EINTR){
                 continue;
             }else{
                 perror("cannot accept client connect request");
                 close(listen_fd);
                 return 1;
             }
         }

                 printf("%d\n",com_fd);
                 printf("%s\n",inet_ntoa(clt_addr.sin_addr));
         pid=vfork();
         if(pid<0){perror("cannot create the child process");
             close(listen_fd);
             return 1;
         }else if(pid==0){
             while((len=read(com_fd,recv_buf,1024))>0){
                                 printf("%d\n",com_fd);
                 recv_buf[len] = '\0';
                 printf("Message from client(%d): %s\n",len,recv_buf);
                 if(recv_buf[0]=='@')
                     break;
                 for(i=0;i<len;i++)
                     recv_buf[i]=toupper(recv_buf[i]);

                 write(com_fd,recv_buf,len);
             }
         close(com_fd);
         return 0;
         }else
             close(com_fd);
     }
         return 0;
}
客户端：
#include<stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/un.h>
#include<netdb.h>
#include<unistd.h>
int main(int argc,char *argv[])
{
     int connect_fd;
     int ret;
     char snd_buf[1024];
     int i;
     int port;
     int len;
     static struct sockaddr_in srv_addr;
     if(argc!=3)
       {
         printf("Usage:%s server_ip_address port\n",argv[0]);
         return 1;
       }

     port=atoi(argv[2]);
     connect_fd=socket(PF_INET,SOCK_STREAM,0);
     if(connect_fd<0)
         {
           perror("Cannot create communication scoket");
           return 1;
         }
     memset(&srv_addr,0,sizeof(srv_addr));
     srv_addr.sin_family=AF_INET;
     srv_addr.sin_addr.s_addr=inet_addr(argv[1]);
     srv_addr.sin_port=htons(port);
     ret=connect(connect_fd,(struct sockaddr*)&srv_addr,sizeof(srv_addr));
     if(ret==-1)
         {
         perror("cannot connect to the server");
         close(connect_fd);
         return 1;
         }

     memset(snd_buf,0,1024);
     while(1)
       {
           write(STDOUT_FILENO,"input message:",14);
           len=read(STDIN_FILENO,snd_buf,1024);
           if(len>0)
               {
                 write(connect_fd,snd_buf,len);
               }
         len=read(connect_fd,snd_buf,len);
         if(len>0)
             {
             snd_buf[len]='\0';
             printf("Message from server:%s\n",snd_buf);
             }

          if(snd_buf[0]=='@') break;
       }

    close(connect_fd);
    return 0;
}
现在服务器与客户端通信是单一的，即不能使两个客户端自由通信，请问有什么技术或者方法，可以使多个服务器之间可以相互通信。像QQ一样，高手帮帮忙!!x谢谢！！
大家留意一下服务器代码里面那句：com_fd=accept(listen_fd,(struct sockaddr*)&clt_addr,&len);
这个com_fd无论接受了多少个连接，都不会发生变化，为什么呢？理论上每有一个新连接产生，就会有一个新com_fd出现啊，真奇怪。

你那连接不是在父进程中都关闭了，他还变化啥了

日	一	二	三	四	五	六

求高手解答 linux实现服务器转发信息，让每个客户端自由通信！！！

扫二维码下载贴吧客户端