- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
为了帮助远程调试 (Java),能够请求远程服务器将任意对象发送到我的本地机器以供检查是很有用的。然而,这意味着远程服务器必须能够在运行时序列化一个事先不知道的任意 java 对象。
所以我四处询问并偶然发现了 Kryo serialization library .来自 Kryo's documentation ,一个主要特点是它在序列化任意 java 对象时非常健壮。对象不必实现 Serializable
,不需要无参数构造函数即可反序列化,我什至不需要在序列化之前了解任何有关对象结构的信息。完美!
所以为了测试 Kryo,我试着看看我是否可以序列化然后反序列化一个 PrintWriter
对象(即任意对象):
import com.esotericsoftware.kryo.Kryo;
import com.esotericsoftware.kryo.io.Input;
import com.esotericsoftware.kryo.io.Output;
import java.io.*;
public class SerializationTest {
private static final String ioFileName = "someIO.bin";
public static void main(String[] args) {
// Create a PrintWriter object that I will later attempt to serialize
PrintWriter outObj = null;
try {
outObj = new PrintWriter("textfile.txt");
} catch (FileNotFoundException e) {
e.printStackTrace();
}
// Change the PrintWriter's state as a test for later to see if state is restored after serialization and deserialization
outObj.println("Hello"); // "Hello" held in PrintWriter's buffer
Kryo kryo = new Kryo(); // Initialize Kryo serialization
writeObj(kryo, outObj); // Save PrintWriter object to file with "Hello" still in its buffer
// Read the previously saved Printwriter object (still with "Hello" in its buffer)
PrintWriter inObj = (PrintWriter) readObj(kryo);
inObj.close(); // commit "Hello" to disk (using deserialized object)
outObj.close(); // commit "Hello" to disk (using original object)
System.out.println(inObj);
}
public static Object readObj(Kryo kryo) {
Object obj = null;
try {
Input input = new Input(new FileInputStream(ioFileName));
obj = kryo.readClassAndObject(input); // ERROR HERE!!
input.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
}
return obj;
}
public static void writeObj(Kryo kryo, Object obj) {
try {
Output output = new Output(new FileOutputStream(ioFileName));
kryo.writeClassAndObject(output, obj);
output.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
}
}
}
序列化工作正常,但在反序列化时,第 39 行对 kryo.readClassAndObject(input)
的调用给出以下 IllegalAccessError
:
Exception in thread "main" java.lang.IllegalAccessError: tried to access class sun.nio.cs.UTF_8 from class sun.nio.cs.UTF_8ConstructorAccess
at sun.nio.cs.UTF_8ConstructorAccess.newInstance(Unknown Source)
at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy$1.newInstance(Kryo.java:1234)
at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1086)
at com.esotericsoftware.kryo.serializers.FieldSerializer.create(FieldSerializer.java:547)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:523)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:704)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:704)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:704)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:704)
at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:106)
at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:786)
at SerializationTest.readObj(SerializationTest.java:39)
at SerializationTest.main(SerializationTest.java:27)
我曾希望我可以序列化和反序列化 PrintWriter
对象 outObj
,并且该对象的状态将保持完整,因此我仍然可以使用反序列化的对象来编写 "Hello"
应该保存在缓冲区中。
有谁知道发生了什么以及如何纠正这个错误?
最佳答案
我认为,您希望 kryo.setInstantiatorStrategy(new StdInstantiatorStrategy());
避免调用构造函数。更多信息 here .
但是,如果我可能会问,您究竟为什么要序列化一个 PrintWriter
?那绝对是自找麻烦。Kryo 不是“ Elixir ”,虽然它的默认反序列化器可以与 大多数 类一起工作,这些类很实用(即便如此,总会有一些极端情况需要您编写自定义插件),您可以当然不要指望它能够处理你能想到的每一个奇异的东西(并且序列化由内部 jvm 特定代码支持的类,比如 sun.*
绝对符合奇异的条件)。
关于java - 使用 Kryo 序列化任意 Java 对象(获取 IllegalAccessError),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/27731969/
WARN: [kryo] Unable to load class slade.core.Child with kryo's ClassLoader. Retrying with current...
我正在为我的 pojo 类使用 Flink 和自定义 kryo 类。但得到 Caused by: java.lang.NullPointerException at MyTreeSeriali
我需要通过添加两个新参数来修改一个类。这个类是用 Kryo 序列化的。 每次我停止流时,我目前都将与此类相关的信息保存为 RDD。 当我重新启动流时,我会加载我之前保留的信息,并使用它们在我停止和重新
我正在尝试将 kryo 序列化用于: kryo.setRegistrationRequired(true); 我不断收到以下错误消息,说某个类未注册: java.lang.IllegalArgumen
我正在使用 Kryo 进行序列化/反序列化,并且没有事先注册类(我正在研究这一点)。也就是说,在反序列化时,我遇到了异常: 无法使用 kryo 的 ClassLoader 加载类 shell.api.
我发现了两种使用 Kryo 进行读写的通用方法,我在想其中一种是更好还是更差,或者它们是否完全相同。 选项 1 - 使用 kryo 函数 writeClassAndObject (readClassA
我直接使用 Kryo IO 来执行我自己的字符串、长整型和 double 型的低级原始序列化。 我想知道的是,Kryo IO 是否有任何方法可以在读回序列化字节时自动检测它们的原始数据类型? 如果我有
我将 JSON 存储在表中(实际上是 Cassandra 列族),如下所示: ____________________________________________________________
我正在尝试使用 Kryo 序列化某些对象的列表列表(自定义类:List>)。 list2D; // List> which is already produced. Kryo k1 = new Kry
我正在尝试使用 Kryo 库将任何给定对象转换为 byteArray 并存储在数据存储或队列中供以后使用。但是是否可以序列化任何给定的对象,或者只能转换实现可序列化接口(interface)的对象。
实际项目中,我们经常需要使用序列化工具来存储和传输对象。目前用得比较多的序列化工具有:jackson、fastjson、kryo、protostuff、fst 等,本文将简单对比这几款工具序列化和反序
你如何使用 反序列化不可变集合Kryo ?除了我所做的事情之外,我还需要注册一些东西吗? 这是我的示例代码 import com.esotericsoftware.kryo.Kryo import c
在使用带有以下代码的Apache Flink时: DataStream> result = source.window(Time.of(1, TimeUnit.SECONDS)).mapWindow(
我正在尝试从此 link 运行 Chill-Scala 的示例代码 我有两个虚拟案例类 一个是用户 @SerialVersionUID(1) case class User(name :String,
我正在尝试了解以下错误,并且正在客户端 ode 中运行。 org.apache.spark.SparkException: Kryo serialization failed: Buffer ove
我有一段 Spark 代码可以在 Spark 1.3 上运行,但当我将它移至 Spark 1.5.2 时失败(集群升级超出我的控制)。失败如下: Caused by: java.io.NotSeria
通过使用 Kryo 3,每次序列化/反序列化根对象(流)时都会创建一个 Kryo 3 实例。 我想知道我可以使用什么重用概念。 从源代码来看,Kryo 实例可能仅以单线程方式使用,并且由于它使用引用,
我正在尝试使用 kryo 序列化和反序列化为二进制文件。我想我有序列化工作,但我似乎无法反序列化。下面是我正在处理的代码,但最终我想存储一个 byte[] 并稍后再次读取它。该文档仅显示如何使用文件执
我正在寻找 Kryo 自定义序列化和反序列化示例。如何检查Kryo读写函数的正确性。 我写了一些代码来检查,但它返回异常。任何帮助将不胜感激。提前致谢。 import com.esotericsoft
对于个人项目,我必须使用 Kryo-Framework 在 Java 中序列化 Collections.sychronizedMap。我绑定(bind)到该框架,因为还有其他依赖项需要它。我目前的尝试
我是一名优秀的程序员,十分优秀!