通過套接字發送多個字節數組

我能夠發送/從客戶端接收一個字節數組，併發送/從服務器接收一個字節數組：

我的代碼是這樣的：

服務器：

Socket sock=null; 
    ByteArrayOutputStream input=null; 
    OutputStream out=null; 
    InputStream in=null; 
    try{ 
     ServerSocket server_sock=new ServerSocket(2972); 


    sock=server_sock.accept(); 

    in = 
     sock.getInputStream(); 
    out=sock.getOutputStream(); 
    }catch(IOException e){ 
     System.out.println(e.getMessage()); 
    } 
String word=""; 

    //1-Receive 

    try{ 

    ByteArrayOutputStream serverinput=new ByteArrayOutputStream(); 
int len=0; 
byte[] buf=new byte[1000]; 
     while ((len = in.read(buf))>=0) { 
       serverinput.write(buf, 0, len); 

     } 

     sock.shutdownInput(); 

     word=new String(serverinput.toByteArray()); 
    System.out.println("Client send 1"+word); 

    }catch(Exception e){ 
     System.out.println(e.getMessage()); 
    } 


    String st="Server is a king"; 
try{ 
    out.write(st.getBytes()); 

    out.flush(); 

}catch(Exception e){ 
     System.out.println(e.getMessage()); 
    }

客戶：

Socket sock=null; 
    OutputStream out=null; 
    InputStream in=null; 


    try{ 
     sock=new Socket("127.0.0.1",2972); 
     }catch(IOException e){ 
     System.out.println(e.getMessage()); 
    } 


String word="Hellow World" ; 
    try{ 
    in = 
     sock.getInputStream(); 
    out=sock.getOutputStream(); 
    }catch(IOException e){ 
     System.out.println(e.getMessage()); 
    } 

//1- send 
    try{ 

     System.out.println("Your string is"+word+"converted to byte"+word.getBytes()); 

    out.write(word.getBytes()); 
    out.flush(); 
sock.shutdownOutput(); 
    }catch(Exception e){ 
     System.out.println(e.getMessage()); 
    } 

    try{ ByteArrayOutputStream serverinput=new ByteArrayOutputStream(); 
int len=0; 
byte[] buf=new byte[1000]; 
     while ((len = in.read(buf))>=0) { 
       serverinput.write(buf, 0, len); 


     } 
    System.out.println("server send 1 "+new String(serverinput.toByteArray())); 
    System.out.println("Your string is"+word+"converted to byte"+word.getBytes()); 

    }catch(Exception e){ 
     System.out.println(e.getMessage()); 
    }

此代碼工作正常，從客戶端和服務器提交，但它不工作時，我想發送/接收更多的字節數組？

它只在我使用shutdown時工作，因爲客戶端和服務器都讀寫數據。

因此，我不能再次使用套接字通道...是否有其他解決方案？ ......這不會導致僵局。

來源

2011-04-29 Programming_Lover

你的問題是，你現在沒有辦法說什麼時候一個字節數組結束和下一個開始。（在你的「一個數組」的解決方案中，字節數組的末尾對應於數據流的結尾，當然，一旦數據流已經結束/關閉，就不能在不創建新的Socket等的情況下重新打開。）

簡單的方法來解決這個是如下，使用圍繞相應的插座流包裹DataOutputStream類和DataInputStream類雙：

要發送的字節數組：
1. 轉換數據，以字節。
2. 使用DataOutputStream.writeInt(int)方法發送字節數組大小。
3. 使用DataOutputStream.write(byte[])方法發送字節數組。
要接收的字節數組：
1. 使用DataInputStream.readInt()方法，接收字節數組的大小。
2. 分配所需大小的字節數組。
3. 重複使用DataInputStream.read(byte[], int, int)方法...將字節接收到字節數組中，直到獲得所有字節。