使用Kryo序列化quickfix.Message

我试图使用kryo序列化序列化一个quickfix.Message实例。使用Kryo序列化quickfix.Message

我正在使用kryo 3.0.3版本。

的代码片段如下：

Message fixMessage = getFixMessage(); 

    Kryo kryo = new Kryo(); 
    kryo.register(Message.class); 

    ByteArrayOutputStream outputStream = new ByteArrayOutputStream(); 
    Output output = new Output(outputStream); 
    kryo.writeObject(output, fixMessage); 
    output.flush(); 
    byte[] result = outputStream.toByteArray(); 
    output.close(); 

    ByteArrayInputStream inputStream = new ByteArrayInputStream(result); 
    Input input = new Input(inputStream); 

    Message fixMessage2 = kryo.readObject(input, Message.class);

，我不断收到此错误：

com.esotericsoftware.kryo.KryoException: Class cannot be created (missing no-arg constructor): quickfix.StringField Serialization trace: fields (quickfix.Message) at com.esotericsoftware.kryo.Kryo$DefaultInstantiatorStrategy.newInstantiatorOf(Kryo.java:1272) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.Kryo.newInstantiator(Kryo.java:1078) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.Kryo.newInstance(Kryo.java:1087) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.FieldSerializer.create(FieldSerializer.java:570) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:546) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:790) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.MapSerializer.read(MapSerializer.java:161) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.MapSerializer.read(MapSerializer.java:39) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:708) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:125) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:551) ~[kryo-3.0.3.jar:?] at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:686) ~[kryo-3.0.3.jar:?]

如果我注册一个KRYO的JavaSerializer这样的：

kryo.register(Message.class, new JavaSerializer());

我得到这一个：

com.esotericsoftware.kryo.KryoException: Error during Java deserialization. at com.esotericsoftware.kryo.serializers.JavaSerializer.read(JavaSerializer.java:65) ~[kryo-3.0.3.jar:?]

我开始认为这个对象根本无法使用KRYO连载...

对这个问题的想法将非常感激。

来源

2016-05-05 theDima

您的第一个错误是“无法创建类（缺少无参数构造函数）”，但我认为您已经解决了这个问题，并且是第二个错误。没有第二个错误来自行：

Message fixMessage2 = kryo.readObject(input, Message.class);

所以才连载，并通过线路获得。你能展示更多的反序列化错误堆栈吗？

来源

2016-05-06 14:52:26 rupweb

错误堆栈中的下一行是：Message fixMessage2 = kryo.readObject（input，Message.class）; – theDima

它正在寻找StringField上的非参数构造函数，它是使用Message的类。两者都是quickfix包的类，我从外部jar（不是我的代码）获得。我不应该（也不能）改变它。 – theDima

是的，但是您使用该'JavaSerializer'修复了非参数构造函数问题，现在问题在反序列化步骤中也是如此。有没有办法在'readObject'上使用'JavaDeserializer'？ – rupweb

Class cannot be created (missing no-arg constructor): quickfix.StringField

对于序列化的所有类，您应该有一个无参数构造函数。如果不是你的班级，你不能改变它，那么你应该创建你自己的序列化程序，如this link

来源

2017-12-22 07:07:19 iviorel

使用Kryo序列化quickfix.Message

回答

相关问题