如何优雅的进行Spring整合MongoDB详解

2023-09-16 03:19:05 66

前言

本文重点是要将mongodb与spring整合到项目中去，在实践中发现问题，追踪问题，然后解决问题。下面话不多说了，来一起看看详细的介绍吧。

一、准备

Maven、Spring(spring-data-mongodb)
springDataforMongoDB是SpringData的一个子模块。目标是为mongodb提供一个相近的一致的基于Spring的编程模型。
SpringDataforMongoDB核心功能是映射POJO到Mongo的DBCollection中的文档，并且提供Repository风格数据访问层。

二、特性

MongoDB的提供了一个面向文档存储，操作起来比较简单和容易。
你可以在MongoDB记录中设置任何属性的索引(如：FirstName="Ning",Address="Beijing")来实现更快的排序。
你可以通过本地或者网络创建数据镜像，这使得MongoDB有更强的扩展性。
如果负载的增加（需要更多的存储空间和更强的处理能力），它可以分布在计算机网络中的其他节点上这就是所谓的分片。
Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记，可轻易查询文档中内嵌的对象及数组。
MongoDb使用update()命令可以实现替换完成的文档（数据）或者一些指定的数据字段。
Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。
Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录，将key与value传给Reduce函数进行处理。
Map函数和Reduce函数是使用Javascript编写的，并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。
GridFS是MongoDB中的一个内置功能，可以用于存放大量小文件。
MongoDB允许在服务端执行脚本，可以用Javascript编写某个函数，直接在服务端执行，也可以把函数的定义存储在服务端，下次直接调用即可。
MongoDB支持各种编程语言:RUBY，PYTHON，JAVA，C++，PHP，C#等多种语言。

三、依赖包


org.springframework.data
spring-data-mongodb
1.5.0.RELEASE


org.slf4j
slf4j-log4j12
1.5.10

spring相关依赖



org.springframework
spring-web
${spring.version}


org.springframework
spring-webmvc
3.1.2.RELEASE



org.springframework
spring-test
4.3.1.RELEASE

四、集成MongoDB

【注：MongoDB添加权限管理请参见我的这篇文章:MongDB开启权限认证】

mongodb.properties

mongo.hostport=172.16.4.166:27017
mongo.dbname=ad_api_count
mongo.username=hehaitao
mongo.password=hehaitao
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4
#\u8FDE\u63A5\u8D85\u65F6\u65F6\u95F4
mongo.connectTimeout=1000
#\u7B49\u5F85\u65F6\u95F4
mongo.maxWaitTime=1500
mongo.autoConnectRetry=true
mongo.socketKeepAlive=true
#Socket\u8D85\u65F6\u65F6\u95F4
mongo.socketTimeout=1500
mongo.slaveOk=true

mongoDB.xml

spring-contex.xml

五、代码实现

基础实现MongoDBService

/**
*FileName:MongoDBService.java
*Package:com.lutongnet.ad.service
*Description:TODO
*Author:zhangfj
*Date:2012-11-29
*Version:V1.0
*/
packagecom.lutong.cps.schedule.service.fj;
importorg.springframework.context.ApplicationContext;
importorg.springframework.context.support.ClassPathXmlApplicationContext;
importorg.springframework.data.mongodb.core.MongoTemplate;
importorg.springframework.data.mongodb.core.query.Query;
importorg.springframework.stereotype.Service;
/**
*@authorzhangfj
*
*/
@Service("mongoDBService")
publicclassMongoDBService
{
/*@Resource(name="mongoTemplate")
protectedMongoTemplatemongoTemplate;*/
/**
*
*@paramquery
*@paramentityClass
*@returnT
*/
publicTfindOne(Queryquery,ClassentityClass)
{
ApplicationContextcontext=newClassPathXmlApplicationContext("mongoDB.xml");
MongoTemplatemongoTemplate=(MongoTemplate)context.getBean("mongoTemplate");
//可以直接调用
returnmongoTemplate.findOne(query,entityClass);
}
}

继承类UserAdCountService

/**
*FileName:UserAdCountService.java
*Package:com.lutongnet.ad.service
*Description:TODO
*Author:zhangfj
*Date:2012-11-29
*Version:V1.0
*/
packagecom.lutong.cps.schedule.service.fj;
importorg.springframework.data.mongodb.core.query.Criteria;
importorg.springframework.data.mongodb.core.query.Query;
importorg.springframework.stereotype.Service;

