详解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实例
以下几种方法:
1.
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:
指定两个副本集:
至少有一个副本集和副本集选项的成员:
你可以使用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);
这里只是官方给的简单演示连接, 不可直接用于生产环境, 比如: 这里边没有配置读写关注, 读取偏好, 连接池配置等都是默认的. 而这些默认值直接用于生产环境肯定是不行的.
至于生产环境怎么配置, 要根据业务情况来实际分析, 我在后边会提供一个参考.
生产环境配置见:
参考官方文档:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。