MongoDB和Java(6):Spring Data整合MongoDB副本集、分片集群
最近花了一些时间学习了下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中存在且已经配置了分片键。
5、参考资料
生产环境部署MongoDB副本集(带keyfile安全认证以及用户权限)
最新文章
- Entity Framework中使用IEnumerable<;T>;、IQueryable<;T>;及IList<;T>;的区别
- C语言中使用系统自带的快排函数
- insertAdjacentHTML方法示例
- Android 遮罩层效果
- ACM/ICPC 之 数据结构-线段树+区间离散化(POJ2528)
- ld returned 1 exit status";的解决办法
- 【转】Docker 常用命令
- 国行手机安装GOOGLE PLAY
- 用Javascript实现回到顶部效果
- Android中使用am命令实现在命令行启动程序详解
- uva 11324
- Cursor--游标
- 关于echarts的使用----模块化单文件引入(推荐) 与标签式单文件引入
- 洛谷2344 奶牛抗议(DP+BIT+离散化)
- C#_会员管理系统:开发五(用户注册)
- Cocos2d-x 3.2 Lua演示样本CocosDenshionTest(音频测试)
- 【MySQL案件】mysql登录-S失败
- Java UDP Socket
- VS 2008 开发WinCE程序 编译部署速度慢的解决办法
- ubuntu16.04微信安装
热门文章
- Writeup:第五届上海市大学生网络安全大赛-Web
- 深度学习剖根问底: Adam优化算法的由来
- HTML5中的Web Worker技术
- 【NWJS】解析node-webkit(NWJS)的打包和发布
- Solidity开发注意
- vue中axios使用二:axios以post,get,jsonp的方式请求后台数据
- 123456123456----updateV#%#6%#%---pinLv###1%%%----com.zzj.CarCleanGame567---前show后广--儿童洗车-222222
- EasyNVR网页摄像机无插件H5、谷歌Chrome直播方案中使用Onvif协议控制视频设备预置位转动
- Python正则简单实例分析
- Linux——xargs命令学习