Hazelcast，Kryo，JsonNode Serializer(Hazelcast, Kryo, JsonNode Serializer)

 我正在使用分布式MAP作为条目实现Hazelcast应用程序。 我的JsonNodeSerializer如下所示 
 
private final ObjectReader jsonNodeReader;
private final ObjectWriter jsonNodeWriter;

@Override
public void write(ObjectDataOutput out, JsonNode jsonNode)
        throws IOException {
    out.write(jsonNodeWriter.writeValueAsBytes(jsonNode));
}

@Override
public JsonNode read(ObjectDataInput in)
        throws IOException {
    return jsonNodeReader.readTree(in);
}
 
 但是，我想使用Kryo来避免使用JsonNodeReader / Writer来节省一些空间并提高性能。 
 
 我尝试使用Kryo并且我无法读取JsonNode / ObjectNode，因为我们没有no-args构造函数。 
 
@Override
public void write(ObjectDataOutput out, JsonNode jsonNode)
        throws IOException {
    Kryo kryo = KRYO_THREAD_LOCAL.get();
    Output output = new Output((OutputStream) out);
    kryo.writeObject(output, jsonNode);
    output.flush();

    //out.write(jsonNodeWriter.writeValueAsBytes(jsonNode));
}

@Trace(dispatcher = true)
@Override
public JsonNode read(ObjectDataInput in)
        throws IOException {
    InputStream inputStream = (InputStream) in;
    Input input = new Input(inputStream);
    Kryo kryo = KRYO_THREAD_LOCAL.get();
    return kryo.readObject(input, ObjectNode.class);
   // return jsonNodeReader.readTree(in);
} 
 
 不确定我使用JsonNodeReader / Writer的方法是否最佳或使用Kryo将使我的解决方案更好。 
 
 我的目标是节省空间并提高性能。 欢迎任何建议让我朝着正确的方向前进。 谢谢 

I am implementing a Hazelcast application using distributed MAP with as the entry. My JsonNodeSerializer looks like as shown below
 
private final ObjectReader jsonNodeReader;
private final ObjectWriter jsonNodeWriter;

@Override
public void write(ObjectDataOutput out, JsonNode jsonNode)
        throws IOException {
    out.write(jsonNodeWriter.writeValueAsBytes(jsonNode));
}

@Override
public JsonNode read(ObjectDataInput in)
        throws IOException {
    return jsonNodeReader.readTree(in);
}
 
However, I wanted to use Kryo to avoid using JsonNodeReader/Writer to save some space and improve performance. 
 
I tried using Kryo and I am not able to read JsonNode/ObjectNode as we do not have no-args constructor.
 
@Override
public void write(ObjectDataOutput out, JsonNode jsonNode)
        throws IOException {
    Kryo kryo = KRYO_THREAD_LOCAL.get();
    Output output = new Output((OutputStream) out);
    kryo.writeObject(output, jsonNode);
    output.flush();

    //out.write(jsonNodeWriter.writeValueAsBytes(jsonNode));
}

@Trace(dispatcher = true)
@Override
public JsonNode read(ObjectDataInput in)
        throws IOException {
    InputStream inputStream = (InputStream) in;
    Input input = new Input(inputStream);
    Kryo kryo = KRYO_THREAD_LOCAL.get();
    return kryo.readObject(input, ObjectNode.class);
   // return jsonNodeReader.readTree(in);
} 
 
Not sure if my approach to use JsonNodeReader/Writer is optimal or Using Kryo will make my solution better.
 
My goal is the save space and improve performance. Any suggestions are welcome to put me in right direction. Thanks

原文：https://stackoverflow.com/questions/40099559