MongoDB和Java（6）：Spring Data整合MongoDB副本集、分片集群

 1 # 副本集环境
 2 mongo.rs=10.10.13.195:27017,10.10.13.195:27018,10.10.13.195:27019
 3 
 4 # 单机环境
 5 mongo.host=10.10.13.195
 6 mongo.port=27017
 7 
 8 # 数据库和验证信息
 9 mongo.dbname=test
10 mongo.username=xugf
11 mongo.password=123456
12 
13 mongo.connectionsPerHost=8
14 mongo.minConnectionsPerHost=3
15 mongo.threadsAllowedToBlockForConnectionMultiplier=4
16 mongo.connectTimeout=1000
17 mongo.maxWaitTime=1500
18 mongo.socketKeepAlive=true
19 mongo.socketTimeout=1500

增长的内容

# 副本集环境
mongo.rs=10.10.13.195:27017,10.10.13.195:27018,10.10.13.195:27019

三、修改MongoConfiguration配置类

首先修改MongoProperties类，主要是添加获取List<ServerAddress>的方法，在此只写了与副本集环境相关的代码片断：

 1 @Component
 2 @PropertySource(value = "classpath:mongodb.properties")
 3 public class MongoProperties {
 4 
 5     @Value("${mongo.rs}")
 6     private String rs;
 7 
 8     private List<ServerAddress> rsServers = new ArrayList<ServerAddress>();
 9 
10     public String getRs() {
11         return rs;
12     }
13 
14     public void setRs(String rs) {
15         this.rs = rs;
16     }
17 
18     public List<ServerAddress> getRsServers() {
19         try {
20             if (rs != null && rs.trim().length() > 0) {
21                 String[] hosts = rs.split(",");
22                 for (String host : hosts) {
23                     String[] ipAndPort = host.split(":");
24                     if (ipAndPort.length == 0) {
25                         continue;
26                     }
27                     if (ipAndPort.length == 1) {
28                         rsServers.add(new ServerAddress(ipAndPort[0], 27017));
29                     } else {
30                         rsServers.add(new ServerAddress(ipAndPort[0], Integer
31                                 .parseInt(ipAndPort[1])));
32                     }
33                 }
34             } else {
35                 rsServers.add(new ServerAddress("localhost", 27017));
36                 return rsServers;
37             }
38         } catch (UnknownHostException e) {
39         }
40         return rsServers;
41     }
42 }

而后修改MongoConfiguration的mongoClient方法，再也不使用host + port方式建立MongoClient，而是传入一个List<ServerAddress>，MongoClient会去判断这是一个副本集环境

 1 public MongoClient mongoClient() throws Exception {
 2 
 3     List<MongoCredential> credentialsList = new ArrayList<MongoCredential>();
 4     credentialsList.add(MongoCredential.createScramSha1Credential(
 5             mongoProperties.getUsername(), mongoProperties.getDbname(),
 6             mongoProperties.getPassword().toCharArray()));
 7 
 8     Builder builder = MongoClientOptions.builder();
 9 
10     builder.connectionsPerHost(mongoProperties.getConnectionsPerHost());
11     builder.threadsAllowedToBlockForConnectionMultiplier(mongoProperties
12             .getThreadsAllowedToBlockForConnectionMultiplier());
13     builder.connectTimeout(mongoProperties.getConnectTimeout());
14     builder.maxWaitTime(mongoProperties.getMaxWaitTime());
15     builder.socketKeepAlive(mongoProperties.isSocketKeepAlive());
16     builder.socketTimeout(mongoProperties.getSocketTimeout());
17     builder.minConnectionsPerHost(mongoProperties
18             .getMinConnectionsPerHost());
19 
20     // 获取副本集服务器集合
21     List<ServerAddress> rsServers = mongoProperties.getRsServers();
22 
23     System.out.println("Rs Servers: " + rsServers);
24 
25     return new MongoClient(rsServers, credentialsList, builder.build());
26 }

第21行：使用MongoProperties获取服务器地址的列表

第25行：使用public MongoClient(List<ServerAddress> seeds, List<MongoCredential> credentialsList, MongoClientOptions options)构造方法建立MongoClient对象

作了以上改动以后，咱们就能够测试了，很简单。

四、分片集群整合

软件系统环境

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的节点

分片集群搭建请参考

MongoDB 分片集群技术

Spring Data整合分片集群的方式更加简单，只须要修改链接属性文件便可，配置以下：

 1 # 分布式集群环境
 2 mongo.rs=10.10.13.195:27016
 3 
 4 # 数据库和验证信息
 5 mongo.dbname=test
 6 mongo.username=xugf
 7 mongo.password=123456
 8 
 9 mongo.connectionsPerHost=8
10 mongo.minConnectionsPerHost=3
11 mongo.threadsAllowedToBlockForConnectionMultiplier=4
12 mongo.connectTimeout=1000
13 mongo.maxWaitTime=1500
14 mongo.socketKeepAlive=true
15 mongo.socketTimeout=1500

第二行，只须要去链接mongos服务就能够。

其他的都不须要修改，前提是程序操做的实体类在mogos中存在且已经配置了分片键。

五、参考资料

MongoDB 分片集群技术

生产环境部署MongoDB副本集(带keyfile安全认证以及用户权限)