MySQL 读写分离

MySQL 读写分离

一、设置主库(Master)

1.修改主库的设置文件

修改主库的 my.cnf 设置文件，生成二进制日志 (binary log) 和服务器唯一ID，这是实现主从复制的须要设置

1. [mysqld]
2. # skip-grant-tables
3. user=root
4. port=3306
5. basedir=/usr/local/mysql
6. datadir=/data/mysql
7. socket=/usr/local/mysql/socket/mysql.sock
8. # Disabling symbolic-links is recommended to prevent assorted security risks
9. # Settings user and group are ignored when systemd is used.
10. # If you need to run mysqld under a different user or group,
11. # customize your systemd unit file for mariadb according to the
12. # instructions in http://fedoraproject.org/wiki/Systemd
13. log-error=/usr/local/mysql/logs/mysqld.log
14. pid_file=/var/run/mysqld/mysqld.pid
15. symbolic-links=0
18. # master 配置
19. server-id=1            # 主库的服务器ID，必须唯一
20. log-bin=mysqls-bin      # 开启二进制日志，文件名可选
21. binlog-format=ROW      # （可选,不指定默认 STATEMENT ）使用行级复制（推荐）
24. # 需要重启mysql服务，master配置才会生效

复制代码

2.创建用于复制的用户

• 登录到Mysql 的主库中，创建一个专门的用户供从库利用，用于复制
  

1. # 创建用户
2. CREATE USER '用户名'@'%' IDENTIFIED BY '用户密码';
3. e.g
4. CREATE USER 'replica_user'@'%' IDENTIFIED BY 'replica123456';
6. # 给用户赋予 '复制' 的权限
7. GRANT REPLICATION SLAVE ON *.* TO '用户名'@'%';
8. e.g
9. GRANT REPLICATION SLAVE ON *.* TO 'replica_user'@'%';
12. # 这里必须要执行,否则在从库执行 SHOW SLAVE STATUS\G; 时会报错 2061
13. alter user '用户名'@'%' identified with mysql_native_password by 'mysql数据库登录密码';
14. e.g
15. alter user 'replica_user'@'%' identified with mysql_native_password by 'replica123456';
17. # 刷新权限
18. FLUSH PRIVILEGES;

复制代码

  Tip
  从库设置启动 复制时报错
  SHOW SLAVE STATUS\G;
  报错：Last_IO_Errno: 2061
Last_IO_Error: error connecting to master ‘replica_user@120.77.27.139:3306’ - rery-time: 60 retries: 1 message: Authentication plugin ‘caching_sha2_password’ reported error: Auhentication requires secure connection.
  3 获取主库的二进制日志位置

• 锁住主库防止数据变化，获取当前的二进制文件名和位置
  

1. # 锁住主库
2. mysql> FLUSH TABLES WITH READ LOCK;
3. Query OK, 0 rows affected (0.01 sec)
5. # 获取当前二进制文件名和位置
6. mysql> SHOW MASTER STATUS;
7. +-------------------+----------+--------------+------------------+-------------------+
8. | File              | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
9. +-------------------+----------+--------------+------------------+-------------------+
10. | mysqls-bin.000001 |      157 |              |                  |                   |
11. +-------------------+----------+--------------+------------------+-------------------+
12. 1 row in set (0.00 sec)
14. # 解锁主库
15. mysql> UNLOCK TABLES;
16. Query OK, 0 rows affected (0.00 sec)

复制代码

二、设置从库(Slave)

1.修改从库的设置文件

• 在从库的MySQL的设置文件 my.cnf 中进行须要的设置，确保其有唯一的服务器ID并启用中继日志
  

1. [mysqld]
2. server-id=2          # 从库的服务器ID，确保唯一
3. relay-log=relay-bin  # 启用中继日志（用于接收主库的二进制日志）
4. replicate-do-db=tbb-iov # 指定从主库中需要复制的数据库
5. read-only=1 # 只读

复制代码

2.毗连到主库并启动复制

• 登录从库，通过以下设置指定主库的信息并启动复制
  

