Java连接MongoDB集群的几种方式

梦里梦外; 2022-04-06 02:05 303阅读 0赞

## 先决条件 ##

先运行mongodb肯定是必须的,然后导入以下包:

import com.mongodb.MongoClient;
    import com.mongodb.MongoClientURI;
    import com.mongodb.ServerAddress;
    import com.mongodb.MongoCredential;
    import com.mongodb.MongoClientOptions;

## `MongoClient` ##

MongoClient()实例表示到数据库的连接池; 你将只需要MongoClient类的一个实例，即使有多个线程也是一样。

重要:

通常，您只能为给定的MongoDB部署（例如独立，副本集或分片群集）创建一个MongoClient实例，并在您的应用程序中使用它。 但是，如果您创建了多个实例：

*  所有资源使用限制（例如，最大连接等）适用于每个MongoClient实例。
 *  要关闭一个实例，调用MongoClient.close() 来清理资源。

### 连接到一个独立的MongoDB实例 ###

以下几种方法:

MongoClient mongoClient = new MongoClient( "host1" , 27017 );

MongoClient mongoClient = new MongoClient(new MongoClientURI("mongodb://host1:27017"));

### MongoDB将自动发现主要和副本。连接到副本集 ###

You can specify the members using the [`MongoClientURI`][MongoClientURI] connection string:

指定两个副本集:

MongoClient mongoClient = new MongoClient( new MongoClientURI( "mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myReplicaSet"));

至少有一个副本集和副本集选项的成员：

MongoClient mongoClient = new MongoClient( new MongoClientURI( "mongodb://host1:27017,host2:27017,host3:27017/?replicaSet=myReplicaSet"));

你可以使用ServerAddress指定副本集中的所有成员.

MongoClient mongoClient = new MongoClient(
    Arrays.asList(new ServerAddress("host1", 27017),
                  new ServerAddress("host2", 27017),
                  new ServerAddress("host3", 27017)));

### 连接到分片集群 ###

要连接到分片群集，请将mongos实例或多个实例指定给MongoClient构造函数。

连接到一个mongos实例:

MongoClient mongoClient = new MongoClient( "localhost" , 27017 );

连接多个 `mongos` 实例:

MongoClient mongoClient = new MongoClient( new MongoClientURI("mongodb://host1:27017,host2:27017"));

MongoClient mongoClient = new MongoClient(
       Arrays.asList(new ServerAddress("host1", 27017),
                     new ServerAddress("host2", 27017)));

### 连接选项 ###

您可以使用`MongoClientURI`或`MongoClientOptions`或两者来指定连接设置。

例如，您可以在`MongoClientURI`连接字符串中指定 `TLS/SSL`和身份验证设置：

MongoClientURI uri = new MongoClientURI("mongodb://user1:pwd1@host1/?authSource=db1&ssl=true");
    MongoClient mongoClient = new MongoClient(uri);

您还可以使用`MongoClientOptions`来指定 `TLS/SSL` 和`MongoCredential`的认证信息：

String user; // the user name
     String database; // the name of the database in which the user is defined
     char[] password; // the password as a character array
     // ...
     MongoCredential credential = MongoCredential.createCredential(user, database, password);
     MongoClientOptions options = MongoClientOptions.builder().sslEnabled(true).build();
     MongoClient mongoClient = new MongoClient(new ServerAddress("host1", 27017),
                                               Arrays.asList(credential),
                                               options);

**这里只是官方给的简单演示连接, 不可直接用于生产环境**, 比如: 这里边没有配置读写关注, 读取偏好, 连接池配置等都是默认的. 而这些默认值直接用于生产环境肯定是不行的.

至于生产环境怎么配置, 要根据业务情况来实际分析, 我在后边会提供一个参考.

[生产环境配置见: mongodb连接配置实践][mongodb]

参考官方文档:

[https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/][https_mongodb.github.io_mongo-java-driver_3.4_driver_tutorials_connect-to-mongodb]

[MongoClientURI]: https://mongodb.github.io/mongo-java-driver/3.4/javadoc?/com/mongodb/MongoClientURI.html
[mongodb]: https://www.cnblogs.com/jycboy/p/10077080.html
[https_mongodb.github.io_mongo-java-driver_3.4_driver_tutorials_connect-to-mongodb]: https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/