Ошибка выдачи строки подключения MongoClientURI «com.mongodb.MongoSocketReadException: преждевременно достигнут конец потока» - PullRequest
Новая
       105

Ошибка выдачи строки подключения MongoClientURI «com.mongodb.MongoSocketReadException: преждевременно достигнут конец потока»

1 голос
/ 14 июля 2020 
public void MongoDBClient(String user, String pwd, String dbName, String collectionName) {
    MongoClientURI uri = new MongoClientURI("mongodb+srv://" + user + ":" + pwd + "@cluster0.mff6p.mongodb.net/"
            + dbName + "?retryWrites=true&w=majority&connectTimeoutMS=30000&socketTimeoutMS=30000");

    try (MongoClient mongoClient = new MongoClient(uri)) {
        MongoDatabase database = mongoClient.getDatabase(dbName);
        MongoCollection<Document> collection = database.getCollection(collectionName);
        Document query = new Document("_id", new ObjectId("5f05e46281048f54ac98c455"));
        Document result = collection.find(query).iterator().next();
        System.out.println(result);
        System.out.println("Test3: " + result.getString("Cluster"));
    }
}

Получение исключения в приведенном выше коде - 

    INFO: Exception in monitor thread while connecting to server cluster0-shard-00-01.mff6p.mongodb.net:27017
com.mongodb.MongoSocketReadException: Prematurely reached end of stream
    at com.mongodb.internal.connection.SocketStream.read(SocketStream.java:112)
    at com.mongodb.internal.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:580)
    at com.mongodb.internal.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:445)
    at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:299)
    at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:259)
    at com.mongodb.internal.connection.CommandHelper.sendAndReceive(CommandHelper.java:83)
    at com.mongodb.internal.connection.CommandHelper.executeCommand(CommandHelper.java:33)
    at com.mongodb.internal.connection.InternalStreamConnectionInitializer.initializeConnectionDescription(InternalStreamConnectionInitializer.java:105)
    at com.mongodb.internal.connection.InternalStreamConnectionInitializer.initialize(InternalStreamConnectionInitializer.java:62)
    at com.mongodb.internal.connection.InternalStreamConnection.open(InternalStreamConnection.java:129)
    at com.mongodb.internal.connection.DefaultServerMonitor$ServerMonitorRunnable.run(DefaultServerMonitor.java:117)
    at java.base/java.lang.Thread.run(Thread.java:834)

Кто-нибудь может мне помочь, я думаю, что есть проблема с URL-адресом строки подключения, MongoClientURI ...

Ответы [ 2 ]

0 голосов
/ 14 июля 2020

Попробуйте вот так 

const MongoClient = require('mongodb').MongoClient; 

const dburl = "mongodb+srv://" + user + ":" + pwd + "@cluster0.mff6p.mongodb.net/"
        + dbName + "?retryWrites=true&w=majority&connectTimeoutMS=30000&socketTimeoutMS=30000";

MongoClient.connect(dburl,{useNewUrlParser:true,useUnifiedTopology:true},(err,client) => {

                  if(err){
                      console.log("Error",err);
                   }
                  else{
                      console.log("Connected");
                  }  
});

СПАСИБО

0 голосов
/ 14 июля 2020

Похоже, ваше соединение было прервано сервером mon go. У этого может быть несколько причин, и лучший способ отладки - просмотреть журналы сервера.

Обычно проблема заключается в следующем:

Из документации:

Для для длительно работающих приложений часто бывает целесообразно включить "keepAlive" на определенное количество миллисекунд. Без него по прошествии некоторого времени вы можете начать видеть ошибки «соединение закрыто», хотя, кажется, без причины.

Попробуйте включить свойство keepAlive. 

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