inputStream數據丟失

Question

我正在做簡單的Java客戶端服務器。這是我的客戶代碼。

try { 
     socket = new Socket(serverIP, serverport); 
     dataStream = new DataOutputStream(new BufferedOutputStream(
       socket.getOutputStream())); 
     long[] data = { 1, 2, 3, 4, 5, 6, 7, 8, 9 }; 
     for (int i = 0; i < data.length; i++) { 
      dataStream.writeLong(data[i]); 
      System.out.println("So far" + dataStream.size()); 
     } 
    } 
    } catch (IOException e) { 
     e.printStackTrace(); 
    } finally { 
     if (socket != null) 
      try { 
       dataStream.flush(); 
       socket.close(); 
       dataStream.close(); 
      } catch (IOException e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 
    } 

這可以正常工作，因爲我可以看到一堆字節已經寫入服務器。這裏是服務器代碼。

try { 
      ServerSocket newSocket = new ServerSocket(2503); 
      while (true) { 
       connectionSocket = newSocket.accept(); 
       input = new DataInputStream(new BufferedInputStream(connectionSocket.getInputStream()));     
       System.out.println(input.readLong()); 
      } 

然而，沒有數據被成功地從服務器套接字讀出，connectionSocket.getInputStream.available（）返回0字節。讓我們假設每個變量都被正確地聲明。任何想法爲什麼？感謝幫助。

Answer 1

抽水馬桶/關閉流之前關閉套接字。

[當時：沖洗/關閉流，代碼被更新之前]

Answer 2

您的循環在每次傳遞時都會調用accept，這會阻塞，直到下一個客戶端連接。因此，第一個客戶端附加，它讀取一個長，打印，然後循環阻塞等待另一個連接附加。你需要在循環之外移動它。可能在一個單獨的線程中，因爲如果您在同一個線程上迭代流，則新客戶端無法連接，直到它完成第一個客戶端。這是下一步，但這裏是你如何解決您的問題：

try { 
    ServerSocket newSocket = new ServerSocket(2503); 
    while(!done) { 
     Socket nextClient = newSocket.accept(); 
     // it's better to start a thread and put the call to this method in there 
     // so the thread owning the ServerSocket can loop back around and accept 
     // another client should another connect while it's servicing this client 
     handleNewClient(nextClient); 
    } 
} finally { 
    newSocket.close(); 
} 

public void handleNewClient(Socket client) { 
    boolean done = false; 
    DataInputStream in = new DataInputStream(new BufferedInputStream(client.getInputStream())); 
    while(!done) { 
     try { 
     Long l = in.readLong(); 
     System.out.println(l); 
     } catch(EOFException e) { 
     // this is not a great way to end the conversation from a client. 
     // better to either know how much you can read the stream (ie count of bytes), 
     // or use a termination encoding. Otherwise you have to wait till the client 
     // closes their side which throws EOFException. 
     done = true; 
     } 
    }  
}