前言
本文重點是要將mongodb與spring整合到項目中去，在實踐中發現問題，追蹤問題，然后解決問題。下面話不多說了，來一起看看詳細的介紹吧。
一、準備
二、特性
三、依賴包
<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-mongodb</artifactId> <version>1.5.0.RELEASE</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.5.10</version> </dependency>
spring 相關依賴
<!-- spring web相關依賴 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>3.1.2.RELEASE</version>
</dependency>
<!-- spring test依賴 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>4.3.1.RELEASE</version>
</dependency>
四、集成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
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mongo="http://www.springframework.org/schema/data/mongo"
xsi:schemaLocation="http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.1.xsd
http://www.springframework.org/schema/data/mongo
http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">
<!-- 加載mongodb的屬性配置文件 -->
<context:property-placeholder location="classpath:mongodb.properties" ignore-unresolvable="true"/>
<!-- 定義mongo對象，對應的是mongodb官方jar包中的Mongo，replica-set設置集群副本的ip地址和端口 -->
<mongo:mongo id="mongo" replica-set="${mongo.hostport}">
<mongo:options
connections-per-host="${mongo.connectionsPerHost}"
threads-allowed-to-block-for-connection-multiplier="${mongo.threadsAllowedToBlockForConnectionMultiplier}"
connect-timeout="${mongo.connectTimeout}"
max-wait-time="${mongo.maxWaitTime}"
auto-connect-retry="${mongo.autoConnectRetry}"
socket-keep-alive="${mongo.socketKeepAlive}"
socket-timeout="${mongo.socketTimeout}"
slave-ok="${mongo.slaveOk}"
write-number="1"
write-timeout="0"
write-fsync="true"/>
</mongo:mongo>
<mongo:db-factory id="mgFactory"
dbname="${mongo.dbname}"
username="${mongo.username}"
password="${mongo.password}"
mongo-ref="mongo" />
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mgFactory"/>
</bean>
</beans>
spring-contex.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:task="http://www.springframework.org/schema/task" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.1.xsd"> <aop:aspectj-autoproxy proxy-target-class="true"/> <!--使用注解管理bean --> <context:annotation-config/> <!-- 掃描com.lutongnet下的所有類 --> <context:component-scan base-package="com.lutong.cps"> <context:exclude-filter type = "annotation" expression = "org.springframework.stereotype.Controller"/> </context:component-scan> <import resource="mongoDB.xml"/> </beans>
五、代碼實現
基礎實現MongoDBService
/**
* File Name : MongoDBService.java
* Package : com.lutongnet.ad.service
* Description : TODO
* Author : zhangfj
* Date : 2012-11-29
* Version : V1.0
*/
package com.lutong.cps.schedule.service.fj;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
/**
* @author zhangfj
*
*/
@Service("mongoDBService")
public class MongoDBService
{
/*@Resource(name = "mongoTemplate")
protected MongoTemplate mongoTemplate;*/
/**
*
* @param query
* @param entityClass
* @return T
*/
public <T> T findOne(Query query, Class<T> entityClass)
{
ApplicationContext context=new ClassPathXmlApplicationContext("mongoDB.xml");
MongoTemplate mongoTemplate= (MongoTemplate) context.getBean("mongoTemplate");
// 可以直接調用
return mongoTemplate.findOne(query, entityClass);
}
}
繼承類UserAdCountService
/**
* File Name : UserAdCountService.java
* Package : com.lutongnet.ad.service
* Description : TODO
* Author : zhangfj
* Date : 2012-11-29
* Version : V1.0
*/
package com.lutong.cps.schedule.service.fj;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;
import com.lutong.cps.schedule.entity.UserAdCount;
/**
* @author zhangfj
*
*/
@Service("userAdCountService")
public class UserAdCountService extends MongoDBService
{
/**
* 獲取單個廣告的觀看次數，查詢不到則返回0
*
* @param adCode
* @return int
*/
public int getUserAdCount(UserAdCount adCode)
{
Criteria criteria = new Criteria();
criteria.andOperator(Criteria.where("userAd").is(adCode.getUserAd()),
Criteria.where("adCode").is(adCode.getAdCode()),
Criteria.where("countDate").is(adCode.getCountDate()));
Query query = new Query(criteria);
UserAdCount result = findOne(query, UserAdCount.class);
if (null != result)
{
return result.getTimesCount();
}
return 0;
}
}
實體類UserAdCount
package com.lutong.cps.schedule.entity;
import java.util.Date;
import org.springframework.data.annotation.PersistenceConstructor;
import org.springframework.data.mongodb.core.mapping.Document;
/**
* mongo專用統計單個用戶的單個廣告觀看次數
* @author cancer
*
*/
@Document(collection="userAdCount")
public class UserAdCount
{
private int timesCount;
/**
* 用戶賬號
*/
private String userAd;
private String adCode;
private String countDate;
private Date expireAt;
@PersistenceConstructor
public UserAdCount(int timesCount, String userAd,String adCode,String countDate,Date expireAt)
{
this.timesCount = timesCount;
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
this.expireAt = expireAt;
}
public UserAdCount(String userAd,String adCode,String countDate)
{
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
}
public UserAdCount(String userAd,String adCode,String countDate,Date expireAt)
{
this.userAd = userAd;
this.adCode = adCode;
this.countDate = countDate;
this.expireAt = expireAt;
}
public UserAdCount(String countDate)
{
this.countDate = countDate;
}
public int getTimesCount()
{
return timesCount;
}
public void setTimesCount(int timesCount)
{
this.timesCount = timesCount;
}
public String getUserAd()
{
return userAd;
}
public void setUserAd(String userAd)
{
this.userAd = userAd;
}
public String getAdCode()
{
return adCode;
}
public void setAdCode(String adCode)
{
this.adCode = adCode;
}
public String getCountDate() {
return countDate;
}
public void setCountDate(String countDate) {
this.countDate = countDate;
}
public Date getExpireAt() {
return expireAt;
}
public void setExpireAt(Date expireAt) {
this.expireAt = expireAt;
}
}
最后寫一個測試類來測試下
import java.util.List;
import javax.annotation.Resource;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.acts.web.modules.mark.model.Users;
import com.lutong.cps.schedule.service.fj.UserAdCountService;
@ContextConfiguration({ "classpath:spring-context.xml",
"classpath:mongoDB.xml"})
@RunWith(SpringJUnit4ClassRunner.class)
public class UserTest {
@Resource(name = "userAdCountService")
private UserAdCountService userAdCountService;
@Test
public void testDao() {
try {
UserAdCount userAdCount = new UserAdCount("hehaitao", "pos001",
DateTime.now().toString("yyyy-MM-dd"));
int count = userAdCountService
.getUserAdCount(userAdCount);
System.out.println(count);
} catch (Exception e) {
e.printStackTrace();
}
}
}
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對億速云的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
