tcp_echo_svr.c

linux下的多个网络通讯的例子 可多参考下

/* TCP 服务器 演示代码 */
#include <stdio.h>                                       
#include <stdlib.h>                                      
#include <errno.h>                                       
#include <string.h>                                      
#include <sys/types.h>                                   
#include <netinet/in.h>                                  
#include <sys/socket.h>                                  
#include <sys/wait.h>  
	
#define MYPORT 4950  	
	
main(int argc,char * argv[]) {       
	                                          
		int sockfd,new_fd;                                       
		struct sockaddr_in my_addr;                              
		struct sockaddr_in their_addr;                           
		int sin_size,numbytes;    
		
		unsigned short port;
		
		char buff[1024];
		
		if(argc < 2)
		{
		  printf("tcp_server port \n");
		  exit(-1);
		}
	
   
		port = (unsigned short ) atoi(argv[1]);   
		
		//第一步:建立TCP套接字 Socket  
		//         AF_INET --> ip通讯
		//				 SOCK_STREAM -->TCP                             
		if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1) {       
			perror("socket");                                        
			exit(1);                                                 
		}  
		  
		
		//第二步:设置侦听端口                                                    
		//初始化结构体，并绑定2323端口 
		
		memset(&my_addr,0,sizeof(struct sockaddr_in)); 
		//memset(&my_addr,0,sizeof(my_addr)); 
		                         
		my_addr.sin_family = AF_INET;     /* ipv4 */                        
		my_addr.sin_port = htons(port);   /* 设置侦听端口是 2323 , 用htons转成网络序*/                       
		my_addr.sin_addr.s_addr = INADDR_ANY;    /* INADDR_ANY来表示任意IP地址可能其通讯 */                 
		//bzero(&(my_addr.sin_zero),8); 
		memset(&(my_addr.sin_zero),0,8);                           
		
		//第三步:绑定套接口,把socket队列与端口关联起来.                                             
		if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct	sockaddr))==-1)                                          
		{                                                        
			perror("bind");                                          
			exit(1);                                                 
		}                                                        
		//第四步:开始在2323端口侦听,是否有客户端发来联接                                         
		if(listen(sockfd,10)==-1) {                              
			perror("listen");                                        
			exit(1);                                                 
		}    
		
		printf("tcp echo server ,listen on %d\n",port);
		//第五步:循环与客户端通讯                                               
		while(1) {                                               
			sin_size = sizeof(struct sockaddr_in); 
			                  
			         
			//如果没有TCP客户端联接，accept将一直阻塞程序                       
			//如果有客户端建立连接，将产生一个全新的套接字 new_fd,专门用于跟这个客户端通读                  
			if((new_fd = accept(sockfd,(struct sockaddr *)&their_addr,&sin_size))==-1)                             
			{                                                        
					perror("accept");                                        
					exit(1);                                                 
			}  
			
			 printf("got packet from %s:%d\n",inet_ntoa(their_addr.sin_addr),ntohs(their_addr.sin_port));                                                       
			//生成一个子进程来完成和客户端的会话，父进程继续监听,
			//如果是一个单进程，某一个client长时间运行，会导致其它客户端得不到响应。
			if(fork()== 0) {                                            
			//5.1 读取从刚创建的socket new_fd,接收客户端发来的信息    
				printf("recv client request\n");
					if((numbytes = recv(new_fd,buff,sizeof(buff),0))==-1)    
					{                                                        
					perror("recv");                                          
					exit(1);                                                 
					}                                                        
					printf("recv len %d\n",numbytes);                                       
					buff[numbytes] = '\0'; 
					printf("packet contains \"%s\"\n",buff); 
					  
					//5.2  将从客户端接收到的信息再发回客户端                     
				//	if(send(new_fd,buff,strlen(buff),0)==-1)                 
					if(send(new_fd,buff,numbytes,0)==-1)                 
							perror("send");
							close(new_fd);                                           
							exit(0);                                                 
					}  
			
					//5.3 用完后,要把子进程创建这个专门新建Socket 关掉                                          
					close(new_fd);                                           
		} 
		//第六步:关闭socket                                                        
		close(sockfd);                                           
}