MongoSocketReadException：过早到达流的末尾（一段时间不活动后）

Question

一段时间不活动后，我在

find

调用（默认 Java 驱动程序）上收到此错误。我试图添加一个手动心跳（写入一个上限集合），但它没有帮助。我只在连接到撰写时的实例时遇到问题（即不在本地上下文中）。

MongoDB 版本为 3.2.8，最新驱动程序（3.3），使用 Java 8.

任何想法？

Answer 1

我在一些文档中找到它：

对于长时间运行的应用程序，以毫秒为单位启用“keepAlive”通常是明智的。没有它，一段时间后你可能会开始看到“连接关闭”错误，这似乎是无缘无故的。

检查这是否有帮助。当您连接到 mongoDB 时，您可以将套接字选项传递给它。我来自节点背景，我们使用以下选项来保持它的活力。

server: {
        socketOptions: {
            keepAlive: 100,
            connectTimeoutMS: 30000
        }
    }

希望这有帮助！

Answer 2

我通过将 sslEnabled 设置为 true 来解决这个问题，代码示例：

@Bean
public MongoClient mongoClient() {
    List<ServerAddress> saList = new ArrayList<>();
    saList.add(new ServerAddress("cluster0-shard-00-00-75shm.gcp.mongodb.net", 27017));
    saList.add(new ServerAddress("cluster0-shard-00-01-75shm.gcp.mongodb.net", 27017));
    saList.add(new ServerAddress("cluster0-shard-00-02-75shm.gcp.mongodb.net", 27017));

    char[] pwd =  "password".toCharArray();
    MongoCredential credential = MongoCredential.createCredential("username", "admin", pwd);

    //set sslEnabled to true here
    MongoClientOptions options = MongoClientOptions.builder()
            .readPreference(ReadPreference.primaryPreferred())
            .retryWrites(true)
            .requiredReplicaSetName("Cluster0-shard-0")
            .maxConnectionIdleTime(6000)
            .sslEnabled(true)
            .build();

    MongoClient mongoClient = new MongoClient(saList, credential, options);     
    return mongoClient;
}

添加：我的客户端 jar 是 org.mongodb.mongodb-driver 3.6.4，服务器是 GCP 上的 mongodb atlas M0 3.6.6

Answer 3

我同意 Rhangaun 的回答，这里是我在 JAVA 代码中的解决方案：

    public static DB getMongoDB() {

        MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
        //build the connection options  
        builder.maxConnectionIdleTime(60000);//set the max wait time in (ms)
        MongoClientOptions opts = builder.build();
        
    
        char[] password2 = "mypassword".toCharArray();
        
        MongoCredential credential2 = MongoCredential.createCredential("username", "databasename",password2);
        
       
        //add your option to the connection 

        MongoClient mongoClient = new MongoClient(new ServerAddress("server ip",27017), Arrays.asList(credential2),opts);
        //use your database 
        cachedDb = mongoClient.getDB("databasename");
        
    return cachedDb;

}

这是我的研究链接：http://3t.io/blog/how-to-prevent-your-connection-from-dropping-with-hosted-mongodb-instances/

希望对你有帮助

Answer 4

这在 spring boot 和基于云的 mongo（Atlas 集群实例）中对我有用。

像这样编辑 application.properties：

spring.data.mongodb.uri = mongodb+srv://username:[email protected]/dbname

对于常规的mongo实例（非集群）使用这个：

spring.data.mongodb.uri = mongodb://username:[email protected]:27017,hostname2:27017/dbname?ssl=true

• 如果你想设置其他连接选项，你可以链接 使用 '&' 的多个参数；文档在这里： https://mongodb.github.io/mongo-java-driver/3.4/javadoc/com/mongodb/MongoClientURI.html
• 如果您使用其他spring.data.mongodb参数，您应该 全部删除 否则 spring 不会读取 弹簧.data.mongodb.uri

Answer 5

对我来说这是一个完全不同的问题——我使用 mongo-java-server 和 Fongo 并最终得到这个错误。事实证明，它的旧版本与

FieldType.DECIMAL128

转换不兼容。

更新到最新版本（目前为 1.36.0）为我解决了这个问题。

Answer 6

问题是Mongodb结束了连接。您需要增加 Mongodb 驱动程序的超时时间，这是一个示例代码。

 MongoClientOptions.Builder builder = new MongoClientOptions.Builder();
    //build the connection options
    builder.maxConnectionIdleTime(86400000);//set the max wait time in (ms)
    MongoClientOptions opts = builder.build();




    final Morphia morphia = new Morphia();


    morphia.mapPackage("com.java.code");


    final String hostURL = "host_url";
            

    MongoCredential  credential = MongoCredential.createCredential("username","database","Password".toCharArray()); 

    ServerAddress address = new ServerAddress(hostURL);


    List<MongoCredential> credentialList = new ArrayList<>();
    credentialList.add(credential);


   final MongoClient client = new MongoClient(address,credentialList,opts);




    // create the Datastore connecting to the default port on the local host
    datastore  = morphia.createDatastore(client,"datastore");

Answer 7

我走了两步就修好了。

第一个：
准备适当的 MongoClientSettings 对象，其中包含我们的 Mongo 客户端的关键设置。

private MongoClientSettings getMongoClientSettings() {
    return MongoClientSettings.builder()
        .retryWrites(true)
        .applyToConnectionPoolSettings(poolSettings -> poolSettings
                .minSize(5)
                .maxSize(300)
                .maxConnectionIdleTime(0, TimeUnit.MILLISECONDS))
        .applyToSocketSettings(socketSettings -> socketSettings
                .connectTimeout(1, TimeUnit.MINUTES)
                .readTimeout(1, TimeUnit.MINUTES))
        .build();
}

maxConnectionIdleTime – 连接可以不使用的最长时间。零值表示对空闲时间没有限制。

maxSize - 允许的最大连接数。这些连接将在空闲时保留在池中。一旦池耗尽，任何需要连接的操作都将阻塞等待可用连接。默认为 100

minSize - 最小连接数。这些连接将在空闲时保留在池中，并且池将确保它至少包含这个最小数量。默认为 0

第二个：
增加 application.properties / application.yaml 文件（或您已有的文件）中的默认超时

mongodb:
 database: your_db_name
 authDatabase: admin
 config:
   enabled: true
   write:
     writeConcern:
       isMajority: true
     timeout:
       milliseconds: 100000

检查一下，它应该可以工作:)