java ObjectInputStream 是如何反序列化对象的源码-CFANZ编程社区

反序列化对象的源码分析与解决方案

问题描述

在Java中，我们经常需要将对象进行序列化和反序列化，以便在不同的系统之间传输数据或存储数据。ObjectInputStream是Java提供的一个类，用于从输入流中反序列化对象。在使用ObjectInputStream进行反序列化时，我们可能会遇到一些问题，例如：

如何使用ObjectInputStream反序列化对象？
ObjectInputStream的源码是如何实现反序列化的？
如何处理反序列化中的异常？

本文将通过分析ObjectInputStream的源码，解决以上问题。

使用ObjectInputStream反序列化对象

要使用ObjectInputStream反序列化对象，我们需要遵循以下步骤：

创建一个InputStream对象，作为反序列化的输入源。
创建一个ObjectInputStream对象，将InputStream对象作为参数传入。
调用ObjectInputStream的readObject方法，读取并返回反序列化后的对象。

以下示例代码展示了如何使用ObjectInputStream反序列化一个对象：

try {
    // 创建一个输入流对象
    InputStream inputStream = new FileInputStream("data.ser");

    // 创建一个ObjectInputStream对象，将输入流对象作为参数传入
    ObjectInputStream objectInputStream = new ObjectInputStream(inputStream);

    // 调用readObject方法，读取并返回反序列化后的对象
    Object object = objectInputStream.readObject();

    // 关闭输入流和ObjectInputStream对象
    objectInputStream.close();
    inputStream.close();

    // 强制转换为实际的对象类型
    MyClass myObject = (MyClass)object;

    // 对反序列化后的对象进行操作
    myObject.doSomething();
} catch (IOException | ClassNotFoundException e) {
    e.printStackTrace();
}

ObjectInputStream的反序列化源码解析

为了更深入地理解ObjectInputStream的反序列化过程，我们将分析其关键源码。

1. readObject方法

public final Object readObject() throws IOException, ClassNotFoundException {
    // 检查ObjectInputStream是否已经关闭
    if (closed) {
        throw new IOException("ObjectInputStream already closed");
    }
    // 读取一个对象
    return readObject0();
}

readObject方法是ObjectInputStream的核心方法，它首先检查ObjectInputStream是否已经关闭，如果已经关闭，则抛出一个IOException异常。然后调用readObject0方法，该方法实际上执行了反序列化的操作。

2. readObject0方法

private Object readObject0(boolean unshared) throws IOException {
    // 读取一个字节，表示待反序列化的对象的类型
    byte tc = bin.peekByte();
    // 根据类型的不同，调用不同的反序列化方法
    switch (tc) {
        case TC_NULL:
            return readNull();
        case TC_REFERENCE:
            return readHandle(unshared);
        case TC_CLASS:
            return readClass(unshared);
        case TC_CLASSDESC:
            return readClassDesc(unshared);
        case TC_ARRAY:
            return readArray(unshared);
        case TC_OBJECT:
            return readOrdinaryObject(unshared);
        case TC_STRING:
        case TC_LONGSTRING:
            return checkResolve(readString(unshared));
        case TC_ENUM:
            return checkResolve(readEnum(unshared));
        default:
            throw new StreamCorruptedException(
                String.format("Invalid type code: %02X", tc));
    }
}

readObject0方法首先读取一个字节，该字节表示待反序列化的对象的类型。然后根据类型的不同，调用不同的反序列化方法。例如，如果类型是TC_NULL，即表示待反序列化的对象是null，那么就调用readNull方法，在该方法中直接返回null。

3. readOrdinaryObject方法

private Object readOrdinaryObject(boolean unshared) throws IOException {
    // 读取一个字节，表示待反序列化的对象的类型
    if (bin.readByte() != TC_OBJECT) {
        throw new InternalError();
    }
    // 读取对象的描述符
    ObjectStreamClass desc = readClassDesc(false);
    // 检查对象是否允许反序列化
    if (desc.isProxy()) {
        throw new InvalidClassException("cannot deserialize proxy");
    }
    // 创建一个新的对象实例
    Object obj = desc.isInstantiable() ? desc.newInstance() : null;
    // 将对象实例添加到对象引用表中
    int handle = handles.assign(unshared ? unsharedMarker : obj);
    if (obj !=