版本：

spring：4.1.3.RELEASE

mongo-java-driver.version：3.4.1

spring-data-mongodb.version：1.7.0.RELEASE

配置：

1、pom.xml中添加核心依赖（两个）

+++++++++++++++++++++++++++++++++++++++++++++++++++++

                
		
			org.mongodb
			mongo-java-driver
			3.4.1
		
		
		
			org.springframework.data
			spring-data-mongodb
			1.7.0.RELEASE
		

++++++++++++++++++++++++++++++++++++++++++++++++++++++

完整pom.xml文件内容如下：

	4.0.0
	com.fwmagic.mongo
	fwmagic-mongo
	1.0.0-SNAPSHOT

	
		4.12
		4.1.3.RELEASE
		1.2.15
		1.6.4
		2.5
		3.3.2
		1.3.2
		3.4.1
		1.7.0.RELEASE

		dev
		UTF-8
		UTF-8
	

	
		
		
			junit
			junit
			${junit.version}
		

		
		
			com.alibaba
			fastjson
			${fastjson.version}
		

		
		
			org.springframework
			spring-context
			${spring.version}
		
		
			org.springframework
			spring-context-support
			${spring.version}
		
		
			org.springframework
			spring-beans
			${spring.version}
		
		
			org.springframework
			spring-webmvc
			${spring.version}
		
		
			org.springframework
			spring-aspects
			${spring.version}
		
		
			org.springframework
			spring-test
			${spring.version}
		
		
		
			org.slf4j
			slf4j-log4j12
			${slf4j.version}
		
		
		
			org.apache.commons
			commons-lang3
			${commons-lang3.version}
		
		
			org.apache.commons
			commons-io
			${commons-io.version}
		
		
		
			joda-time
			joda-time
			${joda-time.version}
		
		
			org.apache.commons
			commons-pool2
			2.0
		
		
		
			org.mongodb
			mongo-java-driver
			${mongo-java-driver.version}
		
		
		
			org.springframework.data
			spring-data-mongodb
			${spring-data-mongodb.version}
			
				
					slf4j-api
					org.slf4j
				
			
		
	
	
		
			
			
				org.apache.maven.plugins
				maven-compiler-plugin
				3.2
				
					1.7
					1.7
					UTF-8
				
			
			
			
				org.apache.maven.plugins
				maven-war-plugin
				2.6
				
					true
					WEB-INF/classes/**
					
						
							src/main/webapp/WEB-INF
							
								applicationContext.xml
							
							true
							WEB-INF
						
					
				
			
			
				org.apache.maven.plugins
				maven-surefire-plugin
				2.7.1
			
		
	

2、mongo.properties

####################################################
###MongoDB configuration
####################################################
mongo.host=localhost
mongo.port=27017
mongo.dbname=demodb
mongo.username=admin
mongo.password=123456
#一个线程变为可用的最大阻塞数
mongo.connectionsPerHost=8
#线程队列数,它与以上面connectionsPerHost值相乘的结果就是线程队列最大值
mongo.threadsAllowedToBlockForConnectionMultiplier=4
#连接超时时间（毫秒） 
mongo.connectTimeout=1500
#最大等待时间
mongo.maxWaitTime=1500
#自动重连
mongo.autoConnectRetry=true
#scoket保持活动
mongo.socketKeepAlive= true
#scoket超时时间
mongo.socketTimeout=1500
#读写分离
mongo.slaveOk=true

3、applicationContext.xml

        
	
	

	
	
		
		
		
		
		

		
			
				classpath:mongo.properties
				classpath:log4j.properties
			
		
	
	
		
	
		
	

	

	
		
	

单元测试：

package com.fwmagic.dao;

import java.util.Date;
import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.CriteriaDefinition;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4Cla***unner;

import com.fwmagic.pojo.Notice;

@RunWith(SpringJUnit4Cla***unner.class)
@ContextConfiguration("classpath:spring/applicationContext*.xml")
public class NoticeDAOTest {

	@Autowired
	private NoticeDAO dao;
	
	/**
	 * 查询所有文档
	 */
	@Test
	public void testList() {
		Query query = new Query();
		List notice = dao.list(query, Notice.class);
		for (Notice n : notice) {
			System.out.println(n);
		}
	}

	/**
	 * 插入文档
	 */
	@Test
	public void testInsert(){
		Notice notice = new Notice();
		notice.setSiteId(7);
		notice.setCreator("diaochan");
		notice.setTitle("今天星期一");
		notice.setUpdateTime(new Date());
		dao.insert(notice);
	}
	
	/**
	 * 更新文档
	 */
	@Test
	public void testUpdate(){
		Criteria criteria = new Criteria();
		criteria.and("creator").is("zhaojun");
		Query query = new Query(criteria);
		dao.update(query, Update.update("createTime", new Date()), Notice.class);
	}
	
	/**
	 * 删除一行文档
	 */
	@Test
	public void testRemove(){
		Criteria criteria = new Criteria();
		criteria.and("creator").is("zhaojun");
		Query query = new Query(criteria);
		dao.remove(query, Notice.class);
	}
	
	//未完待续……
}

NoticeDAO.java

package com.fwmagic.dao;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.stereotype.Repository;

import com.fwmagic.pojo.Notice;
import com.mongodb.WriteResult;

@Repository
public class NoticeDAO implements BaseDAO{

	@Autowired
	private MongoTemplate mt;
	
	@Override
	public List list(Query query, Class entityClass) {
		return mt.find(query, entityClass);
	}

	@Override
	public Notice findOne(Query query, Class entityClass) {
		return mt.findOne(query, entityClass);
	}
	
	@Override
	public void insert(Notice notice){
		mt.insert(notice);
	}
	
	@Override
	public WriteResult update(Query query, Update update, Class entityClass){
		return mt.updateFirst(query, update, entityClass);
	}
	
	@Override
	public void remove(Query query, Class entityClass){
		mt.remove(query, entityClass);
	}
}

完整demo请移步此处查看.