SocketTimeout bei geöffneter Verbindung in MongoDB

Ich habe eine Java-Anwendung, führt einige Aggregationen auf MongoDB, aber manchmal hängt es sich einfach und werfen Sie einen SocketTimeout exception. Wenn die Ausnahme die app läuft einwandfrei (für ein bisschen, dann wird es wohl wieder auferwecken Ausnahme).

Den ich gerade gefunden habe diese Erklärung , scheint eine mögliche Ursache, aber ich bin mir nicht sicher.

Ich initalize die MongoClient und halten die Verbindung zur DB öffnen. Ich bin mir nicht sicher, ob dies ein problem sein könnte und ich bekomme nur jedesmal die Datenbank und dann lassen Sie die Datenbank, um Müll gesammelt (und das schließen der Verbindung).

Ein anderer Ansatz könnte sein ping in regelmäßigen Abständen Mongo, um die Verbindung pool "frisch".

Client verwendet, ist so etwas wie dieses:

public class DbClient {

    private static MongoClient mongoClient;
    private static MongoDatabase db;

    private DbClient() {}

    public static void init() throws Exception {
        mongoClient = new MongoClient();
    }

    public static MongoDatabase getDB() {
        if(mongoClient == null)
            throw new IllegalStateException("Client not initialized!");

        if(db == null) {
            db = mongoClient.getDatabase("my_db");
        }
        return db;
    }
}

Ist dies die mögliche Ursache der SocketTimeout?

Dies ist die Ausnahme, die ausgelöst:

09:20:45.742 [qtp605535417-46] INFO  org.mongodb.driver.connection - Closed connection [connectionId{localValue:16, serverValue:6562}] to myapp.com:27017 because there was a socket exception raised by this connection.
09:20:45.743 [qtp605535417-46] ERROR myapp.service.Api - Error processing request
com.mongodb.MongoSocketReadTimeoutException: Timeout while receiving message
    at com.mongodb.connection.InternalStreamConnection.translateReadException(InternalStreamConnection.java:474) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:225) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.UsageTrackingInternalConnection.receiveMessage(UsageTrackingInternalConnection.java:102) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.DefaultConnectionPool$PooledConnection.receiveMessage(DefaultConnectionPool.java:435) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.CommandProtocol.execute(CommandProtocol.java:112) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:159) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:286) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.DefaultServerConnection.command(DefaultServerConnection.java:173) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:215) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:206) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.CommandOperationHelper.executeWrappedCommandProtocol(CommandOperationHelper.java:112) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.FindOperation$1.call(FindOperation.java:487) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.FindOperation$1.call(FindOperation.java:482) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:239) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:212) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.FindOperation.execute(FindOperation.java:482) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.operation.FindOperation.execute(FindOperation.java:79) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.Mongo.execute(Mongo.java:772) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.Mongo$2.execute(Mongo.java:759) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.OperationIterable.iterator(OperationIterable.java:47) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.FindIterableImpl.iterator(FindIterableImpl.java:143) ~[mongo-java-driver-3.2.2.jar!/:na]
    at myapp.common.db.service.dao.AnalysisMongoImpl.getAnalysis(AnalysisMongoImpl.java:66) ~[common-0.2.0-SNAPSHOT.jar!/:na]
    at myapp.common.db.service.AnalysisServiceImpl.getAnalysis(AnalysisServiceImpl.java:31) ~[common-0.2.0-SNAPSHOT.jar!/:na]
    at myapp.aggregator.service.Api$1.handle(Api.java:88) ~[aggregator-0.2.0-SNAPSHOT.jar!/:na]
    at spark.webserver.MatcherFilter.doFilter(MatcherFilter.java:139) [spark-core-1.1.1.jar!/:na]
    at spark.webserver.JettyHandler.doHandle(JettyHandler.java:54) [spark-core-1.1.1.jar!/:na]
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:179) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:136) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.server.Server.handle(Server.java:451) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.server.HttpChannel.run(HttpChannel.java:252) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:266) [jetty-server-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.run(AbstractConnection.java:240) [jetty-io-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:596) [jetty-util-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:527) [jetty-util-9.0.2.v20130417.jar!/:9.0.2.v20130417]
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_95]
Caused by: java.net.SocketTimeoutException: Read timed out
    at java.net.SocketInputStream.socketRead0(Native Method) ~[na:1.7.0_95]
    at java.net.SocketInputStream.read(SocketInputStream.java:152) ~[na:1.7.0_95]
    at java.net.SocketInputStream.read(SocketInputStream.java:122) ~[na:1.7.0_95]
    at com.mongodb.connection.SocketStream.read(SocketStream.java:85) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:491) ~[mongo-java-driver-3.2.2.jar!/:na]
    at com.mongodb.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:221) ~[mongo-java-driver-3.2.2.jar!/:na]
    ... 34 common frames omitted

