迁移至JanusGraph遇janusgraph.RelationIdentifier序列化错误

这个序列化错误的核心原因是客户端与服务端的GraphBinary序列化配置不匹配，具体细节如下：

• 服务端已配置JanusGraphIoRegistry来处理JanusGraph自定义类型（比如RelationIdentifier），但客户端的GraphBinaryMessageSerializerV1未加载该注册表。当服务端返回包含RelationIdentifier的结果时，客户端找不到对应的反序列化器，从而抛出错误。
• RelationIdentifier是JanusGraph内部用于标识边、属性唯一ID的自定义类型，当查询/突变操作返回边、属性或包含这些元素的结果时，会携带该类型数据，客户端缺少处理逻辑就会触发序列化异常。
• 当前客户端代码仅初始化了基础的GraphBinaryMessageSerializerV1，未指定ioRegistries参数，导致无法识别JanusGraph的自定义类型。

修复方法 #

修改客户端的Cluster配置，为GraphBinaryMessageSerializerV1添加JanusGraphIoRegistry：

@Bean
public Cluster cluster() {
    GraphBinaryMessageSerializerV1 serializer = new GraphBinaryMessageSerializerV1(
            GraphBinaryMessageSerializerV1.build()
                    .ioRegistry(JanusGraphIoRegistry.getInstance())
                    .create()
    );
    return Cluster.build()
            .addContactPoint(dbUrl)
            .port(dbPort)
            .serializer(serializer)
            .maxConnectionPoolSize(5)
            .maxInProcessPerConnection(1)
            .maxSimultaneousUsagePerConnection(10)
            .create();
}

或者通过Config类配置：

import java.util.Collections;
import org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry;
import org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1;

@Bean
public Cluster cluster() {
    return Cluster.build()
            .addContactPoint(dbUrl)
            .port(dbPort)
            .serializer(new GraphBinaryMessageSerializerV1(
                    new GraphBinaryMessageSerializerV1.Config()
                            .ioRegistries(Collections.singletonList(JanusGraphIoRegistry.getInstance()))
            ))
            .maxConnectionPoolSize(5)
            .maxInProcessPerConnection(1)
            .maxSimultaneousUsagePerConnection(10)
            .create();
}

这样客户端就能正确解析服务端返回的JanusGraph自定义类型数据，解决序列化错误。

内容的提问来源于stack exchange，提问作者Thirumal