MongoDB：ReadPreferenceServerSelector未选择服务器

Question

最近我使用的是mongodb java异步驱动程序，它是最新发布的。我正在写一些简单的测试代码，它们是：

    MongoClient mongoClient = MongoClients.create();
    System.out.println("database has been connected!");

    SingleResultCallback<Void> callbackWhenFinished = new SingleResultCallback<Void>() {
        @Override
        public void onResult(final Void result, final Throwable t) {
            System.out.println("Operation Finished!");
        }
    };

    mongoClient.listDatabaseNames().forEach(new Block<String>() {
        @Override
        public void apply(final String s) {
            System.out.println(s);
        }
    }, callbackWhenFinished);

所以您可以看到没有调用回调函数。有人知道为什么吗？

Answer 1

简单的回答是您的回调最终将被调用。

为了获得更长的答案，让我们通过您的代码：

    MongoClient mongoClient = MongoClients.create();
    System.out.println("database has been connected!");

MongoClient不会阻止等待连接到后台的MongoDB（内部连接池正在尝试连接）。从您的日志中，我可以看到您的默认ServerSelectionTimeout为30000ms。

  System.out.println("======= Start =======");

  MongoClient mongoClient = MongoClients.create();

  final CountDownLatch latch = new CountDownLatch(1);

  SingleResultCallback<Void> callbackWhenFinished = new SingleResultCallback<Void>() {
      @Override
      public void onResult(final Void result, final Throwable t) {
          System.out.println("Operation Finished!");
          if (t != null) {
              System.out.println("listDatabaseNames() errored: " + t.getMessage());
          }
          latch.countDown();
      }
  };

  mongoClient.listDatabaseNames().forEach(new Block<String>() {
      @Override
      public void apply(final String s) {
          System.out.println(s);
      }
  }, callbackWhenFinished);

  latch.await();

  // close resources
  mongoClient.close();
  System.out.println("======= Finish =======");

>

没有MongoDB可用。它最终将调用回调并打印出有错误。它将等待直到ServerSelectionTimeout超时。

有一个MongoDB可用。它将最终连接，对于每个数据库，它将应用block并打印出数据库名称，然后最后调用它完成的回调信令。