Dodawanie timeout DatagramSocket - odbiór()

Question

trzeba utworzyć 10 sekund czas oczekiwania na tej części kodu

DatagramPacket getack = nowy DatagramPacket (przychodzący, incoming.length);
socket.receive (getack);

muszę go na liście dla pakietów przychodzących do 10s, jeśli otrzyma paczkę przed 10s byłoby przejść do if w przypadku osiągnie 10s byłoby skoczyć do innego i ponownie wysłać paczkę. Czy to możliwe i jak mogę to zrobić całkiem nowatorsko.

private static void sendDATA() { 
    outgoing = new byte[512]; // Empty array 
    try { 
     ByteBuffer sDATA = ByteBuffer.allocate(516); 
     // 512 - 2 byte opcode, 2 byte block #, 512 data 

     DatagramPacket data = new DatagramPacket(outgoing, outgoing.length, InetAddress.getByName(clientip), clientport); 
     InputStream fis = new FileInputStream(new File(FILE)); 

     int a; 
     int block = 1; 

     while((a = fis.read(outgoing,0,512)) != -1) 
     { 
      data.setLength(a); 
      sDATA.put((byte)3); 
      sDATA.put((byte)block); 
      sDATA.put(outgoing); 
      socket.send(data); 

      while(true) { 
       DatagramPacket getack = new DatagramPacket(incoming, incoming.length); 
       socket.receive(getack); 

       if(incoming[0] == 3 && incoming[1] == block) { 
        break; 
       } else { 
        socket.send(data); 
       } 
      } 

     }  
    } catch (Exception e) { 

    } 

} 

Answer 1

To powinno zadziałać na twój przykład.

socket.setSoTimeout(10000); 
while(true) { 
    DatagramPacket getack = new DatagramPacket(incoming, incoming.length); 
    try { 
     socket.receive(getack); 
    } catch (SocketTimeoutException e) { 
     // resend 
     socket.send(data); 
     continue; 
    } 
    // check received data... 
} 

Answer 2

socket.setSoTimeout(10000); 
socket.receive(getack); 
socket.setSoTimeout(0);