Linux下IP v6 tcp服务器端源码示例

Linux下IP v6 tcp服务器端源码示例

/******************************
*
* server.c
*
******************************/
#include<stdio.h>  
#include<stdlib.h>  
#include<sys/socket.h>  
#include<sys/types.h>  
#include<errno.h>  
#include<string.h>  
#include<netinet/in.h>  
#include<sys/wait.h>  
#include<unistd.h>  
#include<arpa/inet.h>  
#include<pthread.h>  
   
   
#define MAXBUF 1024  
#define LISNUM 10  
#define DEFULT_PORT 8787  
   
void *connect_to_client(void *data);  
struct sockaddr_in6 serv_addr,client_addr;  
/**************************/
int main(int argc,char *argv[])  
{  
       int sockfd,new_fd;  
       unsigned int serv_port;  
       unsigned int lisnum;  
       char buf[MAXBUF+1];  
         
       printf( "the command is %s [port] [listen_num]\n", argv[0] );  
         
       // 监听起始端口  
       if ( argv[1] != NULL )  
       {  
              serv_port = atoi( argv[1] );  
       }  
       else
       {  
              serv_port = DEFULT_PORT;  
       }  

       // 监听端口个数  
       if ( argv[2] != NULL )  
       {  
              lisnum = atoi(argv[2]);  
       }  
       else
       {  
              lisnum = LISNUM;  
       }  
         
       // 创建socket  
       if ( (sockfd = socket(PF_INET6,SOCK_STREAM,0)) < 0 )  
       {  
              perror("creat socket");  
              exit(1);  
       }  
         
       // 配置服务器地址与端口  
       bzero(&serv_addr, sizeof(serv_addr));  
       serv_addr.sin6_family = AF_INET6;  
       serv_addr.sin6_port = htons(serv_port);  
       serv_addr.sin6_addr = in6addr_any;  
       // 地址绑定操作  
       if ( bind(sockfd, (struct sockaddr *)&serv_addr, sizeof(serv_addr) ) <0 )  
       {  
              perror("bind");  
              exit(1);  
       }  
         
       // 服务器监听  
       if ( listen(sockfd, lisnum) < 0 )  
       {  
              perror("listen");  
              exit(1);  
       }  
         
       while(1)  
       {  
              int len = sizeof(struct sockaddr_in6);  
              if ( (new_fd = accept(sockfd, (struct sockaddr *)&client_addr, &len)) < 0 )  
              {  
                     perror("accept");  
                     exit(errno);  
              }  
              printf("receive the request form %s\n", inet_ntop(AF_INET6, &client_addr, buf, sizeof(buf)));  
                
              // 接收到1个TCP连接则创建1个线程用于数据通讯  
              pthread_t child_thread;  
              if ( pthread_create( &child_thread, NULL, connect_to_client, (void *)new_fd) < 0)  
              {  
                     perror("create thread");  
                     continue;  
              }  
       }  
       close( sockfd );  
         
       return(0);  
}  

/************************************
*
* 子程序:用于处理一个与客户端的连接,由一个线程来执行
*
************************************/
void *connect_to_client(void *data)  
{  
       int i;  
       int client_fd=(int)data;  
       char recv_buf[MAXBUF+1];  
       char send_buf[MAXBUF+1];  
       char buf[MAXBUF+1];  
       while(1)  
       {  
              sprintf( send_buf, ">>" );  
              if ( send(client_fd, send_buf, strlen(send_buf), 0) < 0 )  
              {  
                     perror("send");  
                     continue;  
              }  
                
              // 从客户端接收数据，直到接收到换行符   
              while ( i < MAXBUF-1 )  
              {  
                     if ( recv(client_fd, &recv_buf[i], 1, 0) < 0 )  
                     {  
                            perror("recv");  
                            break;  
                     }  
                       
                     if ( recv_buf[i] == '\n' )  
                     {  
                            break;  
                     }  
                       
                     i++;  
              }  
                
              recv_buf[i] = '\0';  
              i = 0;  
              // 将接收到的数据输出到标准输出  
              printf("receive message from '%s':%s\n",  
                      inet_ntop(AF_INET6, &client_addr.sin6_addr, buf, sizeof(buf)),  
                      recv_buf);  
       }  
}//end sub_function