1. CHANGE MASTER TO
2.   MASTER_HOST='主库的IP地址',           # 主库的IP地址
3.   MASTER_PORT=3306,  -- 如果主库使用非默认端口，这里需要指定   
4.   MASTER_USER='replica_user',          # 复制用户
5.   MASTER_PASSWORD='replica_password',  # 复制用户的密码
6.   MASTER_LOG_FILE='mysql-bin.000001',  # 主库的二进制日志文件名
7.   MASTER_LOG_POS=154;                  # 主库的二进制日志位置
9. e.g
10. CHANGE MASTER TO
11.   MASTER_HOST='1x0.xx.xx.13x',
12.   MASTER_PORT=3306,
13.   MASTER_USER='replica_user',
14.   MASTER_PASSWORD='replica123456',
15.   MASTER_LOG_FILE='mysqls-bin.000001',
16.   MASTER_LOG_POS=157;

复制代码

• 启动从库的复制相干命令
  

1. # 启动
2. START SLAVE;
3. # 停止
4. STOP SLAVE;
5. # 查看同步状态
6. SHOW SLAVE STATUS\G;

复制代码

• 主从复制状态参数
  

1.                Slave_IO_State: Waiting for source to send event
2.                   Master_Host: xx.xx.xx.xx
3.                   Master_User: replica_user
4.                   Master_Port: 3306
5.                 Connect_Retry: 60
6.               Master_Log_File: mysqls-bin.000001
7.           Read_Master_Log_Pos: 7657
8.                Relay_Log_File: relay-bin.000006
9.                 Relay_Log_Pos: 2135
10.         Relay_Master_Log_File: mysqls-bin.000001
11.              Slave_IO_Running: Yes
12.             Slave_SQL_Running: Yes
13.               Replicate_Do_DB: tbb-iov,demo

复制代码

Slave_IO_Running 和 Slave_SQL_Running 必须要为 Yes 才表现成功启动主从复制

• 查询同步状态的参数阐明
  

1. 连接和状态信息
2. Slave_IO_State: 当前 IO 线程的状态。例如，Waiting for source to send event 表示从库正在等待主库发送事件。
3. Master_Host: 主库的 IP 地址或主机名。
4. Master_User: 用于复制的用户名。
5. Master_Port: 主库的端口号。
6. Connect_Retry: 从库尝试重新连接到主库的间隔时间（秒）。
7. Master_Log_File: 当前正在读取的主库二进制日志文件。
8. Read_Master_Log_Pos: 当前读取的主库二进制日志的位置。
9. Relay_Log_File: 当前正在使用的中继日志文件。
10. Relay_Log_Pos: 当前中继日志的位置。
11. Relay_Master_Log_File: 当前中继日志对应的主库二进制日志文件。
12. Slave_IO_Running: IO 线程是否正在运行。Yes 表示正在运行，No 表示停止。
13. Slave_SQL_Running: SQL 线程是否正在运行。Yes 表示正在运行，No 表示停止。
14. Slave_SQL_Running_State: SQL 线程的当前状态。例如，Replica has read all relay log; waiting for more updates 表示从库已经读取了所有中继日志，正在等待更多的更新。
16. 复制过滤规则
17. Replicate_Do_DB: 需要复制的数据库列表。
18. Replicate_Ignore_DB: 不需要复制的数据库列表。
19. Replicate_Do_Table: 需要复制的表列表。
20. Replicate_Ignore_Table: 不需要复制的表列表。
21. Replicate_Wild_Do_Table: 需要复制的表的通配符模式。
22. Replicate_Wild_Ignore_Table: 不需要复制的表的通配符模式。
24. 错误信息
25. Last_Errno: 最近一次错误的错误码。
26. Last_Error: 最近一次错误的错误信息。
27. Skip_Counter: 跳过的错误事务计数器。
28. Exec_Master_Log_Pos: 当前已执行的主库二进制日志的位置。
29. Last_IO_Errno: 最近一次 IO 错误的错误码。
30. Last_IO_Error: 最近一次 IO 错误的错误信息。
31. Last_SQL_Errno: 最近一次 SQL 错误的错误码。
32. Last_SQL_Error: 最近一次 SQL 错误的错误信息。
34. 其他信息
35. Relay_Log_Space: 中继日志占用的空间大小（字节）。
36. Until_Condition: 停止复制的条件。
37. Until_Log_File: 停止复制的日志文件。
38. Until_Log_Pos: 停止复制的日志位置。
39. Master_SSL_Allowed: 是否允许 SSL 连接。
40. Master_SSL_CA_File: SSL 证书颁发机构文件路径。
41. Master_SSL_CA_Path: SSL 证书颁发机构路径。
42. Master_SSL_Cert: SSL 证书文件路径。
43. Master_SSL_Cipher: SSL 密码套件。
44. Master_SSL_Key: SSL 私钥文件路径。
45. Seconds_Behind_Master: 从库落后于主库的时间（秒）。
46. Master_SSL_Verify_Server_Cert: 是否验证主库的 SSL 证书。
47. Master_Server_Id: 主库的服务器 ID。
48. Master_UUID: 主库的 UUID。
49. Master_Info_File: 存储主库信息的文件。
50. SQL_Delay: SQL 线程延迟时间（秒）。
51. SQL_Remaining_Delay: 剩余的延迟时间。
52. Replicate_Ignore_Server_Ids: 不需要复制的服务器 ID 列表。
53. Master_Retry_Count: 从库尝试重新连接到主库的最大次数。
54. Master_Bind: 绑定的网络接口。
55. Last_IO_Error_Timestamp: 最近一次 IO 错误的时间戳。
56. Last_SQL_Error_Timestamp: 最近一次 SQL 错误的时间戳。
57. Master_SSL_Crl: SSL 证书吊销列表文件路径。
58. Master_SSL_Crlpath: SSL 证书吊销列表路径。
59. Retrieved_Gtid_Set: 已检索的 GTID 集合。
60. Executed_Gtid_Set: 已执行的 GTID 集合。
61. Auto_Position: 是否启用自动定位（基于 GTID）。
62. Replicate_Rewrite_DB: 数据库重写规则。
63. Channel_Name: 复制通道名称。
64. Master_TLS_Version: 主库支持的 TLS 版本。
65. Master_public_key_path: 主库的公钥文件路径。
66. Get_master_public_key: 是否获取主库的公钥。
67. Network_Namespace: 网络命名空间。

