1、項目構建

添加 pom 文件

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

2、在 application.properties 中添加配置

##start mongodb for basic#----------------------------------------------basic.spring.data.mongodb.host=localhostbasic.spring.data.mongodb.port=27016basic.spring.data.mongodb.username=auto_computebasic.spring.data.mongodb.password=vqOqSZRsbasic.spring.data.mongodb.database=auto_compute#----------------------------------------------##end mongodb for spirit##start mongodb for auth#----------------------------------------------auth.spring.data.mongodb.host=localhostauth.spring.data.mongodb.port=27016auth.spring.data.mongodb.username=datacenterauth.spring.data.mongodb.password=Bds6NadsfafGlVauth.spring.data.mongodb.database=datacenter#----------------------------------------------##end mongodb for spirit

3、配置相應的數(shù)據(jù)源

采用 mongoTemplate 進行 mongo 的相關操作，寫一個基礎的抽象類

import com.mongodb.MongoClient;import com.mongodb.MongoCredential;import com.mongodb.ServerAddress;import lombok.Getter;import lombok.Setter;import org.springframework.data.mongodb.MongoDbFactory;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.core.SimpleMongoDbFactory;import java.util.ArrayList;import java.util.List;@Getter@Setterpublic abstract class AbstractMongoConfigure { private String host; private int port; private String username; private String password; private String database; public MongoDbFactory mongoDbFactory() throws Exception { /*// 無認證的初始化方法 return new SimpleMongoDbFactory(new MongoClient(host, port), database);*/ //有認證的初始化方法 ServerAddress serverAddress = new ServerAddress(host, port); List<MongoCredential> mongoCredentialList = new ArrayList<>(); MongoCredential mongoCredential = MongoCredential.createCredential(username, database, password.toCharArray()); mongoCredentialList.add(mongoCredential); return new SimpleMongoDbFactory(new MongoClient(serverAddress, mongoCredentialList), database); } abstract public MongoTemplate getMongoTemplate() throws Exception;}

數(shù)據(jù)源加載需要繼承 AbstractMongoConfigure 抽象類，有多少個數(shù)據(jù)源就需要新建多少個數(shù)據(jù)源加載類

3.1、第一個數(shù)據(jù)源

import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.context.annotation.Primary;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;@Configuration@EnableMongoRepositories(basePackages = {'com.tcl.dc.autodata.dao.base'}, mongoTemplateRef = 'mongoTemplate')@ConfigurationProperties(prefix = 'basic.spring.data.mongodb')public class BasicMongoConfig extends AbstractMongoConfigure { @Primary @Bean(name = 'mongoTemplate') @Override public MongoTemplate getMongoTemplate() throws Exception { return new MongoTemplate(mongoDbFactory()); }}

其中 basePackages 的值用于相應的基礎包，prefix 為 application.properties 中的配置值

3.2、第二個數(shù)據(jù)源

import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.mongodb.core.MongoTemplate;import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;@Configuration@EnableMongoRepositories(basePackages = {'com.tcl.dc.autodata.dao.auth'}, mongoTemplateRef = 'authMongoTemplate')@ConfigurationProperties(prefix = 'auth.spring.data.mongodb')public class AuthMongoConfig extends AbstractMongoConfigure { @Bean(name = 'authMongoTemplate') @Override public MongoTemplate getMongoTemplate() throws Exception { return new MongoTemplate(mongoDbFactory()); }}

4、注意

1、多個數(shù)據(jù)源中有一個 bean 需要設置為 mongoTemplate ，且必須添加 @Primary 注解，否則 WebMvcConfigurationSupport.class 等會報錯找不到 mongoTemplate

2、Spring Boot 會自動注入 mongoTemplate ，與我們配置的多個數(shù)據(jù)源有沖突。為了防止默認注入，需要排除自動注入的類。在 Spring Boot 的啟動類 Applocation.java 添加排除類注解

@SpringBootApplication(exclude = { MongoAutoConfiguration.class, MongoDataAutoConfiguration.class})

5、使用多個數(shù)據(jù)源

使用時，直接對應注入即可

@Autowired@Qualifier(value = 'mongoTemplate')MongoTemplate mongoTemplate;@Autowired@Qualifier(value = 'authMongoTemplate')MongoTemplate authMongoTemplate;

6、可能遇到的問題

1、’com.mongodb.MongoClient’ that could not be found

詳細報錯如下:

***************************APPLICATION FAILED TO START***************************

Description:

Parameter 0 of method mongoDbFactory in org.springframework.boot.autoconfigure.data.mongo.MongoDataAutoConfiguration required a bean of type ’com.mongodb.MongoClient’ that could not be found. - Bean method ’mongo’ not loaded because auto-configuration ’MongoAutoConfiguration’ was excluded

Action:

Consider revisiting the conditions above or defining a bean of type ’com.mongodb.MongoClient’ in your configuration.

原因：重寫了 MongoClient 等之后導致原來的自動注入缺少 bean

解決方式：主要是看哪個自動注入的類在引用默認的 MongoClient ，把它排除出去即可，例如:

@SpringBootApplication(exclude = { MongoAutoConfiguration.class, MongoDataAutoConfiguration.class})

2、more than one ‘primary’ bean found among candidates

詳細報錯如下:

org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name ’sampleController’: Unsatisfied dependency expressed through field ’mongoTemplate’; nested exception is org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type ’org.springframework.data.mongodb.core.MongoTemplate’ available: more than one ’primary’ bean found among candidates: [logMongoTemplate, userMongoTemplate, mongoTemplate] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:588) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:88) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessPropertyValues(AutowiredAnnotationBeanPostProcessor.java:366) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1264) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:553) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:483) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:306) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:230) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:302) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:761) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:866) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:542) ~[spring-context-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122) ~[spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:737) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:370) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:314) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:1162) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at org.springframework.boot.SpringApplication.run(SpringApplication.java:1151) [spring-boot-1.5.2.RELEASE.jar:1.5.2.RELEASE] at com.biologic.Applocation.main(Applocation.java:18) [classes/:na]Caused by: org.springframework.beans.factory.NoUniqueBeanDefinitionException: No qualifying bean of type ’org.springframework.data.mongodb.core.MongoTemplate’ available: more than one ’primary’ bean found among candidates: [logMongoTemplate, userMongoTemplate, mongoTemplate] at org.springframework.beans.factory.support.DefaultListableBeanFactory.determinePrimaryCandidate(DefaultListableBeanFactory.java:1365) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.determineAutowireCandidate(DefaultListableBeanFactory.java:1326) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1113) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1066) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE] at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:585) ~[spring-beans-4.3.7.RELEASE.jar:4.3.7.RELEASE]

原因：Spring Boot 會自動注入一個默認的 mongoTemplate 或者設置了多個 @Primary 數(shù)據(jù)源

解決方式：排除 Spring Boot 自動注入的類，自動重寫的 mongoTemplate 需要且只能設置一個為@Primary

到此這篇關于SpringBoot配置MongoDB多數(shù)據(jù)源的方法步驟的文章就介紹到這了,更多相關SpringBoot MongoDB多數(shù)據(jù)源內容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網(wǎng)！