如何解决JanusGraph Gremlin连接代码中的GryoMessageSerializerV3d0及JanusGraphIoRegistry.getInstance()过时警告

我来帮你搞定这两个弃用警告，它们都是因为TinkerPop和JanusGraph的API更新，旧的实现方式被标记为过时了，替换成新的写法就能彻底消除警告，同时还能用上更高效的序列化标准。

关键修改点说明 #

1. 替换过时的Gryo序列化器 #

GryoMessageSerializerV3d0已经被官方弃用，现在推荐使用GraphBinary序列化格式——这是TinkerPop 3.4+推出的标准二进制序列化协议，比Gryo兼容性更好、性能更优。

2. 替换过时的IoRegistry获取方式 #

JanusGraphIoRegistry.getInstance()是旧的单例获取方式，现在官方提供了JanusGraphIoRegistry.INSTANCE常量来替代，更符合现代Java的单例规范。

修改后的完整代码 #

import java.util.List;
import java.util.UUID;
import org.apache.tinkerpop.gremlin.driver.Client;
import org.apache.tinkerpop.gremlin.driver.Cluster;
import org.apache.tinkerpop.gremlin.driver.Result;
import org.apache.tinkerpop.gremlin.driver.ser.GraphBinaryMessageSerializerV1;
import org.apache.tinkerpop.gremlin.structure.io.binary.GraphBinaryMapper;
import org.janusgraph.graphdb.tinkerpop.JanusGraphIoRegistry;

public class JanusSessiionConnector {
    // 使用GraphBinaryMapper替代GryoMapper，并用INSTANCE获取IoRegistry
    final static GraphBinaryMapper.Builder builder = GraphBinaryMapper.build().addRegistry(JanusGraphIoRegistry.INSTANCE);
    // 使用GraphBinaryMessageSerializerV1替代过时的Gryo序列化器
    final static GraphBinaryMessageSerializerV1 serializer = new GraphBinaryMessageSerializerV1(builder);
    
    final static Cluster cluster = Cluster.build().addContactPoint("localhost").port(8182)
           .serializer(serializer)
           .maxInProcessPerConnection(32).maxSimultaneousUsagePerConnection(32).maxContentLength(1000000)
           .maxWaitForConnection(10).minConnectionPoolSize(1).maxConnectionPoolSize(1).create();

    public static void main(String[] args) {
        System.out.println("Welcome to janus connector");
        String sessionId = UUID.randomUUID().toString();
        Client sessionClient = cluster.connect(sessionId);
        try {
            sessionClient.submit("graph.tx().open()");
            sessionClient.submit("g.addV('Person').property('Name', 'Justin').next()");
            sessionClient.submit("graph.tx().commit()");
            List<Result> rs = sessionClient.submit("g.V().count()").all().join();
            System.out.println("Result size is "+rs.size());
            System.out.println(rs.get(0).getString());
            sessionClient.closeAsync();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (sessionClient != null) {
                System.out.println("Connection closed ");
                cluster.close();
            }
        }
    }
}

额外优化提示 #

• 你原来代码里的serializer2变量没有被使用，我已经直接移除了，避免冗余代码。
• 如果你使用的JanusGraph版本是0.6.0及以上，这个修改完全兼容，不会影响原有功能，还能获得更好的序列化性能。

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