Sie müssen die post die Ausnahme, seine Botschaft, und der stack-trace. In deiner Frage. Keiner der betreffenden Felder oder Methoden sollen statisch sein.
Ich habe bearbeitet die Frage, danke.
hm, warum? Ich vermute, dass die getDB() könnte das Problem sein, aber wie ich gelesen habe, sollte ich Griff das MongoClient als ein Singleton.
Client != Cursor && Client != - Verbindung. Eigentlich ist der client hält eine Verbindung pool. Über diese Verbindung werden die Operationen auf dem server ausgeführt, wie Abfragen. In diesem Fall wird ein cursor zurückgegeben. Im Fall der Vorgang zu lange dauert, wird ein timeout ausgelöst wird und die Verbindung geschlossen server-Seite. Das, was ich sehen kann, was passiert ist.
Ich glaube nicht, dass dies der Fall ist. Ich habe ein Abfrage-timeout, und diese geworfen werden, auch für nicht-heavy-Aggregationen. Bei lang andauernden Abfragen die Ausnahme, die ausgelöst, ist die richtige. collection.aggregate(pipeline).maxTime(maxTimeout, TimeUnit.SECONDS); und aus den logs kann ich sehen, dass die Ausnahme ausgelöst wird, BEVOR die aggregation.

InformationsquelleAutor Enrichman | 2016-02-24

10

Nach einigen versuchen habe ich herausgefunden, dass es ein problem mit der Azure Load Balancer.

Nach 60s Inaktivität wird es trennen Sie alle ausstehenden TCP-Verbindung.

Nach weiteren Graben die ich gefunden habe, diesen Beitrag von der MongoDB-Diagnose FAQ, und ich habe den tcp-keepalive nach 120s:
```
sudo sysctl -w net.ipv4.tcp_keepalive_time=<value>
```
und habe ich auch den socketKeepAlive der MongoClient zu wahren:
```
MongoClientOptions.Builder options = MongoClientOptions.builder();
options.socketKeepAlive(true);
mongoClient = new MongoClient(mongoAddress, options.build());
```
Nachdem diese behebt das Problem scheint verschwunden!

Wo hast du diesen Befehl ausführen? sudo sysctl -w net.ipv4.tcp_keepalive_time=<Wert>
Direkt auf dem server (linux)

InformationsquelleAutor Enrichman
1

Wenn Sie Erfahrung socket Fehler zwischen clients und Servern oder zwischen Mitgliedern einer sharded cluster-oder Replikatgruppe, die nicht auf andere zumutbare verursacht, überprüfen Sie die TCP-keepalive-Wert (zum Beispiel, die tcp_keepalive_time Wert auf Linux-Systemen). Eine gemeinsame keepalive-Zeit ist 7200 Sekunden (2 Stunden), aber verschiedene Distributionen und macOS haben unterschiedliche Einstellungen.

Für MongoDB, Sie werden bessere Ergebnisse mit kürzeren keepalive Zeiten, in der Größenordnung von 120 Sekunden (zwei Minuten).

wo u installiert haben, mongodb u haben, führen Sie einfach diesen Befehl auf Linux

sudo sysctl -w net.ipv4.tcp_keepalive_time=120

Ich habe bereits net.ipv4.tcp_keepalive_time = 120 auf dem host und ich glaube keep-alive Einstellung wird standardmäßig auf true jetzt. Aber ich bin noch immer org.mongodb.driver.connection : Got socket exception on connection gelegentlich.

InformationsquelleAutor Prashant Agarwal

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.