分布式系统常用的三注解：@DS，@DistributeLock，@GlobalTransactional【开发实践】

文章目录

一、多数据源的动态切换：@DS
- 1.1 多数据源的背景
- - 1.1.1 主从复制
  - 1.1.2 读写分离
  - 1.1.3 分库分表
- 1.2 @DS的使用流程
- - 1.2.1 添加依赖
  - 1.2.2 配置数据源
  - 1.2.3 使用 @DS 切换数据源
- 1.3 使用@DS切换数据源失效
- - 1.3.1 情形二：同类中的方法调用@DS方法
  - 1.3.2 情形一：@Transactional方法调用@DS方法
二、分布式锁：@DistributeLock
- 2.1 分布式锁的作用
- 2.2 @DistributeLock的关键参数
三、分布式事务：@GlobalTransactional
- 2.1 分布式事务的作用
- 2.2 @GlobalTransactional的关键参数
- 2.3 @GlobalTransactional与@DistributeLock同时使用
- 2.4 @GlobalTransactional原理
参考链接

一、多数据源的动态切换：@DS

1.1 多数据源的背景

1.1.1 主从复制

主从复制是一种数据库管理技术，通过将主服务器中的数据变更同步到从服务器上，来实现数据冗余和负载均衡。一般采用一主多从的方案，有时候也会采用多主多从的方案。主从复制的数据同步存在一定延迟。

1.1.2 读写分离

读写分离是一种基于主从复制的数据库读写策略，在应用程序层面（如在代码中或使用中间件）区分读写操作，主节点负责所有的写操作（增、删、改）和实时性较高的读操作（查），从节点负责实时性较低的读操作。在读多写少的情境下，读写分离能提升读取性能（读写分离后避免了读写锁的开销）和实现读负载均衡（使用多个从节点负责读取操作）。

1.1.3 分库分表

分库：单个服务器的磁盘存储容量和CPU处理能力是有极限的，随着存储数据量的增大或请求并发数的增多，单个服务器将无法满足需求。此时可以将原本存储在一个数据库中的数据分散到多个数据库实例中，通过分库来分散单个数据库的存储压力和访问请求，提高系统的可用性和并发处理能力。

分表：对于单张表，随着表中总记录行数的增大，底层B+树的层数也会增大，导致平均访问时延增大。此时可以将原本存储在一张表中的记录分散到多张表中，通过分表来减小单张表中的记录行数，提升访问速度。

1.2 @DS的使用流程

1.2.1 添加依赖

	<dependency><groupId>com.baomidou</groupId><artifactId>dynamic-datasource-spring-boot-starter</artifactId><version>${version}</version></dependency>

1.2.2 配置数据源

spring:datasource:dynamic:primary: masterstrict: falsedatasource:master:url: jdbc:mysql://xx.xx.xx.xx:3306/dynamicusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driverslave_1:url: jdbc:mysql://xx.xx.xx.xx:3307/dynamicusername: rootpassword: 123456driver-class-name: com.mysql.jdbc.Driverslave_2:url: ENC(xxxxx)username: ENC(xxxxx)password: ENC(xxxxx)driver-class-name: com.mysql.jdbc.Driver

1.2.3 使用 @DS 切换数据源

没有使用@DS时使用默认数据源（primary指定的数据源）。
@DS可以作用于Service实现类上或类中的方法上，参数值为指定数据源所配置的库名。


@Service
@DS("master")
public class UserServiceImpl implements UserService {@Autowiredprivate JdbcTemplate jdbcTemplate;public List selectAll() {return jdbcTemplate.queryForList("select * from user");}@Override@DS("slave_1")public List selectByCondition() {return jdbcTemplate.queryForList("select * from user where age >10");}
}