importcom.lutong.cps.schedule.entity.UserAdCount;
/**
*@authorzhangfj
*
*/
@Service("userAdCountService")
publicclassUserAdCountServiceextendsMongoDBService
{
/**
*获取单个广告的观看次数，查询不到则返回0
*
*@paramadCode
*@returnint
*/
publicintgetUserAdCount(UserAdCountadCode)
{
Criteriacriteria=newCriteria();
criteria.andOperator(Criteria.where("userAd").is(adCode.getUserAd()),
Criteria.where("adCode").is(adCode.getAdCode()),
Criteria.where("countDate").is(adCode.getCountDate()));
Queryquery=newQuery(criteria);
UserAdCountresult=findOne(query,UserAdCount.class);
if(null!=result)
{
returnresult.getTimesCount();
}
return0;
}
}

实体类UserAdCount

packagecom.lutong.cps.schedule.entity;
importjava.util.Date;
importorg.springframework.data.annotation.PersistenceConstructor;
importorg.springframework.data.mongodb.core.mapping.Document;
/**
*mongo专用统计单个用户的单个广告观看次数
*@authorcancer
*
*/
@Document(collection="userAdCount")
publicclassUserAdCount
{
privateinttimesCount;

/**
*用户账号
*/
privateStringuserAd;
privateStringadCode;
privateStringcountDate;
privateDateexpireAt;
@PersistenceConstructor
publicUserAdCount(inttimesCount,StringuserAd,StringadCode,StringcountDate,DateexpireAt)
{
this.timesCount=timesCount;
this.userAd=userAd;
this.adCode=adCode;
this.countDate=countDate;
this.expireAt=expireAt;
}

publicUserAdCount(StringuserAd,StringadCode,StringcountDate)
{
this.userAd=userAd;
this.adCode=adCode;
this.countDate=countDate;
}

publicUserAdCount(StringuserAd,StringadCode,StringcountDate,DateexpireAt)
{
this.userAd=userAd;
this.adCode=adCode;
this.countDate=countDate;
this.expireAt=expireAt;
}
publicUserAdCount(StringcountDate)
{
this.countDate=countDate;
}

publicintgetTimesCount()
{
returntimesCount;
}

publicvoidsetTimesCount(inttimesCount)
{
this.timesCount=timesCount;
}

publicStringgetUserAd()
{
returnuserAd;
}

publicvoidsetUserAd(StringuserAd)
{
this.userAd=userAd;
}

publicStringgetAdCode()
{
returnadCode;
}

publicvoidsetAdCode(StringadCode)
{
this.adCode=adCode;
}

publicStringgetCountDate(){
returncountDate;
}

publicvoidsetCountDate(StringcountDate){
this.countDate=countDate;
}

publicDategetExpireAt(){
returnexpireAt;
}

publicvoidsetExpireAt(DateexpireAt){
this.expireAt=expireAt;
}
}

最后写一个测试类来测试下

importjava.util.List;
importjavax.annotation.Resource;
importorg.junit.Test;
importorg.junit.runner.RunWith;
importorg.springframework.test.context.ContextConfiguration;
importorg.springframework.test.context.junit4.SpringJUnit4ClassRunner;
importcom.acts.web.modules.mark.model.Users;
importcom.lutong.cps.schedule.service.fj.UserAdCountService;
@ContextConfiguration({"classpath:spring-context.xml",
"classpath:mongoDB.xml"})
@RunWith(SpringJUnit4ClassRunner.class)
publicclassUserTest{
@Resource(name="userAdCountService")
privateUserAdCountServiceuserAdCountService;
@Test
publicvoidtestDao(){
try{
UserAdCountuserAdCount=newUserAdCount("hehaitao","pos001",
DateTime.now().toString("yyyy-MM-dd"));
intcount=userAdCountService
.getUserAdCount(userAdCount);
System.out.println(count);
}catch(Exceptione){
e.printStackTrace();
}
}
}

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对毛票票的支持。

如何优雅的进行Spring整合MongoDB详解

热门推荐

随机推荐