mongo-springmvc+spring data mongo配置

2018-05-30

1.导入必要包pom.xml

<dependency>  
    <groupId>org.springframework.data</groupId>  
    <artifactId>spring-data-mongodb</artifactId>  
    <version>1.8.4.RELEASE</version>  
</dependency>

2.applicationContext.xml引入mongo-content.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" 
	xsi:schemaLocation="http://www.springframework.org/schema/beans	http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">	
	
	<import resource="applicationContext-config.xml"/>
	<import resource="applicationContext-dao.xml"/>
	<import resource="applicationContext-service.xml"/>
	
	<!--导入mongodb的配置文件-->  
    <import resource="mongodb-context.xml"/>  
    
    <import resource="redis-context.xml"/>
	
</beans>

3.mongodb-content.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.xsd
       		http://www.springframework.org/schema/beans
       		http://www.springframework.org/schema/beans/spring-beans.xsd
			http://www.springframework.org/schema/data/mongo
          	http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd">
	<context:property-placeholder location="classpath:config.properties"/>
	
	<!-- 只有这个版本spring-mongo-1.0.xsd采用mongo其他版本不支持 mongo:mongo -->
	<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的工厂，通过它来取得mongo实例,dbname为mongodb的数据库名，没有的话会自动创建 -->  
    <mongo:db-factory dbname="${mongo.database}" mongo-ref="mongo"/>  
    
    <!-- 用户名密码验证 -->
    <bean id="userCredentials" class="org.springframework.data.authentication.UserCredentials">  
         <constructor-arg   name="username" value="${mongo.username}" />   
         <constructor-arg   name="password" value="${mongo.password}" />   
      </bean>  
    
    <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">  
        <constructor-arg ref="mongo"/>  
        <constructor-arg name="databaseName" value="${mongo.database}"/>
        <constructor-arg name="userCredentials" ref="userCredentials" />  
    </bean>  
    
    <!-- 映射转换器，扫描back-package目录下的文件，根据注释，把它们作为mongodb的一个collection的映射 -->
    <mongo:mapping-converter base-package="com.hold.third.mongo.model"/>
    <!-- mongodb bean的仓库目录，会自动扫描扩展了MongoRepository接口的接口进行注入 -->
    <mongo:repositories base-package="com.hold.third.mongo.repository"/>
</beans>

4.config.properties

#mongoDB连接配置  
mongo.hostport=${mongo.hostport}
mongo.connectionsPerHost=8
mongo.threadsAllowedToBlockForConnectionMultiplier=4
#连接超时时间 
mongo.connectTimeout=1000
#等待时间  
mongo.maxWaitTime=1500
mongo.autoConnectRetry=true
mongo.socketKeepAlive=true
#Socket超时时间  
mongo.socketTimeout=1500
mongo.slaveOk=true
#数据库名称  
mongo.database=${mongo.database}
mongo.username=${mongo.username}
mongo.password=${mongo.password}

5.mongo类ContentMG.class

package com.hold.third.mongo.model;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;  
  
@Document(collection = "content")  
public class ContentMG {  
	
	@Id
	private String id;
	
	private String content;
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	public String getContent() {
		return content;
	}
	public void setContent(String content) {
		this.content = content;
	}
}

6.使用mongo保存和查询

@Autowired
private MongoTemplate template;
   public Map<String, Object> testMongo(String content) {
    Map<String, Object> dataMap = new HashMap<String, Object>();
	//保存
	ContentMG mg=new ContentMG();
	mg.setId(RandomIdUtil.getRandomCode());
	mg.setContent(content);
	template.save(mg);
	
	//查询
	Query query=new Query();
	Criteria c=new Criteria();
	c.and("content").is("1");
	query.addCriteria(c);
	dataMap.put("list", template.find(query, ContentMG.class));
       return dataMap;
   }