迹忆客 专注技术分享

本文介绍如何修复Java的 java.io.StreamCorruptedException: invalid stream header 异常。

Java 中的 java.io.StreamCorruptedException: invalid stream header

java.io.StreamCorruptedException: invalid stream header 是相对常见的异常。 要了解此异常的原因，我们需要查看异常中的无效流标头，因为它可以解释问题背后的原因。

StreamCorruptedException 有两个构造函数，第一个有一个参数，另一个没有参数。 接受论点的人描述了异常的原因。

java.io.StreamCorruptedException: invalid stream header: XXXXXX 是带有参数的异常，其中 XXXXXX 表示无效的标头详细信息。

当我们使用 ObjectInputStream 时，通常会发生此异常。 因为，根据 Javadoc，只能从支持 java.io.Serialized 或 java.io.Externalizable 的流中读取那些对象。

因此，每当我们使用ObjectInputStream时，都应该将其与序列化数据一起使用。 当文本、HTML、XML、JSON 等文件直接传递给 ObjectInputStream 构造函数而不是可序列化文件时，大多数 StreamCorruptedException: invalid Stream header 都会发生。

以下是一些常见的 java.io.StreamCorruptedException: 具有相应 ASCII 值的无效流标头。

让我们尝试一个会抛出 java.io.StreamCorruptedException: invalid stream header 异常的示例。 参见示例：

package jiyik;

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.ServerSocket;
import java.net.Socket;

public class Example {

    private static ServerSocket Server_Socket;
    private static int Port_Number = 5000;

    public static void main(String args[]) throws IOException, ClassNotFoundException{
        Server_Socket = new ServerSocket(Port_Number);
        while(true){
            System.out.println("Waiting for client request");
            //create socket and then wait for client connection
            Socket DemoSocket = Server_Socket.accept();
            //read from socket to the ObjectInputStream object
            ObjectInputStream Object_Input_Stream = new ObjectInputStream(DemoSocket.getInputStream());
            //convert the ObjectInputStream to the String
            String DemoMessage = (String) Object_Input_Stream.readObject();
            System.out.println("The Received Message is: " + DemoMessage);
            //ObjectOutputStream object
            ObjectOutputStream Object_Output_Stream = new ObjectOutputStream(DemoSocket.getOutputStream());
            //write object to the Socket
            Object_Output_Stream.writeObject("Hello Client "+DemoMessage);
            //close
            Object_Input_Stream.close();
            Object_Output_Stream.close();
            DemoSocket.close();
            //terminate the server on exit from the client
            if(DemoMessage.equalsIgnoreCase("exit")) break;
        }
        System.out.println("Shut down Socket server!!");
        //close the ServerSocket
        Server_Socket.close();
    }

}

上面的代码尝试读取从客户端发送的字符串。 此代码的输出是 java.io.StreamCorruptedException: invalid stream header 异常。

查看输出：

Exception in thread "main" java.io.StreamCorruptedException: invalid stream header: 54657374
    at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:803)
    at java.io.ObjectInputStream.<init>(ObjectInputStream.java:298)
    at Example.main(SocketServerExample.java:29)

出现此异常的原因是我们没有使用 ObjectOutputStream 发送数据，因为我们不能指望 ObjectOutputStream 自动将文本转换为对象； 十六进制值 54657374 被转换为 Test 作为文本，我们必须将其直接作为字节发送。

我们可以使用readObject()和writeObject()方法来解决这个问题。