Как мне сериализовать список вершин / ребер Tinkerpop для службы отдыха? [встроенный JanusGraph]

Используя встроенный JanusGraph, я создаю службу REST, которая возвращает списки Vertex и Edge, но я бы хотел вернуть json, как это делает сервер gremlin.

Я попытался использовать MessageSerializer, но не могу преобразовать двоичный формат в json.

@RequestMapping("/search")
public String search(@RequestBody SearchOptions options) throws JsonProcessingException, SerializationException {
    List<Object> data = new ArrayList<>();
    Builder responseBuilder = getResponseBuilder(data);

    List<Vertex> nodes;
    List<Object> edges;

    if (Strings.isNullOrEmpty(options.getText()) || Strings.isNullOrEmpty(options.getField())) {
        nodes = g.V().limit(options.getLimit()).toList();
        edges = g.V().limit(options.getLimit()).aggregate("node").outE().as("edge").inV().where(P.within("node"))
                .select("edge").toList();
    } else {
        nodes = g.V().has(options.getField(), options.getText()).toList();
        edges = g.V().has(options.getField(), options.getText()).aggregate("node").outE().as("edge").inV()
                .where(P.within("node")).select("edge").toList();
    }
    data.add(nodes);
    data.add(edges);

    ResponseMessage response = responseBuilder.create();
    ByteBufAllocator allocator = new PooledByteBufAllocator();
    ByteBuf byteBuffer = ser.serializeResponseAsBinary(response, allocator);
    byte[] bytes = byteBuffer.array();
    String str = new String(bytes);
    return str;
}   

@Bean
public MessageSerializer messageSerializer() {
    GryoMapper.Builder kryo = GryoMapper.build().addRegistry(JanusGraphIoRegistry.getInstance());
    MessageSerializer serializer = new GryoMessageSerializerV1d0(kryo);
    return serializer;
}

Я попытался использовать сопоставитель объектов Джексона, но получил эту ошибку -

[http-nio-8080-exec-10] ERROR o.a.c.c.C.[.[.[.[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception
org.apache.tinkerpop.shaded.jackson.databind.JsonMappingException: (was java.lang.IllegalStateException) (through reference chain: org.apache.tinkerpop.gremlin.driver.message.ResponseMessage["result"]->org.apache.tinkerpop.gremlin.driver.message.ResponseResult["data"]->java.util.ArrayList[0]->java.util.ArrayList[0]->org.janusgraph.graphdb.relations.RelationIdentifier["inVertexId"])
    at org.apache.tinkerpop.shaded.jackson.databind.JsonMappingException.wrapWithPath(JsonMappingException.java:388)   

Я определяю ObjectMapper так:

ObjectMapper mapper = GraphSONMapper.build().version(GraphSONVersion.V2_0).create().createMapper();

К вашему сведению - это был правильный способ создания ObjectMapper.

private ObjectMapper mapper = GraphSONMapper.build()
        .addRegistry(JanusGraphIoRegistry.getInstance())
        .version(GraphSONVersion.V2_0).create().createMapper();

person Jeremy    schedule 24.01.2018    source источник


Ответы (1)


Я думаю, вам нужно просто создать Jackson ObjectMapper из экземпляра GraphSONMapper с любыми конфигурациями, которые вам нужны, а затем передать в него свои результаты:

gremlin> mapper = GraphSONMapper.build().version(GraphSONVersion.V2_0).create().createMapper()
==>org.apache.tinkerpop.shaded.jackson.databind.ObjectMapper@4ca8dbfa
gremlin> mapper.class
==>class org.apache.tinkerpop.shaded.jackson.databind.ObjectMapper
gremlin> vertices = g.V().toList()
==>v[1]
==>v[2]
==>v[3]
==>v[4]
==>v[5]
==>v[6]
gremlin> mapper.writeValueAsString(vertices)
==>[{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":1},"label":"person","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":0},"value":"marko","label":"name"}}],"age":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":1},"value":{"@type":"g:Int32","@value":29},"label":"age"}}]}}},{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":2},"label":"person","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":2},"value":"vadas","label":"name"}}],"age":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":3},"value":{"@type":"g:Int32","@value":27},"label":"age"}}]}}},{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":3},"label":"software","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":4},"value":"lop","label":"name"}}],"lang":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":5},"value":"java","label":"lang"}}]}}},{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":4},"label":"person","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":6},"value":"josh","label":"name"}}],"age":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":7},"value":{"@type":"g:Int32","@value":32},"label":"age"}}]}}},{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":5},"label":"software","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":8},"value":"ripple","label":"name"}}],"lang":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":9},"value":"java","label":"lang"}}]}}},{"@type":"g:Vertex","@value":{"id":{"@type":"g:Int32","@value":6},"label":"person","properties":{"name":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":10},"value":"peter","label":"name"}}],"age":[{"@type":"g:VertexProperty","@value":{"id":{"@type":"g:Int64","@value":11},"value":{"@type":"g:Int32","@value":35},"label":"age"}}]}}}]
person stephen mallette    schedule 24.01.2018
comment
К сожалению, я получаю ошибку при использовании этого метода. Может надо что то прописать? - person Jeremy; 25.01.2018
comment
Хм, может он не знает, что делать с JanusGraph RelationIdentifier? Я бы попытался проверить это - разверните ResponseMessage и просто передайте RelationIdentifier в ObjectMapper и посмотрите, получите ли вы ту же ошибку (хотя я предполагаю, что это будет выглядеть немного менее запутанным) - person stephen mallette; 25.01.2018
comment
Вот и все. Мне просто нужно добавить реестр ввода-вывода для JanusGraph. - person Jeremy; 25.01.2018