读写分离：分布式架构下的性能优化核心方案

// 1. 定义数据源路由类public class ReadWriteRoutingDataSource extends AbstractRoutingDataSource {    @Override    protected Object determineCurrentLookupKey() {        // 依据ThreadLocal判断当前操作类型        if (DynamicDataSourceContextHolder.isWrite()) {            return "masterDataSource"; // 写操作路由到主库        } else {            // 读操作轮询从库（简化逻辑）            return "slaveDataSource" + (new Random().nextInt(2) + 1);         }    }}// 2. 配置数据源@Configurationpublic class DataSourceConfig {    // 主库数据源配置    @Bean("masterDataSource")    public DataSource masterDataSource() {        HikariConfig config = new HikariConfig();        config.setJdbcUrl("jdbc:mysql://master:3306/test");        // 其他配置（用户名、密码等）        return new HikariDataSource(config);    }    // 从库1数据源配置    @Bean("slaveDataSource1")    public DataSource slaveDataSource1() { /* 类似主库配置，地址为slave1 */ }    // 从库2数据源配置    @Bean("slaveDataSource2")    public DataSource slaveDataSource2() { /* 类似主库配置，地址为slave2 */ }    // 注册路由数据源    @Bean    public DataSource routingDataSource() {        ReadWriteRoutingDataSource routingDataSource = new ReadWriteRoutingDataSource();        Map<Object, Object> dataSources = new HashMap<>();        dataSources.put("masterDataSource", masterDataSource());        dataSources.put("slaveDataSource1", slaveDataSource1());        dataSources.put("slaveDataSource2", slaveDataSource2());        routingDataSource.setTargetDataSources(dataSources);        routingDataSource.setDefaultTargetDataSource(masterDataSource()); // 默认主库        return routingDataSource;    }}// 3. 自定义注解实现读写切换@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public @interface ReadOnly { }// 4. AOP切面控制数据源@Aspect@Componentpublic class ReadWriteAspect {    @Before("@annotation(readOnly)")    public void setReadMode(ReadOnly readOnly) {        DynamicDataSourceContextHolder.setRead(); // 标记为读操作    }    @After("@annotation(readOnly)")    public void clearReadMode() {        DynamicDataSourceContextHolder.clear(); // 清除标记    }}// 5. 业务层使用@Servicepublic class UserService {    // 写操作（默认主库）    public void createUser(User user) { /* 插入主库逻辑 */ }    // 读操作（通过注解路由到从库）    @ReadOnly    public User getUserById(Long id) { /* 从从库查询逻辑 */ }}

spring:  shardingsphere:    datasource:      names: master,slave1,slave2      master: # 主库配置        type: com.zaxxer.hikari.HikariDataSource        driver-class-name: com.mysql.cj.jdbc.Driver        jdbc-url: jdbc:mysql://master:3306/test        username: root        password: 123456      slave1: # 从库1配置（类似主库，地址为slave1）      slave2: # 从库2配置（类似主库，地址为slave2）    rules:      readwrite-splitting:        data-sources:          test-db: # 数据源名称            type: Static # 静态路由（固定主从节点）            props:              write-data-source-name: master # 写数据源              read-data-source-names: slave1,slave2 # 读数据源列表              load-balancer-name: round_robin # 负载均衡策略（轮询）    props:      sql-show: true # 打印SQL路由日志

// 订单详情查询（实时性要求高，强制读主库）public Order getOrderDetail(Long orderId) {    DynamicDataSourceContextHolder.setWrite(); // 标记为写操作，路由到主库    try {        return orderMapper.selectById(orderId);    } finally {        DynamicDataSourceContextHolder.clear();    }}

@Transactionalpublic void updateUserAndQuery(User user) {    // 1. 写操作（主库）    userMapper.updateById(user);    // 2. 事务内读操作，强制走主库    HintManager.getInstance().setWriteRouteOnly();    User updatedUser = userMapper.selectById(user.getId());}

<!-- MyCat配置：仅使用延迟<1秒的从库 --><readHost host="slave1" url="slave1:3306" user="root" password="123456">    <property name="delayThreshold">1000</property> <!-- 延迟阈值（毫秒） --></readHost>

spring:  shardingsphere:    rules:      readwrite-splitting:        data-sources:          test-db:            props:              load-balancer-name: weight_round_robin # 加权轮询策略    load-balancers:      weight_round_robin:        type: WeightRoundRobin        props:          slave1: 3 # 从库1权重3          slave2: 1 # 从库2权重1（性能较差）

// 按用户ID哈希路由到从库private String getSlaveDataSourceByUserId(Long userId) {    int slaveCount = 2; // 从库数量    int index = Math.abs(userId.hashCode()) % slaveCount;    return "slaveDataSource" + (index + 1);}

-- 强制路由到主库（即使是SELECT语句）/* !SHARDINGSPHERE_ROUTE_TO_WRITE_DATASOURCE! */SELECT * FROM user WHERE id = 1 FOR UPDATE;

-- 从库开启只读（超级用户除外，方便主从同步）SET GLOBAL read_only = 1;-- 禁止超级用户写入（可选，更严格）SET GLOBAL super_read_only = 1;