前言
本文重點是要將mongodb與spring整合到項目中去，在實踐中發現問題，追蹤問題，然后解決問題。下面話不多說了，來一起看看詳細的介紹吧。
一、準備
- Maven、Spring(spring-data-mongodb)
- spring Data for MongoDB是Spring Data的一個子模塊。 目標是為mongodb提供一個相近的一致的基于Spring的編程模型。
- Spring Data for MongoDB核心功能是映射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#等多種語言。
三、依賴包
|
1
2
3
4
5
6
7
8
9
10
|
<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 相關依賴
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
<!-- 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
mongo.hostport=172.16.4.166:27017mongo.dbname=ad_api_countmongo.username=hehaitaomongo.password=hehaitaomongo.connectionsPerHost=8mongo.threadsAllowedToBlockForConnectionMultiplier=4#\u8FDE\u63A5\u8D85\u65F6\u65F6\u95F4mongo.connectTimeout=1000#\u7B49\u5F85\u65F6\u95F4mongo.maxWaitTime=1500mongo.autoConnectRetry=truemongo.socketKeepAlive=true#Socket\u8D85\u65F6\u65F6\u95F4mongo.socketTimeout=1500mongo.slaveOk=true |
mongoDB.xml
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
<?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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
<?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 <a href="http://www.springframework.org/schema/beans/spring-beans-3.1.xsd">http://www.springframework.org/schema/beans/spring-beans-3.1.xsd</a> <a href="http://www.springframework.org/schema/context">http://www.springframework.org/schema/context</a> <a href="http://www.springframework.org/schema/context/spring-context-3.1.xsd">http://www.springframework.org/schema/context/spring-context-3.1.xsd</a> 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
/** * 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
/** * 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
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
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; } } |
最后寫一個測試類來測試下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
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(); } }} |
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對服務器之家的支持。
原文鏈接：http://www.cnblogs.com/zishengY/p/8467176.html
