2012-04-07 4 views
9

Desidero inviare i dati al server, quindi attendere una risposta per un minuto e quindi chiudere il socket.timeout impostato per la ricezione socket

Come fare?

DatagramPacket sendpack = new ......; 
socket.send(pack); 
DatagramPacket recievepack = new .....; 
//wait 1 minute{ 
socket.recieve(buf); 
//wait 1 minute} 
socket.close(); 
+0

È necessario attendere un minuto o dati disponibili sulla presa? Se vuoi aspettare un minuto intero, userei la funzione sleep o usleep. Questi per il periodo di tempo scadranno prima di continuare. Se si è in attesa di dati, esaminerei la funzione di selezione, che consentirà di attendere l'arrivo dei dati o un periodo di tempo scaduto, a seconda dell'evento che si verifica per primo. – Glenn

+0

@Glenn Il sonno potrebbe perdere fino a un minuto. Cosa succede se i dati arrivano dopo un secondo? Cosa pensi che i timeout di lettura siano * per *, esattamente? – EJP

risposta

19

Si può provare questo. Cambia il timeout del socket come richiesto nel tuo scenario! Questo codice invierà un messaggio e quindi attenderà di ricevere messaggi fino al raggiungimento del timeout!

DatagramSocket s; 

    try { 
     s = new DatagramSocket(); 
     byte[] buf = new byte[1000]; 
     DatagramPacket dp = new DatagramPacket(buf, buf.length); 
     InetAddress hostAddress = InetAddress.getByName("localhost"); 

     String outString = "Say hi";  // message to send 
     buf = outString.getBytes(); 

     DatagramPacket out = new DatagramPacket(buf, buf.length, hostAddress, 9999); 
     s.send(out);  // send to the server 

     s.setSoTimeout(1000); // set the timeout in millisecounds. 

     while(true){  // recieve data until timeout 
      try { 
       s.receive(dp); 
       String rcvd = "rcvd from " + dp.getAddress() + ", " + dp.getPort() + ": "+ new String(dp.getData(), 0, dp.getLength()); 
       System.out.println(rcvd); 
      } 
      catch (SocketTimeoutException e) { 
       // timeout exception. 
       System.out.println("Timeout reached!!! " + e); 
       s.close(); 
      } 
     } 

    } catch (SocketException e1) { 
     // TODO Auto-generated catch block 
     //e1.printStackTrace(); 
     System.out.println("Socket closed " + e1); 

    } catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
+0

Un secondo è troppo breve per un timeout di lettura. Questo codice genererà 'SocketException: socket closed' non appena si verifica un timeout, a causa di un'interruzione' mancante'. Non tutte le "SocketExceptions" significano che il socket è chiuso. – EJP

1

Per chiarire il commento di EJP, questo è ciò che intendeva per "mancanza di break" che causa un SocketException.

String group = "224.0.0.0"; 
int port = 5000; 

MulticastSocket recvSock = new MulticastSocket(port); 
recvSock.joinGroup(InetAddress.getByName(group)); 
recvSock.setSoTimeout(1000); 

while(true) { 
    try { 
     recvSock.receive(in);    
    } catch (SocketTimeoutException e) { 
     break; // Closing here would cause a SocketException 
    } 
} 

// Move the close() outside the try catch bloock 
recvSock.leaveGroup(InetAddress.getByName(group)); 
recvSock.close();