使用DataInputStream和DataOutputStream以及套接字的中断管道

Question

我设置了客户端和服务器套接字。当我使用类ObjectOutputStream和ObjectInputStream以及ReadObject/WriteObject方法时，一切都运行良好。

它模拟了与机器人的通信，我确信机器人只正确解释方法DataOutputStream.WriteBytes。

所以我建立了一个新的体系结构来进行模拟，因为机器人不能每天进行测试。

在下面的代码中，ObjectOutputStream/ObjectInputStream ReadObject/WriteObject被替换为DataInputStream/DataOutputStreamWriteBytes和IOutils.TobyteArray。服务器套接字正确地接收到消息，但当它试图回写响应时，我得到一个中断的管道，就好像连接在某个地方关闭了一样。注意，我从不关闭套接字或流，因为机器人即使在30秒后也能应答。如果能帮助DataOutputStream.WriteBytes工作，我们将不胜感激。

下面是非工作代码：

客户：

Socket serverSocket =  new Socket("server", 9899);
DataOutputStream outputStream = new DataOutputStream(serverSocket.getOutputStream());
//ObjectOutputStream outputStream = new ObjectOutputStream(serverSocket.getOutputStream());
//outputStream.writeObject("\n" + "message" + "\r");
outputStream.writeBytes("\n" + "message" + "\r");
outputStream.flush();

DataInputStream inputStream = new DataInputStream(serverSocket.getInputStream());
//ObjectInputStream inputStream = new ObjectInputStream(serverSocket.getInputStream());
byte [] bytes = IOUtils.toByteArray(inputStream);
String serverResponse = new String(bytes,"UTF-8");
//  String serverResponse = (String)inputStream.readObject();

服务器：

ServerSocket serverSocket = new ServerSocket(9899);

while (true) {

 Socket socket = serverSocket.accept();

//ObjectInputStream inputStream = new ObjectInputStream(socket.getInputStream());
DataInputStream inputStream = new DataInputStream(socket.getInputStream());
byte [] bytes = IOUtils.toByteArray(inputStream);
String message = new String(bytes,"UTF-8");
//String message = (String) inputStream.readObject();
Thread.sleep(15000);

//ObjectOutputStream outputStream = new ObjectOutputStream(socket.getOutputStream());
DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
//outputStream.writeObject("server response");
outputStream.writeBytes("server response"); //EXCEPTION THROWN HERE FOR BROKEN PIPE
outputStream.flush();

            }

谢谢你抽出时间

Answer 1

Ioutils.ToString（InputStream）必须读取流直到其结束，这将意味着对等方已断开连接。所以你不能给它写信。

如果要用数据流交换字符串，则应该使用writeUTF（）和readUTF（）。

或读写行。