# saga-transaction

**Repository Path**: cjbi/saga-transaction

## Basic Information

- **Project Name**: saga-transaction
- **Description**: 通过托管Spring事务管理器实现分布式事务处理，简单而不失优雅，无代码侵入性。
- **Primary Language**: Java
- **License**: Apache-2.0
- **Default Branch**: main
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 1
- **Forks**: 2
- **Created**: 2023-03-01
- **Last Updated**: 2023-09-28

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README


Saga-Transaction | 自己动手实现Saga长事务
---
通过托管Spring事务管理器实现分布式事务处理，简单而不失优雅，无代码侵入性。。。

### 理论基础

1987年普林斯顿大学的Hector Garcia-Molina和Kenneth Salem发表了一篇Paper Sagas，讲述的是如何处理long lived transaction（长活事务）。Saga是一个长活事务可被分解成可以交错运行的子事务集合。其中每个子事务都是一个保持数据库一致性的真实事务。

### 框架主要特点

- 两阶段提交本地事务（事务活动阶段、异步提交阶段），高性能，最终一致性
- 事件驱动架构，参与者可异步执行，高吞吐
- 异常框架自动回滚子事务，无需写Cancel代码
- 隔离级别支持读已提交
- 无代码侵入，集成简单

### 框架原理解析

（缺失的图）

1. 服务A开启事务，生成事务xid，在Consul设置全局锁，此时服务发起方持有全局锁

2. 服务A通过Feign调用服务B，设置header头传递事务xid

3. 服务B开启事务，执行业务

4. 服务B写入子事务的业务执行状态到Consul中

5. 服务B执行完业务后，返回Feign调用结果，不提交事务，异步线程等待全局锁。

6. 服务A调用完毕，释放全局锁，从Consul中获取子事务的业务执行状态，全部成功提交事务，有一个失败则回滚事务

7. 服务B获取到锁，从Consul中获取子事务的业务执行状态，全部成功提交事务，有一个失败则回滚事务


### 支持的数据库种类

因为是托管Spring事务管理器，理论上只要支持事务的受Spring事务管理的数据库都能够支持

### 中间件依赖

Spring、Consul

### 如何使用请看saga-simple这个工程（示例Demo）

- shop 商城系统分布式事务处理（订单保存、库存扣减、支付订单）
- account 模拟转账业务分布式事务处理

### TODO List
- 异常调用cancel方法自动补偿事务（不使用数据库事务场景）
- 超时机制
- 支持消息驱动的微服务架构事务处理（RabbitMQ）
- 事务状态存储支持Redis、Zookeeper（目前只支持Consul）