KryoSerialization.java 文件源码

@Override
public <T> T deserialize(byte[] data, Class<T> clz) throws IOException, ClassNotFoundException {
    Kryo kryo = kryoThreadMap.get();
    kryo.register(clz);
    KryoObjectInput input = new KryoObjectInput(kryo, new FastInput(new ByteArrayInputStream(data)));
    return (T) input.readObject();
}