toBeBetterJavaer数据库读写分离：动态数据源

伍盛普Silas

337人浏览 · 2025-11-09 01:02:58

伍盛普Silas · 2025-11-09 01:02:58 发布

toBeBetterJavaer数据库读写分离：动态数据源

【免费下载链接】toBeBetterJavaer JavaBooks：这是一个由多位资深Java开发者共同维护的Java学习资源库，内含大量高质量的Java教程、视频、博客等资料，可以帮助Java学习者快速提升技术水平。项目地址: https://gitcode.com/GitHub_Trending/to/toBeBetterJavaer

在高并发的Java应用中，数据库读写分离是提升系统性能的关键手段之一。通过将读操作和写操作分流到不同的数据库节点，可以有效减轻主库压力，提高查询响应速度。动态数据源技术则是实现这一架构的核心，它能根据业务场景自动切换数据源，确保数据一致性和系统稳定性。

读写分离的必要性

传统单一数据库架构在面对大量并发请求时，往往会出现性能瓶颈。特别是当读操作远多于写操作时，所有请求都集中在主库，会导致：

主库CPU、IO资源紧张
查询响应延迟增加
写操作阻塞读操作，反之亦然

通过读写分离架构，可以将读请求分发到从库，写请求集中在主库，实现负载均衡。根据统计，多数业务场景下读写比例约为8:2，这种架构能显著提升系统吞吐量。

动态数据源实现原理

动态数据源的核心思想是通过AOP（面向切面编程）技术，在方法执行前根据业务规则自动切换数据源。常见实现方式包括：

1. 数据源路由

通过自定义DataSource实现类，管理多个数据源实例，并根据路由规则动态选择目标数据源。关键代码结构如下：

public class DynamicDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return DynamicDataSourceContextHolder.getDataSourceKey();
    }
}

2. 注解式切换

使用自定义注解标记方法的数据源类型（如@ReadDataSource、@WriteDataSource），通过AOP切面解析注解并切换数据源上下文。

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface ReadDataSource {
}

项目中的动态数据源实现

在toBeBetterJavaer项目中，提供了完整的动态数据源解决方案，主要涉及以下模块：

配置文件

数据源配置文件位于docs/springboot/mysql-druid.md，包含主从库连接信息：

spring:
  datasource:
    master:
      url: jdbc:mysql://localhost:3306/master_db
      username: root
      password: 123456
    slave:
      url: jdbc:mysql://localhost:3307/slave_db
      username: root
      password: 123456

核心实现类

动态数据源路由实现位于docs/springboot/transaction.md，主要包含：

DynamicDataSource：数据源路由核心类
DynamicDataSourceContextHolder：线程本地上下文管理
DataSourceAspect：AOP切面实现注解解析

事务一致性保障

为确保读写分离场景下的数据一致性，项目提供了分布式事务解决方案，详情可参考docs/mysql/lijie-shiwu.md。主要采用最终一致性方案：

写操作优先执行并锁定资源
读操作通过延迟读取保证数据可见性
定期数据校验与补偿机制

实际应用场景

1. 普通查询场景

使用@ReadDataSource注解标记查询方法，自动路由到从库：

@Service
public class UserServiceImpl implements UserService {
    
    @Autowired
    private UserMapper userMapper;
    
    @ReadDataSource
    @Override
    public User getUserById(Long id) {
        return userMapper.selectById(id);
    }
    
    @Override
    public int saveUser(User user) {
        return userMapper.insert(user);
    }
}

2. 读写混合场景

在复杂业务逻辑中，可能需要先读后写，此时需注意数据源切换顺序：

@Transactional
public void updateUserInfo(User user) {
    // 先读主库获取最新数据
    DynamicDataSourceContextHolder.setDataSourceKey("master");
    User existingUser = userMapper.selectById(user.getId());
    
    // 业务逻辑处理
    existingUser.setUsername(user.getUsername());
    
    // 写操作自动使用主库
    userMapper.updateById(existingUser);
}