复制代码

  Tip
  数据库开启主从复制之前，主库和从库的数据需要保持一致，
  三、Spring Boot + MySQL+ Mybatis 主从复制，读写分离

1、Maven 依赖引入

主要依赖如下

1. <properties>
2.     <java.version>1.8</java.version>
3.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
4.     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
5.     <spring-boot.version>2.6.13</spring-boot.version>
6.     <mybatis.version>2.2.2</mybatis.version>
7.     <mysql.version>8.0.30</mysql.version>
8.     <alibabadruid.version>1.2.16</alibabadruid.version>
9.     <lombok.version>1.18.26</lombok.version>
11. </properties>
12. <dependencies>
14.     <dependency>
15.         <groupId>org.springframework.boot</groupId>
16.         <artifactId>spring-boot-starter</artifactId>
17.     </dependency>
19.     <dependency>
20.         <groupId>org.springframework.boot</groupId>
21.         <artifactId>spring-boot-starter-test</artifactId>
22.         <scope>test</scope>
23.     </dependency>
26.     <!-- web依赖 -->
27.     <dependency>
28.         <groupId>org.springframework.boot</groupId>
29.         <artifactId>spring-boot-starter-web</artifactId>
30.     </dependency>
32.     <!-- aop -->
33.     <dependency>
34.         <groupId>org.springframework.boot</groupId>
35.         <artifactId>spring-boot-starter-aop</artifactId>
36.     </dependency>
38.     <!-- mybatis -->
39.     <dependency>
40.         <groupId>org.mybatis.spring.boot</groupId>
41.         <artifactId>mybatis-spring-boot-starter</artifactId>
42.         <version>${mybatis.version}</version>
43.     </dependency>
45.     <!-- mysql -->
46.     <dependency>
47.         <groupId>mysql</groupId>
48.         <artifactId>mysql-connector-java</artifactId>
49.         <version>${mysql.version}</version>
50.     </dependency>
52.     <!-- druid mysql数据库连接池-->
53.     <dependency>
54.         <groupId>com.alibaba</groupId>
55.         <artifactId>druid-spring-boot-starter</artifactId>
56.         <version>${alibabadruid.version}</version>
57.     </dependency>
59.     <!-- lombok 工具 -->
60.     <dependency>
61.         <groupId>org.projectlombok</groupId>
62.         <artifactId>lombok</artifactId>
63.         <version>${lombok.version}</version>
64.     </dependency>
66. </dependencies>

复制代码

2、mysql主从设置

自定义mysql的主从数据源的毗连参数，以及mybatis的设置

