udp 서버의 최신 패킷 수신 - C

Question

UDP 서버가 select 시스템 호출로 패킷을 수신 중입니다. 그리고 각 UDP 클라이언트로부터 최신 패킷을 받고 싶습니다. (또한 여러 개의 UDP 클라이언트 패킷을 듣고 싶습니다.) 내 간단한 UDP 서버의

코드 :

int main(void) { 
    int fd; 
    int port = 5678; 
    char buffer[1024]; 
    fd_set readfs; 
    socklen_t client_length; 
    struct timeval timeout_interval; 
    struct sockaddr_in6 server_addr; 
    struct sockaddr_in6 client_addr; 
    int result; 
    int recv; 
    char client_addr_ipv6[100]; 

    fd = socket(PF_INET6, SOCK_DGRAM, 0); 
    printf(" \e[1m \e[34m ---------------------------------------- \n-------------------- UDP SERVER --------------------\n \e[39m \e[0m \n"); 
    printf("Process: \e[34m %d \e[49m Port ..\n", port); 

    if (fd < 0) { 
     printf("ERR: fd < 0"); 
    } else { 
     memset(&server_addr, 0, sizeof(server_addr)); 
     server_addr.sin6_family = AF_INET6; 
     server_addr.sin6_addr = in6addr_any; 
     server_addr.sin6_port = htons(port); 
     memset(&client_addr, 0, sizeof(client_addr)); 
     client_addr.sin6_family = AF_INET6; 
     client_addr.sin6_addr = in6addr_any; 
     client_addr.sin6_port = htons(port); 

     if (bind(fd, (struct sockaddr *) &server_addr, sizeof(server_addr)) 
       >= 0) { 
      printf("\e[1m INFO: \e[0m \e[34m Bind success.. \e[39m\n"); 

     } else { 
      printf("Bind."); 
      return -1; 
     } 
     for (;;) { 
      FD_ZERO(&readfs); 
      FD_SET(fd, &readfs); 
      int max_fd = MAX(0, fd); 
      timeout_interval.tv_sec = 3; 
      timeout_interval.tv_usec = 50000000; 

      result = select(max_fd + 1, &readfs, NULL, NULL, &timeout_interval); 
      //printf("\n %d \t %d \n", result, fd); 
      if (result < 0) { 
       printf("ERR\n"); 
      } else if (result == 0) { 
       printf("\nTimeout\n"); 
      } else { 
       if (FD_ISSET(fd, &readfs)) { 
        client_length = sizeof(client_addr); 
        if ((recv = recvfrom(fd, buffer, sizeof(buffer), 0, 
            (struct sockaddr *) &client_addr, &client_length)) 
          < 0) { 
         printf("Recv-ERR!"); 
         break; 
        } 
        inet_ntop(AF_INET6, &(client_addr.sin6_addr), client_addr_ipv6, 100); 
        //printf("Client IP/Port : %s ",client_addr_ipv6); 

        printf("\n ------------------------------------------ \n"); 
        printf("\e[1m Data: \e[0m \e[32m %.*s \n Client IP/Port : \e[34m %s/%d \n\e[39m", recv, buffer,client_addr_ipv6,ntohs(client_addr.sin6_port)); 
       } 
      } 
     } 
    } 
} 

Answer 1

이 처리하는 가장 좋은 방법은 보낸 사람이하는 것입니다 각 패킷에 일련 번호를 넣습니다. 전송 된 각 패킷에 대해 시퀀스 번호가 1 씩 증가합니다.

수신 측에서는 수신 한 마지막 패킷의 카운터를 추적합니다. 들어오는 다음 패킷이 더 큰 카운터를 가지고 있으면 최신 패킷입니다. 크기가 크지 않은 경우 이전 패킷이므로 응용 프로그램에 적절한 방식으로 처리 할 수 ​​있습니다.

또한 recv 변수의 이름을 recv_len으로 바꿔야합니다. recv은이 변수 정의에 의해 마스크 될 소켓 함수의 이름입니다.