MongoDB: java.lang.IllegalStateException: 状态应该为：打开

Question

我有一个应用程序，从一个数据源中提取数据并将其插入到MongoDB。有时候提取过程需要很长时间，当应用程序尝试将一行数据推送到MongoDB时，可能会引发以下异常，可能是由于超时问题导致：

com.mongodb.MongoSocketReadException: Prematurely reached end of stream
    at com.mongodb.connection.SocketStream.read(SocketStream.java:88)
    at com.mongodb.connection.InternalStreamConnection.receiveResponseBuffers(InternalStreamConnection.java:492)
    at com.mongodb.connection.InternalStreamConnection.receiveMessage(InternalStreamConnection.java:222)
    at com.mongodb.connection.UsageTrackingInternalConnection.receiveMessage(UsageTrackingInternalConnection.java:105)
    at com.mongodb.connection.DefaultConnectionPool$PooledConnection.receiveMessage(DefaultConnectionPool.java:438)
    at com.mongodb.connection.WriteCommandProtocol.receiveMessage(WriteCommandProtocol.java:262)
    at com.mongodb.connection.WriteCommandProtocol.execute(WriteCommandProtocol.java:104)
    at com.mongodb.connection.UpdateCommandProtocol.execute(UpdateCommandProtocol.java:64)
    at com.mongodb.connection.UpdateCommandProtocol.execute(UpdateCommandProtocol.java:37)
    at com.mongodb.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:168)
    at com.mongodb.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:289)
    at com.mongodb.connection.DefaultServerConnection.updateCommand(DefaultServerConnection.java:143)
    at com.mongodb.operation.MixedBulkWriteOperation$Run$3.executeWriteCommandProtocol(MixedBulkWriteOperation.java:481)
    at com.mongodb.operation.MixedBulkWriteOperation$Run$RunExecutor.execute(MixedBulkWriteOperation.java:647)
    at com.mongodb.operation.MixedBulkWriteOperation$Run.execute(MixedBulkWriteOperation.java:400)
    at com.mongodb.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:180)
    at com.mongodb.operation.MixedBulkWriteOperation$1.call(MixedBulkWriteOperation.java:169)
    at com.mongodb.operation.OperationHelper.withConnectionSource(OperationHelper.java:232)
    at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:223)
    at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:169)
    at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:75)
    at com.mongodb.Mongo.execute(Mongo.java:827)
    at com.mongodb.Mongo$2.execute(Mongo.java:810)
    at com.mongodb.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:515)
    at com.mongodb.MongoCollectionImpl.update(MongoCollectionImpl.java:508)
    at com.mongodb.MongoCollectionImpl.updateOne(MongoCollectionImpl.java:355)
    at com.test.db.mongoDB.RetryingMongoCollection.updateOne(RetryingMongoCollection.java:909)

有一个MongoCollection类的包装器，可以处理每个抛出的MongoException和java.lang.IllegalStateException异常

@Override
public UpdateResult updateOne(Bson filter, Bson update,
        UpdateOptions updateOptions) {
    UpdateResult retVal = null;
    final ExceptionHelper ex = new ExceptionHelper(CAConstants.RETRIES, ErrorType.ERROR, true);
    boolean isDone = false;
    while (!isDone) {
        try {
            retVal = proxied.updateOne(filter, update, updateOptions);
            isDone = true;
        } catch (final MongoException | IllegalStateException e) {
            ex.logIfZero("Failed to launch MongoDB operation", e);
            if (ex.lastTry()) {
                isDone = true;
                Log.error("Failed to launch MongoDB operation.", e);
            } else {
                Log.error("[MDB] Going to update mongo instance due to exception", e);
                db = MongoDBFactory.getUpdatedMongoDBInstance();
                setCollection();
            }
        }
    }
    return retVal;
}

尝试重新加载MongoClient：

        if ( mongoClient != null ) {
            try {
                mongoClient.close();
            } catch (Exception e) {
                Log.error("Mongo client throws exception while closing connection", e);
            }
...
        mongoClient = new MongoClient(servers, Arrays.asList(credential), 
                new MongoClientOptions.Builder()
                    .requiredReplicaSetName(REPLICASET_NAME)
                    .connectTimeout(0)
                    .connectionsPerHost(CONNECTION_PER_HOST)
                    .cursorFinalizerEnabled(false)
                    .build());

        db = mongoClient.getDatabase(database);

然而，在出现"com.mongodb.MongoSocketReadException: Prematurely reached end of stream"后更新mongoClient时，会出现以下错误：

java.lang.IllegalStateException: state should be: open
    at com.mongodb.assertions.Assertions.isTrue(Assertions.java:70)
    at com.mongodb.connection.BaseCluster.selectServer(BaseCluster.java:82)
    at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.<init>(ClusterBinding.java:75)
    at com.mongodb.binding.ClusterBinding$ClusterBindingConnectionSource.<init>(ClusterBinding.java:71)
    at com.mongodb.binding.ClusterBinding.getWriteConnectionSource(ClusterBinding.java:68)
    at com.mongodb.operation.OperationHelper.withConnection(OperationHelper.java:221)
    at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:169)
    at com.mongodb.operation.MixedBulkWriteOperation.execute(MixedBulkWriteOperation.java:75)
    at com.mongodb.Mongo.execute(Mongo.java:827)
    at com.mongodb.Mongo$2.execute(Mongo.java:810)
    at com.mongodb.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:515)
    at com.mongodb.MongoCollectionImpl.update(MongoCollectionImpl.java:508)
    at com.mongodb.MongoCollectionImpl.updateOne(MongoCollectionImpl.java:355)
    at com.test.db.mongoDB.RetryingMongoCollection.updateOne(RetryingMongoCollection.java:909)

并且一直失败......

我使用的是mongoDB ver 3.2.9; Mongo java客户端版本为3.3.0。

请提供支持。

- EVG

---

我注意到你也在mongodb-user组（https://groups.google.com/forum/#!topic/mongodb-user/hhoFxnSplfI）发了这个问题，在那里Ross要求你跟进一个Jira问题。 你最终是否在Jira上提交了报告或找到了超时错误的解决方案？ 当“拉取过程需要很长时间”时，具体需要多久？ - Stennie

嗨，Stennie，拉取过程可能需要超过一个小时的时间。关键是我们逐个从不同的表中提取数据。因此，我们无法控制它... - EVG

Answer 1

尝试在MongoClientOptions中设置maxConnectionIdleTime选项（特别是如果您正在使用托管的MongoDB环境）。

示例：

    new MongoClientOptions.Builder()
    .requiredReplicaSetName(REPLICASET_NAME)
    .maxConnectionIdleTime (MAX_IDLE_TIME)
    .connectionsPerHost(CONNECTION_PER_HOST)
    .cursorFinalizerEnabled(false)
    .build();

connectTimeout是误导性的，因为它是用于初始连接的超时设置。

关于重新初始化MongoClient的问题，请确保客户端代码在正确的范围内，以便插入代码能够捕获。此外，我只看到db对象被重新初始化，而不是集合级别对象（代理？）。

- Jai Hirsch