1. server:
2.   port: 8082
4. # 自定义mysql配置
5. mysql:
6.   datasource:
7.     master:
8.       driver-class-name: com.mysql.cj.jdbc.Driver
9.       url: jdbc:mysql://ip1:port/demo?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
10.       username: xxx
11.       password: xxx
12.       initial-size: 5
13.       max-active: 20
14.       min-idle: 5
15.       max-wait: 60000
16.       time-between-eviction-runs-millis: 60000
17.       min-evictable-idle-time-millis: 300000
18.       max-evictable-idle-time-millis: 900000
19.       validation-query: SELECT 1 FROM DUAL
20.       test-while-idle: true
21.       test-on-borrow: false
22.       test-on-return: false
23.       pool-prepared-statements: true
24.       max-open-prepared-statements: 50
25.       max-pool-prepared-statement-per-connection-size: 20
26.       filters: stat,wall
27.       use-global-data-source-stat: true
28.       connect-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
30.     slave:
31.       driver-class-name: com.mysql.cj.jdbc.Driver
32.       url: jdbc:mysql://ip2:port/demo?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true
33.       username: xxxx # 这里的账号最好是只读权限的mysql用户,从库只负责读,不能写入数据
34.       password: xxxx
35.       initial-size: 5
36.       max-active: 25
37.       min-idle: 5
38.       max-wait: 60000
39.       time-between-eviction-runs-millis: 60000
40.       min-evictable-idle-time-millis: 300000
41.       max-evictable-idle-time-millis: 900000
42.       validation-query: SELECT 1 FROM DUAL
43.       test-while-idle: true
44.       test-on-borrow: false
45.       test-on-return: false
46.       pool-prepared-statements: true
47.       max-open-prepared-statements: 50
48.       max-pool-prepared-statement-per-connection-size: 20
49.       filters: stat,wall
50.       use-global-data-source-stat: true
51.       connect-properties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
53. # 指定mapper*.xml加载位置
54. mybatis:
55.   config-location: classpath:mybatis/mybatis-config.xml
56.   mapper-locations: classpath:mybatis/mapper/*.xml

复制代码

3、数据源设置

1. DataSourceConfig 数据源设置类

1. import com.alibaba.druid.pool.DruidDataSource;
2. import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder;
3. import com.datasource.demo.enums.DataSourceType;
4. import org.springframework.beans.factory.annotation.Qualifier;
5. import org.springframework.boot.context.properties.ConfigurationProperties;
6. import org.springframework.context.annotation.Bean;
7. import org.springframework.context.annotation.Configuration;
8. import org.springframework.context.annotation.Primary;
10. import java.util.HashMap;
11. import java.util.Map;
13. /**
14. * ClassName: DataSourceConfig
15. * Package: com.datasource.demo.config
16. * Description:
17. * 数据源配置
18. *
19. * @Author wfk
20. * @Create 2024/11/12 14:15
21. * @Version 1.0
22. */
23. @Configuration
24. public class DataSourceConfig {
26.     /**
27.      * 主库数据源
28.      *
29.      * @return
30.      */
31.     @Bean("master")
32.     @ConfigurationProperties(prefix = "mysql.datasource.master")
33.     public DruidDataSource dataSource1() {
34.         return DruidDataSourceBuilder.create().build();
35.     }
37.     /**
38.      * 从库数据源
39.      *
40.      * @return
41.      */
42.     @Bean("slave")
43.     @ConfigurationProperties(prefix = "mysql.datasource.slave")
44.     public DruidDataSource dataSource2() {
45.         return DruidDataSourceBuilder.create().build();
46.     }
49.     /**
50.      * 配置默认数据源
51.      *
52.      * @param masterDataSource
53.      * @param slaveDataSource
54.      *
55.      * 必须要加 @Primary 注解,优先下面的配置
56.      * @return
57.      */
58.     @Primary
59.     @Bean("dynamicDataSource")
60.     public DynamicDataSource dataSource(@Qualifier("master") DruidDataSource masterDataSource,
61.                                  @Qualifier("slave") DruidDataSource slaveDataSource) {
62.         Map<Object, Object> targetDataSources = new HashMap<>();
63.         targetDataSources.put(DataSourceType.MASTER.getName(), masterDataSource);
64.         targetDataSources.put(DataSourceType.SLAVE.getName(), slaveDataSource);
65.         DynamicDataSource dynamicDataSource = new DynamicDataSource();
66.         dynamicDataSource.setTargetDataSources(targetDataSources);
67.         dynamicDataSource.setDefaultTargetDataSource(masterDataSource);
68.         return dynamicDataSource;
69.     }
70. }

