介绍下SpringBoot在分布式架构中，如何实现读写分离

在分布式架构中，Spring Boot 可以通过多种方式实现读写分离，以提升系统性能和扩展性。以下是常见的实现方法：

1. 使用多数据源

通过配置多个数据源，将读操作和写操作分别路由到不同的数据库实例。

实现步骤：

配置多数据源：
在 application.yml 或 application.properties 中配置主从数据源。

spring:datasource:master:url: jdbc:mysql://master-host:3306/dbusername: rootpassword: rootslave:url: jdbc:mysql://slave-host:3306/dbusername: rootpassword: root

创建数据源配置类：
使用 @Configuration 和 @Bean 注解配置主从数据源。

@Configuration
public class DataSourceConfig {@Bean(name = "masterDataSource")@ConfigurationProperties(prefix = "spring.datasource.master")public DataSource masterDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "slaveDataSource")@ConfigurationProperties(prefix = "spring.datasource.slave")public DataSource slaveDataSource() {return DataSourceBuilder.create().build();}@Primary@Bean(name = "routingDataSource")public DataSource routingDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,@Qualifier("slaveDataSource") DataSource slaveDataSource) {Map<Object, Object> targetDataSources = new HashMap<>();targetDataSources.put("master", masterDataSource);targetDataSources.put("slave", slaveDataSource);AbstractRoutingDataSource routingDataSource = new AbstractRoutingDataSource() {@Overrideprotected Object determineCurrentLookupKey() {return DataSourceContextHolder.getDataSourceKey();}};routingDataSource.setDefaultTargetDataSource(masterDataSource);routingDataSource.setTargetDataSources(targetDataSources);return routingDataSource;}
}

数据源上下文管理：
使用 ThreadLocal 管理当前线程的数据源。

public class DataSourceContextHolder {private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();public static void setDataSourceKey(String key) {contextHolder.set(key);}public static String getDataSourceKey() {return contextHolder.get();}public static void clearDataSourceKey() {contextHolder.remove();}
}

AOP 切面实现数据源切换：
通过 AOP 在方法执行前切换数据源。

@Aspect
@Component
public class DataSourceAspect {@Before("@annotation(com.example.annotation.Master)")public void setMasterDataSource() {DataSourceContextHolder.setDataSourceKey("master");}@Before("@annotation(com.example.annotation.Slave)")public void setSlaveDataSource() {DataSourceContextHolder.setDataSourceKey("slave");}@After("@annotation(com.example.annotation.Master) || @annotation(com.example.annotation.Slave)")public void clearDataSource() {DataSourceContextHolder.clearDataSourceKey();}
}

自定义注解：
定义 @Master 和 @Slave 注解，用于标记方法使用主库或从库。

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface Master {
}@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface Slave {
}

在 Service 层使用注解：
在 Service 层方法上使用 @Master 或 @Slave 注解。

@Service
public class UserService {@Autowiredprivate UserMapper userMapper;@Masterpublic void addUser(User user) {userMapper.insert(user);}@Slavepublic User getUserById(Long id) {return userMapper.selectById(id);}
}