详解Java 连接MongoDB集群的几种方式

先决条件

先运行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 );​

2. you can specify themongoclienturi connection string.

				?

									mongoclient mongoclient = new mongoclient(new mongoclienturi("mongodb://host1:27017"));

连接到副本集

mongodb将自动发现主要和副本。

you can specify the members using themongoclienturi connection string:

指定两个副本集:

复制代码代码如下:

	mongoclient mongoclient = new mongoclient( new mongoclienturi("mongodb://host1:27017,host2:27017,host3:27017"));​

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

复制代码代码如下:

	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);