先决条件
先运行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 data ; // the name of the data in which the user is defined char[] password; // the password as a character array // ... MongoCredential credential = MongoCredential.createCredential(user, data , password); MongoClientOptions options = MongoClientOptions.builder().sslEnabled(true).build(); MongoClient mongoClient = new MongoClient(new ServerAddress(\"host1\", 27017), Arrays.asList(credential), options);
这里只是官方给的简单演示连接, 不可直接用于生产环境, 比如: 这里边没有配置读写关注, 读取偏好, 连接池配置等都是默认的. 而这些默认值直接用于生产环境肯定是不行的.
至于生产环境怎么配置, 要根据业务情况来实际分析, 我在后边会提供一个参考.
参考官方文档:
https://mongodb.github.io/mongo-java-driver/3.4/driver/tutorials/connect-to-mongodb/
继续阅读与本文标签相同的文章
2017全球存储大会:存储设备面临三大挑战
区块链核心内容有哪些东西?
-
Java锁---偏向锁、轻量级锁、自旋锁、重量级锁
2026-05-19栏目: 教程
-
CTF从入门到提升(七)insert 等数据表相关操作注入及例题分享
2026-05-19栏目: 教程
-
合肥新闻联播:“NEXT创新大会”合肥重磅开年 聚焦“新经济”赋能产业升级
2026-05-19栏目: 教程
-
NEXT创新大会走进合肥,看“新经济”带“科创之都”腾飞。
2026-05-19栏目: 教程
-
win7系统想要用iis7远程桌面管理,可是他显示说你没有开通远程权限怎么解决?
2026-05-19栏目: 教程
