如何检查是否与Java建立了MongoDB连接？

Question

在我的应用程序中，MongoDB 3.2.4在自定义端口上运行，我想实现逻辑，我的应用程序将尝试在自定义端口上访问MongoDB，如果失败，它将使用默认的27018端口。

为此，我使用以下代码：

String mongoClientURI = "mongodb://" + DB_SRV_USR + ":" + DB_SRV_PWD + "@" + DB_URL + ":" + DB_PORT_CUS + "/" + dbName;
MongoClientURI connectionString = new MongoClientURI(mongoClientURI);

// enable SSL connection
MongoClientOptions.builder().sslEnabled(true).build();

if (this.mongoClient == null) {
    this.mongoClient = new MongoClient(connectionString);
}

// create database if doesn't exist
MongoDatabase mdb = this.mongoClient.getDatabase(dbName);

try {
    this.mongoClient.getAddress();
} catch (com.mongodb.MongoSocketOpenException e) {
    System.out.println("Switch to default port");
    /*…use default port logic…*/
}

问题是没有捕获到这个异常。虽然MongoDB抛出以下异常：

com.mongodb.MongoSocketOpenException：com.mongodb.connection.SocketStream.open（SocketStream.java：63）在com.mongodb.connection的com.mongodb.connection.InternalStreamConnection.open（InternalStreamConnection.java:114）处打开套接字异常。 DefaultServerMonitor $ ServerMonitorRunnable.run（DefaultServerMonitor.java:128）at java.lang.Thread.run（Thread.java:745）引起：java.net.ConnectException：连接被拒绝：连接java.net.DualStackPlainSocketImpl.waitForConnect（Native方法）在java.net.AbstractStackPocketSmplImpl.smplConnect（DualStackPlainSocketImpl.java:85）java.net.AbstractPlainSocketImpl.doConnect（AbstractPlainSocketImpl.java:350）java.net的java.net.AbstractPlainSocketImpl.connectToAddress（AbstractPlainSocketImpl.java:206）。 java.net.Socket.connect中java.net.SocksSocketImpl.connect（SocksSocketImpl.java:392）的java.net.PlainSocketImpl.connect（PlainSocketImpl.java:172）中的net.AbstractPlainSocketImpl.connect（AbstractPlainSocketImpl.java:188） （Socket.java:589）在c om.mongodb.connection.SocketStreamHelper.initialize（SocketStreamHelper.java:50）at com.mongodb.connection.SocketStream.open（SocketStream.java:58）... 3更多

我的try-catch表达式无法捕获此异常。

我尝试了多种方法，例如捕获：

• Exception
• RuntimeException
• MongoSocketOpenException
• MongoException
• MongoCommandException

没有一个不起作用。

我的问题：

1. 如何检查MongoDB连接是否已建立？
2. 怎么能抓住MongoSocketOpenException的例外？

Answer 1

1. 我用这段代码来检查连接：

   try {
       mongo.getAddress();
   } catch (Exception e) {
       System.out.println("Database unavailable!");
       mongo.close();
       return;
   }

2. 不确定在这里我的猜测是this.mongoClient.getAddress();没有抛出那个例外，但我真的不知道

编辑：我通过以下方式初始化：

Builder builder = MongoClientOptions.builder().connectTimeout(3000);  
MongoClient mongo = new MongoClient(new ServerAddress("192.168.0.1", 3000), builder.build());