最近花了一些时间学习了下MongoDB数据库，感觉还是比较全面系统的，涉及了软件安装、客户端操作、安全认证、副本集和分布式集群搭建，以及使用Spring Data连接MongoDB进行数据操作，收获很大。特此记录，以备查看。
文章目录：
MongoDB和Java（1）：Linux下的MongoDB安装
MongoDB和Java（2）：普通用户启动mongod进程
MongoDB和Java（4）：Spring Data整合MongoDB（XML配置）
MongoDB和Java（5）：Spring Data整合MongoDB（注解配置）
MongoDB和Java（6）：Spring Data整合MongoDB副本集、分片集群
本文记录如何整合Spring data和MongoDB副本集、分片集群。
Java客户端这边的开发环境和《MongoDB和Java（5）：Spring Data整合MongoDB（注解配置）》是一样的，实体类、数据层接口、测试类代码都不需要太多的改动，主要需要改的就是mongo的连接属性文件、MongoClient的创建方式。
源代码下载
MongoDB和Java学习代码.zip
1、副本集环境
主：10.10.13.195:27017
从：10.10.13.195:27018, 10.10.13.195:27019
副本集搭建请参考
生产环境部署MongoDB副本集(带keyfile安全认证以及用户权限)
下面我们就简单介绍一下Spring data整合副本集
2、修改连接属性文件
首先修改mongodb.properties
# 副本集环境
mongo.rs=10.10.13.195:27017,10.10.13.195:27018,10.10.13.195:27019 # 单机环境
mongo.host=10.10.13.195
mongo.port=27017 # 数据库和验证信息
mongo.dbname=test
mongo.username=xugf
mongo.password=123456 mongo.connectionsPerHost=8
mongo.minConnectionsPerHost=3
mongo.threadsAllowedToBlockForConnectionMultiplier=4
mongo.connectTimeout=1000
mongo.maxWaitTime=1500
mongo.socketKeepAlive=true
mongo.socketTimeout=1500
增加的内容
# 副本集环境
mongo.rs=10.10.13.195:27017,10.10.13.195:27018,10.10.13.195:27019
3、修改MongoConfiguration配置类
首先修改MongoProperties类，主要是添加获取List<ServerAddress>的方法，在此只写了与副本集环境相关的代码片段：
@Component
@PropertySource(value = "classpath:mongodb.properties")
public class MongoProperties { @Value("${mongo.rs}")
private String rs; private List<ServerAddress> rsServers = new ArrayList<ServerAddress>(); public String getRs() {
return rs;
} public void setRs(String rs) {
this.rs = rs;
} public List<ServerAddress> getRsServers() {
try {
if (rs != null && rs.trim().length() > 0) {
String[] hosts = rs.split(",");
for (String host : hosts) {
String[] ipAndPort = host.split(":");
if (ipAndPort.length == 0) {
continue;
}
if (ipAndPort.length == 1) {
rsServers.add(new ServerAddress(ipAndPort[0], 27017));
} else {
rsServers.add(new ServerAddress(ipAndPort[0], Integer
.parseInt(ipAndPort[1])));
}
}
} else {
rsServers.add(new ServerAddress("localhost", 27017));
return rsServers;
}
} catch (UnknownHostException e) {
}
return rsServers;
}
}
然后修改MongoConfiguration的mongoClient方法，不再使用host + port方式创建MongoClient，而是传入一个List<ServerAddress>，MongoClient会去判断这是一个副本集环境
public MongoClient mongoClient() throws Exception {
List<MongoCredential> credentialsList = new ArrayList<MongoCredential>();
credentialsList.add(MongoCredential.createScramSha1Credential(
mongoProperties.getUsername(), mongoProperties.getDbname(),
mongoProperties.getPassword().toCharArray()));
Builder builder = MongoClientOptions.builder();
builder.connectionsPerHost(mongoProperties.getConnectionsPerHost());
builder.threadsAllowedToBlockForConnectionMultiplier(mongoProperties
.getThreadsAllowedToBlockForConnectionMultiplier());
builder.connectTimeout(mongoProperties.getConnectTimeout());
builder.maxWaitTime(mongoProperties.getMaxWaitTime());
builder.socketKeepAlive(mongoProperties.isSocketKeepAlive());
builder.socketTimeout(mongoProperties.getSocketTimeout());
builder.minConnectionsPerHost(mongoProperties
.getMinConnectionsPerHost());
// 获取副本集服务器集合
List<ServerAddress> rsServers = mongoProperties.getRsServers();
System.out.println("Rs Servers: " + rsServers);
return new MongoClient(rsServers, credentialsList, builder.build());
}
第21行：使用MongoProperties获取服务器地址的列表
第25行：使用public MongoClient(List<ServerAddress> seeds, List<MongoCredential> credentialsList, MongoClientOptions options)构造方法创建MongoClient对象
做了以上改动之后，我们就可以测试了，很简单。
4、分片集群整合
软件系统环境
| MongoDB版本 | mongodb-linux-x86_64-rhel62-4.0.2 |
| 服务器操作系统 | CentOS 6.5 |
| 服务器IP | 10.10.13.195 |
端口分配
| 27016 | Mongos服务器 |
| 27020 | 副本集sh1，分片1的节点 |
| 27021 | 副本集sh1，分片1的节点 |
| 27022 | 副本集sh1，分片1的节点 |
| 27023 | 副本集configSet，配置服务器 |
| 27024 | 副本集configSet，配置服务器 |
| 27025 | 副本集configSet，配置服务器 |
| 27026 | 副本集sh2，分片2的节点 |
| 27027 | 副本集sh2，分片2的节点 |
| 27028 | 副本集sh2，分片2的节点 |
分片集群搭建请参考
Spring Data整合分片集群的方式更加简单，只需要修改连接属性文件即可，配置如下：
# 分布式集群环境
mongo.rs=10.10.13.195:27016 # 数据库和验证信息
mongo.dbname=test
mongo.username=xugf
mongo.password=123456 mongo.connectionsPerHost=8
mongo.minConnectionsPerHost=3
mongo.threadsAllowedToBlockForConnectionMultiplier=4
mongo.connectTimeout=1000
mongo.maxWaitTime=1500
mongo.socketKeepAlive=true
mongo.socketTimeout=1500
第二行，只需要去连接mongos服务就可以。
其余的都不需要修改，前提是程序操作的实体类在mogos中存在且已经配置了分片键。