Сериализация/десериализация Kryo

Question

Я пытаюсь использовать kryo для сериализации и десериализации в двоичном формате. Я думаю, что у меня работает сериализация, но я не могу десериализовать. Ниже приведен код, с которым я возился, но в конечном итоге я хочу сохранить байт [], а затем прочитать его снова. В документации только показано, как это сделать с файлами.

 Kryo kryo = new Kryo(); 
     kryo.register(ArrayList.class); 
     kryo.register(Modifier.class); 

     ByteArrayOutputStream b = new ByteArrayOutputStream(); 

     Modifier modifier = new Modifier(); 
     modifier.type = "Yo swa!"; 
     modifier.amount = 10; 

     Output output = new Output(b); 
     kryo.writeClassAndObject(output, modifier); 

     System.out.println("Kryo size: " + output.toBytes().length); 

     Input input = new Input(output.getBuffer()); 

     //Exception in thread "main" java.lang.IndexOutOfBoundsException: Index: 11, Size: 0 
     Modifier r = kryo.readObject(input, Modifier.class); 
     //Same error: 
     Modifier r = kryo.readObject(new Input(new ByteArrayInputStream(output.toBytes())), Modifier.class); 

     System.out.println(r.type); 

Answer 1

Вы сериализации по writeClassAndObject методом и десериализации по readObject, которые не совместимы.

Вы должны использовать либо writeClassAndObject =>readClassAndObject, либо writeObject =>readObject.

Следующие работы для меня (kryo version 2.21).

writeObject =>readObject

package test; 

import com.esotericsoftware.kryo.Kryo; 
import com.esotericsoftware.kryo.io.Input; 
import com.esotericsoftware.kryo.io.Output; 

import java.io.ByteArrayInputStream; 
import java.io.ByteArrayOutputStream; 
import java.util.ArrayList; 

public class TestMain { 

    public static void main(String[] args) { 
     Kryo kryo = new Kryo(); 
     kryo.register(ArrayList.class); 
     kryo.register(Modifier.class); 

     ByteArrayOutputStream b = new ByteArrayOutputStream(); 

     Modifier modifier = new Modifier(); 
     modifier.type = "Yo swa!"; 
     modifier.amount = 10; 

     Output output = new Output(b); 
     kryo.writeObject(output, modifier); 
     output.flush(); 
     output.close(); 

     System.out.println("Kryo size: " + output.toBytes().length); 

     Input input = new Input(output.getBuffer()); 

     Modifier r = kryo.readObject(input, Modifier.class); 

     System.out.println(r.type); 
    } 

    static class Modifier { 
     String type; 
     int amount; 
    } 
} 

writeClassAndObject =>readClassAndObject

package test; 

import com.esotericsoftware.kryo.Kryo; 
import com.esotericsoftware.kryo.io.Input; 
import com.esotericsoftware.kryo.io.Output; 

import java.io.ByteArrayInputStream; 
import java.io.ByteArrayOutputStream; 
import java.util.ArrayList; 

public class TestMain { 

    public static void main(String[] args) { 
     Kryo kryo = new Kryo(); 
     kryo.register(ArrayList.class); 
     kryo.register(Modifier.class); 

     ByteArrayOutputStream b = new ByteArrayOutputStream(); 

     Modifier modifier = new Modifier(); 
     modifier.type = "Yo swa!"; 
     modifier.amount = 10; 

     Output output = new Output(b); 
     kryo.writeClassAndObject(output, modifier); 
     output.flush(); 
     output.close(); 

     System.out.println("Kryo size: " + output.toBytes().length); 

     Input input = new Input(output.getBuffer()); 

     Modifier r = (Modifier) kryo.readClassAndObject(input); 

     System.out.println(r.type); 
    } 

    static class Modifier { 
     String type; 
     int amount; 
    } 
}