平時我們用spring data mongodb都是采用xml配置的方式來鏈接數(shù)據(jù)庫

但是往往有的時候需要用代碼的方式來實現(xiàn).

比如說我們有可能要同時操作多個db的數(shù)據(jù),總不能一個db配置一個DbFactory吧.

這個時候就需要代碼來動態(tài)創(chuàng)建和獲取了.

下面貼上實現(xiàn)的代碼,里面的參數(shù)都寫死了,大家在做封裝的時候可以作為參數(shù)傳進去獲取配置文件也行.

@Configuration

public class AppConfig {

public @Bean MongoDbFactory mongoDbFactory() throws Exception {

//mongodb地址,集群環(huán)境填多個

List<ServerAddress> seeds = Arrays.asList(new ServerAddress("localhost", 27017));

//用戶認證信息,參數(shù)為用戶,數(shù)據(jù)庫,密碼

//MongoCredential com.mongodb.MongoCredential.createCredential(String userName, String database, char[] password)

MongoCredential mongoCredential = MongoCredential.createCredential("cxytiandi", "cxytiandi", "cxytiandi".toCharArray());

List<MongoCredential> credentialsList = Arrays.asList(mongoCredential);

//連接池參數(shù)配置

MongoClientOptions.Builder builder = new MongoClientOptions.Builder();

// 每個主機的連接數(shù)

int connPerHost = 20;

builder.connectionsPerHost(connPerHost);

// 線程隊列數(shù)

int threadCount = 20;

builder.threadsAllowedToBlockForConnectionMultiplier(threadCount);

// 最大等待連接的線程阻塞時間(單位：毫秒)

int maxWaitTime = 1000;

builder.maxWaitTime(maxWaitTime);

// 連接超時的時間.0是默認和無限(單位：毫秒)

int timeOut = 1000;

builder.connectTimeout(timeOut);

MongoClientOptions options = builder.build();

MongoClient mongoClient = new MongoClient(seeds, credentialsList, options);

//這里第二個參數(shù)也就是cxytiandi是用戶認證的庫名,在哪個庫認證就表示登陸哪個庫

return new SimpleMongoDbFactory(mongoClient, "cxytiandi");

}

public @Bean MongoTemplate mongoTemplate() throws Exception {

return new MongoTemplate(mongoDbFactory());

}

public static void main(String[] args) throws UnknownHostException, Exception {

AppConfig appConfig = new AppConfig();

MongoTemplate mongoTemplate = appConfig.mongoTemplate();

mongoTemplate.getCollectionNames().forEach(System.out::println);

}

}