UDP并发服务器(udpserver_bf.cpp)

.基于数据报套接字的服务器回射程序设计

  编写一服务器程序和客户程序，如图1，要求客户每输入一行数据，服 务器接收后加 上echo: 回送给客户程序，当客户输入“q”后退出。

 *****要求分别以循环服务器和并发服务器实现。

【实例截图】

【核心代码】

void child(int new_socket,int clientno)
{
   int n;
   char buffer[1024];
   char *hello = "I got your message"; 
   char r[]="getudp";
   char a[7]; 
   while(1)
{
bzero(buffer,1024);
//来自客户端的读取请求
n = read( new_socket , buffer, 1023); 
if (n < 0)
printf("ERROR reading from socket");
else printf("Type 1 msg rcvd from client %d using tcp :%s\n",clientno, buffer );
  
for(int i=0;i<6;i )
a[i]=buffer[i];
a[6]='\0';
//比较收到的消息是否是getport
if(strcmp(a, r) == 0){

            int udpport;
            //选择空闲端口
            for(int i = 0; i < MAXCLIENTS; i )
            {
                if(freeports[i] == 0)
                {
                    freeports[i] = 1;
                    udpport =ports[i];
                    break;
                }
            }
            sprintf(buffer, "%d",udpport);
            printf("Udpport send to client %d using tcp :%s\n",clientno,buffer );
            //向客户端发送空闲端口并关闭tcp连接
n=write(new_socket , buffer , strlen(buffer));
if (n < 0)
printf("ERROR writing from socket");
printf("---------------close tcp for client %d---------------\n",clientno);
close(new_socket);//close tcp soket
int p= udpserver(buffer,clientno);// 调用udp服务器来处理连接
//udp连接关闭后，释放端口
for(int i = 0; i < MAXCLIENTS; i )
            {
                if(ports[i] == p)
                {
                    freeports[i] = 0;
                    break;
                }
            }
            break;
        }
    printf("Type 2 response send to client %d using tcp :%s\n",clientno,buffer);
    //向客户端发送响应消息
n=write(new_socket , buffer , strlen(buffer));
if (n < 0)
printf("ERROR writing from socket");

}
}
int udpserver(char* udpport,int clientno)
{
int sockfd; 
    char buffer[1024]; 
    int port=atoi(udpport);
    char *hello = "Hello from udp server"; 
    struct sockaddr_in servaddr, cliaddr; 
      
    // 正在创建udp套接字文件描述符
    if ( (sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0 ) { 
        perror("socket creation failed"); 
        exit(EXIT_FAILURE); 
    } 
      
    memset(&servaddr, 0, sizeof(servaddr)); 
    memset(&cliaddr, 0, sizeof(cliaddr)); 
      
    // 填写服务器信息 
    servaddr.sin_family    = AF_INET; // IPv4 
    servaddr.sin_addr.s_addr = INADDR_ANY; 
    servaddr.sin_port = htons(port); 
      
    // bind()系统调用将套接字绑定到服务器地址 
    if ( bind(sockfd, (const struct sockaddr *)&servaddr,  
            sizeof(servaddr)) < 0 ) 
    { 
        perror("bind failed"); 
        exit(EXIT_FAILURE); 
    } 
      
    int len, n; 
  
    len = sizeof(cliaddr);
    char r[]="quitudp";
char a[8];
while(1)
{
bzero(buffer,1024);
//从客户那里收回邮件
n=recvfrom(sockfd, buffer, sizeof(buffer), 
            0, (struct sockaddr*)&cliaddr,(socklen_t*)&len); 
if (n < 0)
printf("ERROR reading from socket");
else printf("Type 3 msg rcvd from client %d using udp :%s\n",clientno, buffer);
  
for(int i=0;i<7;i )
a[i]=buffer[i];
a[7]='\0';
//比较recv消息是否退出udp
if(strcmp(a, r) == 0){
    //向客户端发送bye并关闭udp连接
    n=sendto(sockfd, "Bye",3, 0, 
          (struct sockaddr*)&cliaddr, sizeof(cliaddr));
    if (n < 0)
printf("ERROR writing from socket");
            printf("---------------close udp for client %d---------------\n",clientno);
            close(sockfd);
            break;
        }
    printf("Type 4 response send to client %d using udp :%s\n",clientno,buffer);
    //向客户端发送响应消息
n=sendto(sockfd, buffer,sizeof(buffer) , 0, 
          (struct sockaddr*)&cliaddr, sizeof(cliaddr));
if (n < 0)
printf("ERROR writing from socket");

}
return port;
}