MongoDB 中打开连接的 SocketTimeout

在使用 MongoDB 数据库时，我们经常需要与数据库建立连接并进行数据的读取和写入操作。在连接数据库时，一个常见的问题是如何处理 Socket 超时。在 MongoDB 中，我们可以通过设置 SocketTimeout 的参数来控制连接的超时时间。本文将介绍 SocketTimeout 的概念，以及在实际应用中如何设置和使用它。

java
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
public class MongoDBExample {
    public static void main(String[] args) {
        MongoClientOptions options = MongoClientOptions.builder()
                .socketTimeout(5000)  // 设置 SocketTimeout 为 5 秒
                .build();
        MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017", options);
        MongoClient client = new MongoClient(uri);
        // 进行数据库操作
        // ...
        
        client.close();
    }
}

java
import com.mongodb.MongoClient;
import com.mongodb.MongoClientOptions;
import com.mongodb.MongoClientURI;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
public class MongoDBExample {
    public static void main(String[] args) {
        MongoClientOptions options = MongoClientOptions.builder()
                .socketTimeout(5000)  // 设置 SocketTimeout 为 5 秒
                .build();
        MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017", options);
        MongoClient client = new MongoClient(uri);
        MongoDatabase database = client.getDatabase("mydb");
        MongoCollection collection = database.getCollection("mycollection");
        FindIterable iterable = collection.find().maxTime(2000);  // 设置查询的超时时间为 2 秒
        for (Document document : iterable) {
            // 处理查询结果
            // ...
        }
        
        client.close();
    }
}