Seata
Seata 是一款开源的分布式事务解决方案,致力于在微服务架构下提供高性能和简单易用的分布式事务服务。
官网地址:https://seata.io/zh-cn/index.html
为什么会产生分布式事务?
示例:用户下单后需要创建订单,同时会员积分对应增加,库存数量相应减少。如果是在一个数据库单个事务中没有问题。一旦涉及分布式环境下,需要保证所有的数据要么全局提交,要么全局回滚。
分布式解决方案需要增加一个事务协调者。
二阶段提交:
第一个阶段如下:
第二个阶段如下:
分布式事务体系三个重要角色
- 事务管理器(TM):决定什么时候全局提交/回滚 (司令官)
- 事务协调者(TC):负责通知命令的中间件Seata-Server(传令官)
- 资源管理器(RM):做具体事儿的工具人(大头兵)
事务边界
操作成功,全局提交;操作出现异常,全局回滚。
Seata AT模式下如何实现数据自动提交、回滚?
通过SQL Parser对SQL语句进行解析实现UNDO_LOG。
Seata如何避免并发场景的脏读与脏写?
利用TC自带的分布式锁
怎么使用Seata框架,来保证事务的隔离性?
因seata一阶段本地事务已提交,为防止其他事务脏读脏写需要加强隔离。
- 脏读 select语句加for update,代理方法增加@GlobalLock+@Transactional或@GlobalTransactional
- 脏写必须使用@GlobalTransactional
注:如果你查询的业务的接口没有@GlobalTransactional 包裹,也就是这个方法上压根没有分布式事务的需求,这时你可以在方法上标注@GlobalLock+@Transactional 注解,并且在查询语句上加 for update。 如果你查询的接口在事务链路上外层有@GlobalTransactional注解,那么你查询的语句只要加for update就行。设计这个注解的原因是在没有这个注解之前,需要查询分布式事务读已提交的数据,但业务本身不需要分布式事务。 若使用@GlobalTransactional注解就会增加一些没用的额外的rpc开销比如begin 返回xid,提交事务等。GlobalLock简化了rpc过程,使其做到更高的性能。