开篇
不知不觉竟然一个月没更新了，人一旦懒下来只会越来越懒。
最近对分布式事务产生了一些兴趣，查阅了一些文章以及论文。这篇文章主要介绍我看的两个项目，不涉及一些理论知识。
- 阿里开源版本的Seata，主要看了Go实现的seata-golang(落后java版)
- 以及前段时间很多公众号都发的dtm。
Seata简介
Seata是由阿里开源的分布式事务服务，目前为用户提供了AT、TCC、SAGA、XA的事务模式，整体采用的是两阶段提交协议。Go版的seata-golang 目前好像只实现了mysql的AT、TCC模式，作者现在不咋更新了。
Seata 有几个核心角色：
- TC(Transaction Coordinator) -事务协调者。(维护全局和分支事务的状态，驱动全局事务提交或回滚)
- TM(Transaction Manager)-事务管理器。(定义全局事务的范围：开始全局事务、提交或回滚全局事务。)
- RM(Resource Manager)-资源管理器。(管理分支事务处理的资源，与TC交谈以注册分支事务和报告分支事务的状态，并驱动分支事务提交或回滚)
当然这样看，可能还不是很理解，我拿一张官网的图加以解释。
从上图中可以看出，这三个角色所负责的工作如下，
TC
- 维护全局和分支事务状态，需要进行存储。
- 当一个分布式事务处理结束，需要通知到每个RM是commit还是rollback。
TM
- 向TC请求开启一个分布式事务，得到一个全局唯一的分布式id。
- 根据每个参与分布式事务的RM一阶段的反馈，决定二阶段向TC请求此次分布式事务是commit还是rollback(绝大部分场景下，一阶段任一RM失败，本次分布式事务失败)
RM
说的白一点就是管理参与分布式事务的各个服务(比如经典下单场景中涉及到的:订单服务、库存服务、营销服务等)
ps:个人感觉，这里的RM有点类似微服务中的中间处理层(专业术语他们管这叫bff->backend for fronted)。
- 一阶段 prepare 行为(主动)：每个RM调用 自定义 的 prepare 逻辑。
- 二阶段 commit 行为(被动触发)：如果本次分布式事务第一阶段全部RM成功，TC处理完自身状态变更后，调用各个RM自定义 的 commit 逻辑。(一阶段RM全部成功)
- 二阶段 rollback 行为(被动触发)：如果本次分布式事务第一阶段任一RM失败，TC处理完自身状态变更后，调用各个RM自定义 的 rollback 逻辑。(一阶段任意RM失败)
好了。下面可以看看seata-golang 实现的一些细节了，seata-golang 底层采用gRPC进行通信。
seata-golang
我们先看RM部分结构。
至于managers，保存支持的各大事务模式实现(TCC、XA等)，每个模式只需要实现此接口即可。
再看TC部分结构(去除部分字段)。
TC对数据的存储目前支持mysql和pgsql，即只要实现SessionManager接口，然后注入到SessionHolder的manager。
介绍完这两个基本结构，还记得我们上面说过他们之间的关系吗?
二阶段TC会根据当前事务状态去通知RM是commit还是rollback。
在初始化ResourceManager 的时候，
我们看到最终会调用TC一个 grpc 接口branchCommunicate。
对应到服务端。
我们知道gRPC有四种基础的通信模式。
- 一元模式(Unary RPC)
- 服务器端流RPC(Server Sreaming RPC)
- 客户端流RPC(Client Streaming RPC)
- 双向流RPC(Bidirectional Streaming RPC)
想要流的形式也很简单，只需要在proto方法定义中将对应的请求|响应 参数前加上stream标记，那么这个接口就是流式传送了。至于是哪种流，取决于你把stream加在哪边，如果请求和响应都加，那么就是双向流了。
客户端和服务端都可以通过stream.Send 发送请求，通过stream.Recv 接收数据。
当RM调用BranchCommunicate时，
最终处理分支事务调用manager.BranchCommit，
相应的，当TC被RM调用BranchCommunicate 后，
上面要发送给RM 通知commit 或者 rollback 数据是咋么来的呢?
当TC要通知RM进行分支commit 的时候，
最后一个就是TM，没啥理解难度。
其实seat-golang还有别的可以提一提的。
比如说，它里面通过go反射实现的动态代理功能(虽然我觉得完全没必要?)，我懒得写了。
这篇文章再写就更长了，不继续写dtm了，感兴趣的留个言，我看看要不要写一篇dtm。
参考
https://seata.io/zh-cn/docs/overview/what-is-seata.html
https://github.com/opentrx/seata-golang