复制代码

以上源码分析：

• 采用了阿里云的Druid数据库毗连池，以是需要利用 DruidDataSource
  
• @ConfigurationProperties(prefix = “mysql.datasource.slave”) 加载 yml 设置文件的自定义属性，自定义参数名称需要和 druid 的设置的标准名称一样，不然无法主动加载
  
• DynamicDataSource 继承了 抽象类 AbstractRoutingDataSource，是实现动态数据源的核心类，将所有数据源注入到这个类中，通过 DataSourceContextHolder 修改数据源，实现动态切换。
  
• @Primary 注解必须要加上，标志为优先利用的数据源
  

2.DataSourceContextHolder 数据源上下文

1. /**
2. * ClassName: DataSourceContextHolder
3. * Package: com.datasource.demo.config.datasource
4. * Description:
5. * 本地线程，数据源上下文
6. * @Author wfk
7. * @Create 2024/11/12 14:45
8. * @Version 1.0
9. */
10. public class DataSourceContextHolder {
12.     // 定义一个 ThreadLocal 变量，用于保存当前线程的数据源标识
13.     private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();
15.     // 设置当前线程的数据源标识
16.     public static void setDataSource(String dataSource){
17.         contextHolder.set(dataSource);
18.     }
20.     // 获取当前线程的数据源标识
21.     public static String getDataSource(){
22.         return contextHolder.get();
23.     }
25.     // 清除当前线程的数据源标识
26.     public static void clearDataSource(){
27.         contextHolder.remove();
28.     }
29. }

复制代码

以上源码分析：

• ThreadLocal 是一个线程局部变量容器，每个线程都有本身独立的副本。这意味着每个线程都可以独立地设置和获取本身的 ThreadLocal 变量值，而不会影响其他线程。
  
• setDataSource(String dataSource) 方法用于设置当火线程的数据源标识。调用这个方法时，传入的数据源标识会被生存在当火线程的 ThreadLocal 变量中。
  
• getDataSource() 方法用于获取当火线程的数据源标识。这个方法通常在数据源路由逻辑中被调用，根据当火线程的数据源标识选择合适的数据源进行数据库操作。
  
• clearDataSource() 方法用于清除当火线程的数据源标识。这个方法通常在哀求处置处罚完毕后被调用，以开释资源并防止内存泄漏。
  

3.DynamicDataSource 数据源路由

1. import lombok.extern.slf4j.Slf4j;
2. import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
4. /**
5. * ClassName: DynamicDataSource
6. * Package: com.datasource.demo.config.datasource
7. * Description:
8. *
9. * @Author wfk
10. * @Create 2024/11/12 14:42
11. * @Version 1.0
12. */
13. @Slf4j
14. public class DynamicDataSource extends AbstractRoutingDataSource {
15.     @Override
16.     protected Object determineCurrentLookupKey() {
17.         String dataSource = DataSourceContextHolder.getDataSource();
18.         log.info("当前数据源 {}", dataSource);
19.         return dataSource;
20.     }
21. }

复制代码

以上源码分析：

• AbstractRoutingDataSource 是 Spring 框架提供的一个抽象类，用于实现数据源的动态切换。它提供了一个 determineCurrentLookupKey 方法，该方法返回一个键值，用于从设置的数据源映射中查找当前应利用的数据源。
  
• determineCurrentLookupKey 方法用于确定当火线程应该利用哪个数据源，通过调用DataSourceContextHolder.getDataSource() 来获取当火线程的数据源标识
  

4.DataSourceType 自定义数据源类别罗列

1. public enum DataSourceType {
2.     MASTER("master"),
3.     SLAVE("slave");
4.     private String name;
5.     DataSourceType(String name) {
6.         this.name = name;
7.     }
8.     public String getName() {
9.         return name;
10.     }
11. }

复制代码

4、数据源切换

1.自定义注解实现

自定义注解，作用于方法上，通过AOP切面拦截，根据注解的value所对应的数据库源类别，实现数据源切换。

1. @Target(ElementType.METHOD)
2. @Retention(RetentionPolicy.RUNTIME)
3. public @interface DBDataSource {
4.     DataSourceType value() default DataSourceType.MASTER;
5. }

复制代码

2.AOP切面实现

