为了在Spring Boot中整合MySQL主从集群，你需要完成以下步骤：
- 在
application.properties或application.yml配置文件中配置主从集群的数据源信息。 - 使用Spring Data的
AbstractRoutingDataSource来支持数据源的动态路由。 - 配置一个
DataSource的路由逻辑，可以根据特定的规则（例如读写分离）来选择数据源。
以下是一个简化的例子：
application.yml
spring:
datasource:
master:
url: jdbc:mysql://master-host:3306/yourdb
username: your-username
password: your-password
slave:
url: jdbc:mysql://slave-host:3306/yourdb
username: your-username
password: your-passwordDataSourceConfig.java
@Configuration
public class DataSourceConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.master")
public DataSource masterDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.slave")
public DataSource slaveDataSource() {
return DataSourceBuilder.create().build();
}
@Bean
public DataSource routingDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
@Qualifier("slaveDataSource") DataSource slaveDataSource) {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DataSourceType.MASTER, masterDataSource);
targetDataSources.put(DataSourceType.SLAVE, slaveDataSource);
RoutingDataSource routingDataSource = new RoutingDataSource();
routingDataSource.setDefaultTargetDataSource(masterDataSource);
routingDataSource.setTargetDataSources(targetDataSources);
return routingDataSource;
}
public enum DataSourceType {
MASTER, SLAVE
}
public static class RoutingDataSource extends AbstractRoutingDataSource {
@Override
protected Object determineCurrentLookupKey() {
return DataSourceType.MASTER; // 默认使用主数据源
}
}
}在实际应用中，你可能需要根据实际情况来决定何时选择主数据源进行写操作，何时选择从数据源进行读操作。例如，你可以使用AOP来根据方法注解来动态路由到对应的数据源。
以上代码仅为示例，实际应用中需要根据具体业务场景进行调整和完善。