springmvc项目中mongoDB一个账号连接多数据库

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");

}