SpringBoot配置MongoDB多資料來源的方法步驟
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=localhost basic.spring.data.mongodb.port=27016 basic.spring.data.mongodb.username=auto_compute basic.spring.data.mongodb.password=vqOqSZRs basic.spring.data.mongodb.database=auto_compute #---------------------------------------------- ##end mongodb for spirit ##start mongodb for auth #---------------------------------------------- auth.spring.data.mongodb.host=localhost auth.spring.data.mongodb.port=27016 auth.spring.data.mongodb.username=datacenter auth.spring.data.mongodb.password=Bds6NadsfafGlV auth.spring.data.mongodb.database=datacenter #---------------------------------------------- ##end mongodb for spirit
3、配置相應的資料來源
採用 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
@Setter
public 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;
}
資料來源載入需要繼承 AbstractMongoConfigure 抽象類，有多少個數據源就需要新建多少個數據源載入類
3.1、第一個資料來源
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、第二個資料來源
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、多個數據源中有一個 bean 需要設定為 mongoTemplate ，且必須新增 @Primary 註解，否則 WebMvcConfigurationSupport.class 等會報錯找不到 mongoTemplate
2、Spring Boot 會自動注入 mongoTemplate ，與我們配置的多個數據源有衝突。為了防止預設注入，需要排除自動注入的類。在 Spring Boot 的啟動類 Applocation.java 新增排除類註解
@SpringBootApplication(exclude = {
MongoAutoConfiguration.class,MongoDataAutoConfiguration.class})
5、使用多個數據源
使用時，直接對應注入即可
@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,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 資料來源
解決方式：排除 Spring Boot 自動注入的類，自動重寫的 mongoTemplate 需要且只能設定一個為@Primary
到此這篇關於SpringBoot配置MongoDB多資料來源的方法步驟的文章就介紹到這了,更多相關SpringBoot MongoDB多資料來源內容請搜尋我們以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援我們！