1. import com.datasource.demo.annotions.DBDataSource;
2. import com.datasource.demo.config.datasource.DataSourceContextHolder;
3. import com.datasource.demo.enums.DataSourceType;
4. import lombok.extern.slf4j.Slf4j;
5. import org.aspectj.lang.JoinPoint;
6. import org.aspectj.lang.annotation.Before;
7. import org.aspectj.lang.annotation.Pointcut;
8. import org.aspectj.lang.reflect.MethodSignature;
9. import org.springframework.stereotype.Component;
10. import org.aspectj.lang.annotation.Aspect;
12. import java.lang.reflect.Method;
14. /**
15. * ClassName: DataSourceAspect
16. * Package: com.datasource.demo.aspect
17. * Description:
18. * 数据源AOP切面
19. *
20. * @Author wfk
21. * @Create 2024/11/12 16:05
22. * @Version 1.0
23. */
25. @Slf4j
26. @Aspect
27. @Component
28. public class DataSourceAspect {
30.     @Pointcut("execution(* com.datasource.demo.service..*.*(..))")
31.     public void aspect() {
32.     }
34.     @Before("aspect()")
35.     private void doBefore(JoinPoint joinPoint) {
36.         Object target = joinPoint.getTarget();
37.         Class<?> clazz = target.getClass();
38.         // 获取方法签名
39.         MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
40.         // 获取方法名称
41.         String methodName = methodSignature.getName();
42.         // 获取方法参数列表
43.         Class<?>[] parameterTypes = methodSignature.getMethod().getParameterTypes();
44.         try {
45.             // 通过方法名称和参数列表可以唯一获取方法(可能有重载的同名方法)
46.             Method method = clazz.getMethod(methodName, parameterTypes);
47.             // 判断方法是否存在指定的注解
48.             if (method !=null && method.isAnnotationPresent(DBDataSource.class)){
49.                 DBDataSource annotation = method.getAnnotation(DBDataSource.class);
50.                 // 如果是从库那就切换当前线程的数据源
51.                 if (DataSourceType.SLAVE == annotation.value()) {
52.                     DataSourceContextHolder.setDataSource(DataSourceType.SLAVE.getName());
53.                     return;
54.                 }
55.             }
56.         } catch (NoSuchMethodException e) {
57.             e.printStackTrace();
58.         }
59.         // 默认是使用主库
60.         DataSourceContextHolder.setDataSource(DataSourceType.MASTER.getName());
61.     }
62. }

复制代码

以上源码分析：
1.@Pointcut("execution( com.datasource.demo.service….(…))")*

• execution()：这是定义切入点表达式的关键字，用来匹配Java方法的执行毗连点。
  
• *：第一个星号表现返回值类型，这里的星号意味着匹配任何返回类型的方法。‘com.datasource.demo.service…*.*(…)：这部分是切入点表达式的主体，指定了要匹配的方法的位置和名称。
  
  
  
  • com.datasource.demo.service：这是包名，指明了要匹配的方法地点的包。
    
  • ..：两个点号表现该包下的所有子包。
    
  • *.*：第一个星号代表类名，第二个星号代表方法名，这里利用两个星号表现匹配该包及其子包下所有类的所有方法。
    
  • (..)：括号内的两个点号表现参数列表，这里表现匹配任何参数列表的方法。
    
  
  

2.方法调用和注解查抄

• 获取目标对象和方法签名。
  
• 通过反射获取方法对象，并查抄方法是否标注了 DBDataSource 注解。
  
• 假如方法标注了 DBDataSource 注解且注解值为 DataSourceType.SLAVE，则设置当火线程的数据源为从库。
  
• 否则，默认设置当火线程的数据源为主库。
  

3.最终实现如下

在service层的实现类中，添加注解，查询相干的业务，通过注解指定从库，写入数据默认利用主库，实现读写分离。

1. @DBDataSource(DataSourceType.SLAVE)
2. @Override
3. public List<BookInfoPO> getBookInfoList() {
4.     return bookInfoMapper.getBookInfoListMapper();
5. }

复制代码

总结

关于数据源切换另有很多种方式

• 在mapper层做拦截，对insert、update、delete 和 select 完全分离，可以通过MyCat、shardingsphere 等数据库中间件实现主动分离。
  
• 也可以通过规范方法名前缀，对get、find、query 开头等方法进行拦截，也可以实现读写分离。
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。