1.spring-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:mongo="http://www.springframework.org/schema/data/mongo"
xsi:schemaLocation=
"http://www.springframework.org/schema/data/mongo
http://www.springframework.org/schema/data/mongo/spring-mongo.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
<mongo:mongo-client host="Ip" port="27018" id="mongo"
credentials="user:password@admin">
<mongo:client-options connections-per-host="8"
threads-allowed-to-block-for-connection-multiplier="5"
connect-timeout="1000"
max-wait-time="1500"
socket-keep-alive="true"
socket-timeout="1500"/>
</mongo:mongo-client>
<!-- Connection to MongoDB server -->
<mongo:db-factory dbname="默认dbname" mongo-ref="mongo"/>
<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
<constructor-arg name="mongoDbFactory" ref="mongoDbFactory"/>
</bean>
<mongo:mapping-converter id="converter" db-factory-ref="mongoDbFactory"/>
<!-- MongoDB GridFS Template -->
<bean id="gridTemplate" class="org.springframework.data.mongodb.gridfs.GridFsTemplate">
<constructor-arg ref="mongoDbFactory"/>
<constructor-arg ref="converter"/>
</bean>
</beans>
2.MongoConfiguration.class去初始化template
package com.yxtech.commom.mongo;
import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.yxtech.api.exam.vo.ExportVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.data.authentication.UserCredentials;
import org.springframework.data.mongodb.core.MongoTemplate;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.Map;
/**
* User: Chenxh
* Date: 2016/2/3
* Time: 9:18
*/
public class MongoConfiguration {
public static Map<String, MongoTemplate> mongoRes = new HashMap<>();
private static Logger logger = LoggerFactory.getLogger(MongoConfiguration.class);
public static MongoTemplate createMongoTemplate(String database) {
//ConfigurableApplicationContext context = new ClassPathXmlApplicationContext("classpath:config/mongodb/spring-mongodb.xml");
MongoTemplate mongoTemplate0 = mongoRes.get(database);
if (null == mongoTemplate0) {
Mongo mongo ;
try {
Mongo _s_mongo=SpringContextHolder.getBean("mongo", Mongo.class);
MongoClient _mongo_client=SpringContextHolder.getBean("mongo", MongoClient.class);
MongoCredential credential = _mongo_client.getCredentialsList().get(0);
mongo = new Mongo(_s_mongo.getAddress().getHost(), _s_mongo.getAddress().getPort());
DB db = mongo.getDB(database);
boolean flag = db.authenticate(credential.getUserName(), credential.getPassword());
if(flag == false){
DB admin = mongo.getDB("admin");
boolean auth = admin.authenticate(credential.getUserName(), credential.getPassword());
if(auth){
admin = mongo.getDB(database);
mongo = admin.getMongo();
mongoTemplate0 = new MongoTemplate(mongo, database);
logger.info("mongoTemplate0 create,database:"+database);
mongoRes.put(database, mongoTemplate0);
return mongoTemplate0;
}
}
UserCredentials uc = new UserCredentials(credential.getUserName(),
new String(credential.getPassword()));
mongoTemplate0 = new MongoTemplate(mongo, database,uc);
logger.info("mongoTemplate0 create,database:"+database);
mongoRes.put(database, mongoTemplate0);
} catch (UnknownHostException e) {
e.printStackTrace();
throw new RuntimeException("数据库连接错误");
}
}
return mongoTemplate0;
}
public static void main(String[] args) throws Exception {
MongoTemplate mongoTemplate = new MongoConfiguration().createMongoTemplate("database");
ExportVo vo = new ExportVo();
vo.setTitle("999999");
mongoTemplate.insert(vo,"abc");
MongoTemplate mongoTemplate2 = new MongoConfiguration().createMongoTemplate("56c197119b05706d2d6365f5");
ExportVo vo2 = new ExportVo();
vo2.setTitle("88888");
mongoTemplate2.insert(vo2,"abc2");
}