java.io.StreamCorruptedException： invalid stream header： 7371007E

serialization java io

2022-09-02 10:53:33

我有一个客户端服务器应用程序，它使用对象进行通信。
当我只将一个对象从客户端发送到服务器时，一切都运行良好。
当我试图在同一个流上一个接一个地发送几个对象时，我得到

StreamCorruptedException.

有人可以引导我找到此错误的原因吗？

客户端写入方法

   private SecMessage[] send(SecMessage[] msgs) 
   {
     SecMessage result[]=new SecMessage[msgs.length];
      Socket s=null;
      ObjectOutputStream objOut =null;
      ObjectInputStream objIn=null;
      try
      {
       s=new Socket("localhost",12345);
       objOut=new ObjectOutputStream( s.getOutputStream());
       for (SecMessage msg : msgs) 
       {
            objOut.writeObject(msg);
       }
       objOut.flush();
       objIn=new ObjectInputStream(s.getInputStream());
       for (int i=0;i<result.length;i++)
            result[i]=(SecMessage)objIn.readObject();
      }
      catch(java.io.IOException e)
      {
       alert(IO_ERROR_MSG+"\n"+e.getMessage());
      } 
      catch (ClassNotFoundException e) 
      {
       alert(INTERNAL_ERROR+"\n"+e.getMessage());
      }
      finally
      {
       try {objIn.close();} catch (IOException e) {}
       try {objOut.close();} catch (IOException e) {}
      }
      return result;
 }

服务器读取方法

//in is an inputStream Defined in the server
SecMessage rcvdMsgObj;
rcvdMsgObj=(SecMessage)new ObjectInputStream(in).readObject();
return rcvdMsgObj;

而 SecMessage 类是

public class SecMessage implements java.io.Serializable
{
 private static final long serialVersionUID = 3940341617988134707L;
 private String cmd;
    //... nothing interesting here , just a bunch of fields , getter and setters
}

答案 1

如果要发送多个对象，通常最简单的方法是将它们放入某种类型的持有者/集合，如或。它使您不必显式检查流的结束，并负责显式传输流中有多少个对象。Object[]List

编辑：现在我格式化了代码，我看到你已经在数组中拥有消息。只需将数组写入对象流，然后在服务器端读取数组即可。

您的“服务器读取方法”仅读取一个对象。如果多次调用它，您将收到错误，因为它正在尝试从同一输入流打开多个对象流。这将不起作用，因为所有对象都写入客户端上的同一对象流，因此您必须在服务器端镜像此安排。也就是说，使用一个对象输入流并从中读取多个对象。

（您得到的错误是因为 objectOutputStream 写入了一个标头，这是 objectIutputStream 所期望的。由于您不是在写入多个流，而只是写入多个对象，则在套接字输入上创建的下一个 objectInputStream 无法找到第二个标头，并引发异常。

若要修复此问题，请在接受套接字连接时创建对象InputStream。将此对象InputStream传递到您的服务器读取方法，并从中读取对象。

答案 2

当我只将一个对象从客户端发送到服务器时，一切都运行良好。

当我尝试在同一流上一个接一个地发送几个对象时，我得到了.StreamCorruptedException

实际上，您的客户端代码正在将一个对象写入服务器，并从服务器读取多个对象。而且服务器端没有任何东西在写入客户端尝试读取的对象。