Kryoシーケンス化と逆シーケンス化のいくつかの問題
4530 ワード
会社の他のグループには共通のmaven依存パッケージのシーケンス化と逆シーケンス化がkryoを採用しているので、私は新しいコードでkryoをテストしました.テストの時、いくつかの問題が記録されました.
1.kryo逆シーケンス化は、デフォルト呼び出しクラスの無パラメトリック構造関数を反射します.クラスまたはクラスのオブジェクト属性に無パラメトリック構造関数がない場合、逆シーケンス化に失敗した例外が放出されます.解決策は、kryoクラスを継承するサブクラスを書き、逆射によるインスタンスの取得方法を再実現します.ブログを参照してください.https://vyloy.iteye.com/blog/1483029
2.kryoは、ArrayListおよびHashMapをシーケンス化および逆シーケンス化する際にArrayListを登録する必要がある.ClassとHashMap.classのシーケンス化クラスは、シーケンス化と逆シーケンス化に成功します.
3.シーケンス化されたArrayListのバイトフローが大きい場合は、設定された出力フローのサイズを表示する必要があります.そうしないと、デフォルトのフロー制限によりバイトフローの転送が誤り、逆シーケンス化に失敗する可能性があります
4.伝送対象のList属性はArraysでは使用できない.asList(array)形式生成,Arrays.asList(array)の戻り結果は、Arraysの内部クラスであり、集合ArrayListではなく、Arraysの内部クラスを使用すると逆シーケンス化異常を引き起こす
1.kryo逆シーケンス化は、デフォルト呼び出しクラスの無パラメトリック構造関数を反射します.クラスまたはクラスのオブジェクト属性に無パラメトリック構造関数がない場合、逆シーケンス化に失敗した例外が放出されます.解決策は、kryoクラスを継承するサブクラスを書き、逆射によるインスタンスの取得方法を再実現します.ブログを参照してください.https://vyloy.iteye.com/blog/1483029
2.kryoは、ArrayListおよびHashMapをシーケンス化および逆シーケンス化する際にArrayListを登録する必要がある.ClassとHashMap.classのシーケンス化クラスは、シーケンス化と逆シーケンス化に成功します.
MapSerializer serializer = new MapSerializer();
serializer.setKeyClass(String.class, new JavaSerializer());
serializer.setKeysCanBeNull(false);
serializer.setValueClass(clazz, new BeanSerializer(kryo, clazz));
serializer.setValuesCanBeNull(true);
kryo.register(HashMap.class, serializer);
CollectionSerializer serializer = new CollectionSerializer();
serializer.setElementClass(clazz, new BeanSerializer(kryo, clazz));
serializer.setElementsCanBeNull(false);
kryo.register(clazz, new BeanSerializer(kryo, clazz));
kryo.register(ArrayList.class, serializer);
3.シーケンス化されたArrayListのバイトフローが大きい場合は、設定された出力フローのサイズを表示する必要があります.そうしないと、デフォルトのフロー制限によりバイトフローの転送が誤り、逆シーケンス化に失敗する可能性があります
ByteArrayOutputStream byteBufferOutputStream = new ByteArrayOutputStream();
// 100000
Output output = new Output(byteBufferOutputStream,100000);
kryo.writeObject(output, list);
//kryo io output buffersize 4096
public Output(OutputStream outputStream) {
this(4096, 4096);
if (outputStream == null) {
throw new IllegalArgumentException("outputStream cannot be null.");
} else {
this.outputStream = outputStream;
}
}
4.伝送対象のList属性はArraysでは使用できない.asList(array)形式生成,Arrays.asList(array)の戻り結果は、Arraysの内部クラスであり、集合ArrayListではなく、Arraysの内部クラスを使用すると逆シーケンス化異常を引き起こす
// Arrays RandomAccess java.io.Serializable
/**
* @serial include
*/
private static class ArrayList extends AbstractList
implements RandomAccess, java.io.Serializable
{
private static final long serialVersionUID = -2764017481108945198L;
private final E[] a;
ArrayList(E[] array) {
a = Objects.requireNonNull(array);
}
@Override
public int size() {
return a.length;
}
@Override
public Object[] toArray() {
return a.clone();
}
@Override
@SuppressWarnings("unchecked")
public T[] toArray(T[] a) {
int size = size();
if (a.length < size)
return Arrays.copyOf(this.a, size,
(Class extends T[]>) a.getClass());
System.arraycopy(this.a, 0, a, 0, size);
if (a.length > size)
a[size] = null;
return a;
}
@Override
public E get(int index) {
return a[index];
}
@Override
public E set(int index, E element) {
E oldValue = a[index];
a[index] = element;
return oldValue;
}
@Override
public int indexOf(Object o) {
E[] a = this.a;
if (o == null) {
for (int i = 0; i < a.length; i++)
if (a[i] == null)
return i;
} else {
for (int i = 0; i < a.length; i++)
if (o.equals(a[i]))
return i;
}
return -1;
}
@Override
public boolean contains(Object o) {
return indexOf(o) != -1;
}
@Override
public Spliterator spliterator() {
return Spliterators.spliterator(a, Spliterator.ORDERED);
}
@Override
public void forEach(Consumer super E> action) {
Objects.requireNonNull(action);
for (E e : a) {
action.accept(e);
}
}
@Override
public void replaceAll(UnaryOperator operator) {
Objects.requireNonNull(operator);
E[] a = this.a;
for (int i = 0; i < a.length; i++) {
a[i] = operator.apply(a[i]);
}
}
@Override
public void sort(Comparator super E> c) {
Arrays.sort(a, c);
}
}