GridDB与MongoDB集成报错：数据传输时出现读取超时问题

在跨GridDB和MongoDB进行数据传输的过程中，触发了com.mongodb.MongoSocketException: localhost:27017: Read timed out错误，以下是问题代码及解决方案：

问题代码 #

// 建立GridDB连接
GridStoreFactory factory = GridStoreFactory.getInstance();
GridStore gridStore = factory.getGridStore("yourGridStoreConfig");

// 连接MongoDB
MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase mongoDB = mongoClient.getDatabase("yourMongoDB");

// 执行GridDB到MongoDB的数据传输
try {
    // 从GridDB查询数据
    GridQuery<Row> gridQuery = gridStore.query("SELECT * FROM yourGridDBCollection");
    List<Row> rows = gridQuery.fetch();

    // 将数据插入MongoDB
    MongoCollection<Document> mongoCollection = mongoDB.getCollection("yourMongoCollection");
    for (Row row : rows) {
        Document document = new Document(row.getString("column1"), row.getString("column2"));
        mongoCollection.insertOne(document);
    }
} catch (Exception e) {
    System.err.println("Integration error: " + e.getMessage());
    // 报错信息：com.mongodb.MongoSocketException: localhost:27017: Read timed out
}

// 关闭连接
gridStore.close();
mongoClient.close();

解决方案 #

• 检查MongoDB服务状态：确认本地MongoDB服务已启动。可以通过终端执行mongod命令启动服务，或者查看系统服务列表（如Windows服务、Linux systemd）确认MongoDB处于运行状态。
• 调整MongoDB连接超时参数：创建MongoClient时显式设置更长的连接和读写超时时间，避免短时间内未完成操作导致超时：

MongoClientOptions options = MongoClientOptions.builder()
        .connectTimeout(30000)  // 连接超时设为30秒
        .socketTimeout(60000)   // 读写操作超时设为60秒
        .build();
MongoClient mongoClient = new MongoClient(new ServerAddress("localhost", 27017), options);

• 分批处理数据：如果GridDB返回的数据量较大，一次性读取和插入会增加MongoDB连接压力，改为分批读取插入：

// 分批从GridDB拉取数据，每次100条
GridQuery<Row> gridQuery = gridStore.query("SELECT * FROM yourGridDBCollection");
try (GridRowSet rowSet = gridQuery.fetch(100)) {
    while (rowSet.hasNext()) {
        Row row = rowSet.next();
        Document document = new Document(row.getString("column1"), row.getString("column2"));
        mongoCollection.insertOne(document);
    }
}

• 验证网络与端口权限：检查本地防火墙是否拦截了27017端口，确保MongoDB配置中监听的是localhost或允许本地连接（查看mongod.conf中的bindIp配置）。

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