SpringBoot+Mybatis注解方式实现多数据源读写分离教程

"本文将详细介绍如何使用Mybatis注解来实现多数据源的读写分离。在实际项目中，为了提高数据库性能，通常会采用主从数据库的架构，主数据库负责写操作，从数据库负责读操作。我们将通过具体的步骤和示例代码来展示这一过程。" 在Java开发中，Mybatis是一个流行的持久层框架，它允许开发者直接编写SQL语句，提供了灵活的数据访问能力。当面临多数据源的需求时，Mybatis提供了支持，可以通过注解来配置读写分离。 首先，你需要设置两个不同的数据库连接，这里我们用`master_test`作为主数据库，`slave_test`作为从数据库。确保这两个数据库中都有一个相同结构的表`t_user`，包含`id`（主键自增ID）和`name`（名称）两个字段，并在每个数据库中插入不同的数据，比如主库的`name`为`xiaobin`，从库的`name`为`xiaoliu`。 接下来，我们需要在Spring Boot项目中集成Mybatis。在`pom.xml`文件中添加依赖，指定Spring Boot的父版本，以及Mybatis和Lombok的版本。这里使用的是Spring Boot `2.1.4.RELEASE`，Mybatis `1.3.2`和Lombok `1.18.6`。 然后，你需要配置两个数据源。在`application.properties`或`application.yml`中，定义两个数据源的连接信息，例如： ```properties # 主数据库配置 spring.datasource.primary.url=jdbc:mysql://localhost:3306/master_test?useSSL=false spring.datasource.primary.username=root spring.datasource.primary.password=root spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver # 从数据库配置 spring.datasource.secondary.url=jdbc:mysql://localhost:3306/slave_test?useSSL=false spring.datasource.secondary.username=root spring.datasource.secondary.password=root spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver ``` 接下来是关键的Mybatis配置。创建一个配置类，使用`@Configuration`和`@MapperScan`注解来指定Mybatis扫描的Mapper接口路径。同时，使用`@Bean`定义两个数据源并指定数据源类型： ```java @Configuration @MapperScan(basePackages = "com.xiaobin.mysql_master_slave.mapper", annotationClass = DataSource.class) public class DataSourceConfig { @Primary @Bean(name = "primaryDataSource") @ConfigurationProperties(prefix = "spring.datasource.primary") public DataSource primaryDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "secondaryDataSource") @ConfigurationProperties(prefix = "spring.datasource.secondary") public DataSource secondaryDataSource() { return DataSourceBuilder.create().build(); } } ``` 接着，创建一个`@Configuration`类来处理事务管理，配置两个数据源的事务管理器： ```java @Configuration @EnableTransactionManagement public class TransactionConfig { @Primary @Bean(name = "primaryTransactionManager") public PlatformTransactionManager primaryTransactionManager(@Qualifier("primaryDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } @Bean(name = "secondaryTransactionManager") public PlatformTransactionManager secondaryTransactionManager(@Qualifier("secondaryDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } } ``` 现在，我们需要在Mapper接口上使用自定义注解`@DataSource`来指定使用哪个数据源。创建一个自定义注解，例如： ```java @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface DataSource { String value() default ""; } ``` 最后，在Mapper接口中使用这个自定义注解来标记读操作和写操作。例如： ```java @Mapper public interface UserMapper { @Select("SELECT * FROM t_user WHERE id = #{id}") @DataSource("secondary") // 读操作使用从库 User selectUserById(int id); @Insert("INSERT INTO t_user(name) VALUES(#{name})") @DataSource("primary") // 写操作使用主库 int insertUser(User user); } ``` 通过这种方式，你可以灵活地控制读写操作对应的数据源。在执行SQL时，Mybatis会根据注解来选择正确数据源，实现了读写分离。这种方法降低了系统的复杂性，提高了系统的可维护性和性能。记得在实际项目中，根据业务需求调整读写策略，比如在高并发场景下，可能需要更复杂的负载均衡策略。