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 the
MongoClientURI

connection string.

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

连接到副本集

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

You can specify the members using the 
MongoClientURI

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

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

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


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

参考官方文档:

https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/


转发清注明出处:  https://www.cnblogs.com/jycboy/p/10076859.html

原文 

http://www.cnblogs.com/jycboy/p/10076859.html

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Java 连接MongoDB集群的几种方式

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址