我们的应用程序是建立在 mongodb 副本集之上的。 我想捕获副本集处于自动故障转移过程中的时间范围内抛出的所有异常。 我将使应用程序重试或等待故障转移完成。 这样故障转移就不会影响用户。 我在这里找到了描述 Java 驱动程序行为的文档:https://jira.mongodb.org/browse/DOCS-581

我编写了一个测试程序来查找所有可能的异常，它们都是 MongoException 但具有不同的消息:

1. MongoException.Network:“对服务器/10.11.0.121:27017 的读取操作在数据库测试中失败”
2. MongoException: “找不到主人”
3. MongoException:“没有与 master 对话，重试次数已用完”
4. 也许更多...

我很困惑，不确定通过错误消息确定是否安全。 我也不想捕获所有 MongoException。 有什么建议吗？

谢谢

最佳答案

我现在认为Java中的Mongo在这方面尤其薄弱。我认为您解释错误代码的策略无法很好地扩展或在驱动程序发展中幸存下来。当然，这是意见。

好消息是 Mongo 驱动程序提供了一种获取 ReplicaSet 状态的方法:http://api.mongodb.org/java/2.11.1/com/mongodb/ReplicaSetStatus.html .您可以直接使用它来确定是否有对您的应用程序可见的 Master。如果这就是你想知道的，http://api.mongodb.org/java/2.11.1/com/mongodb/Mongo.html#getReplicaSetStatus()是你所需要的全部。捕获那个 child 并检查一个非空的主人，你就在路上。

ReplicaSetStatus rss = mongo.getReplicaSetStatus();
boolean driverInFailover = rss.getMaster() == null;

如果您真正需要的是弄清楚 ReplSet 是死的、只读的还是读写的，这会变得更加困难。这是对我有用的代码。我讨厌它。

@Override
public ReplSetStatus getReplSetStatus() {
    ReplSetStatus rss = ReplSetStatus.DOWN;
    MongoClient freshClient = null;
    try {
        if ( mongo != null ) {
            ReplicaSetStatus replicaSetStatus = mongo.getReplicaSetStatus();
            if ( replicaSetStatus != null ) {
                if ( replicaSetStatus.getMaster() != null ) {
                    rss = ReplSetStatus.ReadWrite;
                } else {
                    /*
                     * When mongo.getReplicaSetStatus().getMaster() returns null, it takes a a
                     * fresh client to assert whether the ReplSet is read-only or completely
                     * down. I freaking hate this, but take it up with 10gen.
                     */
                    freshClient = new MongoClient( mongo.getAllAddress(), mongo.getMongoClientOptions() );
                    replicaSetStatus = freshClient.getReplicaSetStatus();
                    if ( replicaSetStatus != null ) {
                        rss = replicaSetStatus.getMaster() != null ? ReplSetStatus.ReadWrite : ReplSetStatus.ReadOnly;
                    } else {
                        log.warn( "freshClient.getReplicaSetStatus() is null" );
                    }
                }
            } else {
                log.warn( "mongo.getReplicaSetStatus() returned null" );
            }
        } else {
            throw new IllegalStateException( "mongo is null?!?" );
        }
    } catch ( Throwable t ) {
        log.error( "Ingore unexpected error", t );
    } finally {
        if ( freshClient != null ) {
            freshClient.close();
        }
    }
    log.debug( "getReplSetStatus(): {}", rss );
    return rss;
}

我讨厌它，因为它不遵循您的应用程序的 Mongo Java 驱动程序约定，您的应用程序只需要一个 Mongo，并且通过这个单例，您可以连接到其余的 Mongo 数据结构(数据库、集合等)。我只能通过在检查期间新建第二个 Mongo 来观察这项工作，以便我可以依靠 ReplicaSetStatus 空检查来区分“ReplSet-DOWN”和“只读”。

此驱动程序真正需要的是某种方式来直接询问 Mongo 的问题，以查看 ReplSet 是否可以预期此时支持每个 WriteConcerns 或 ReadPreferences。像...

/**
 * @return true if current state of Client can support readPreference, false otherwise
 */
boolean mongo.canDoRead( ReadPreference readPreference )

/**
 * @return true if current state of Client can support writeConcern; false otherwise
 */
boolean mongo.canDoWrite( WriteConcern writeConcern ) 

这对我来说很有意义，因为它承认创建 Mongo 时 ReplSet 可能很棒，但现在的情况意味着特定类型的读取或写入操作可能会因条件变化而失败。

无论如何，也许http://api.mongodb.org/java/2.11.1/com/mongodb/ReplicaSetStatus.html满足您的需求。

关于mongodb - MongoDB java 驱动程序如何确定副本集是否处于自动故障转移过程中？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/17988394/