通过套接字发送多个字节数组

我能够发送/从客户端接收一个字节数组，并发送/从服务器接收一个字节数组：

我的代码是这样的：

服务器：

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)方法...将字节接收到字节数组中，直到获得所有字节。