大家好,我是培训时长N年半的培训生,菜..菜包。
喜欢 ..xx..xx..xx..篮球。
长时间培训,感觉需要写点东西,欢迎指正、交流。
概述
TCC是一种补偿型的事务,其核心思想是:对于每个操作,都要注册一个与其对应的确认和补偿(撤销)的操作。
TCC是一种应用层的、手动补偿的补偿型事务。
运行过程
- Try 阶段主要是对业务系统做检测和资源预留。
- Confirm 阶段主要是对业务系统做确认提交,Try 阶段执行成功并开始执行 Confirm 阶段时,默认 Confirm 阶段时不会出错的。即:只要 Try 成功,Confirm 一定成功;若Confirm失败,则一直重试直至成功。
- Cancel 阶段主要是在业务执行错误,需要回滚的状态下执行的业务取消,预留资源的释放。
例子
隔壁老王给儿子转账,老王是农行的卡,儿子是工行的卡。
假设老王当前卡里有10000块,想转给儿子3000块,儿子目前卡里有2000块。
TCC理想成功情况下
- 农行检查老王账户状态,再将老王卡里的10000块扣减3000块,剩下7000块,往老王的预转出账户里增加3000块。(Try)
- 工行检查儿子账户状态,再将儿子的预转入账户里增加3000块。(Try)
- 以上步骤全部成功,农行将老王的预转出账户减少3000块,工行将儿子的预转入账户减少3000块,同时儿子的卡里增加3000块。(Confirm)
class Transfer{
String transfer(){
//农行预转出
nonghang.tryReduce(3000);
//工行预转入
gonghang.tryAdd(3000);
//农行确认转出
nonghang.confirmReduce(3000);
//工行确认转入
gonghang.confirmAdd(3000);
return "success";
}
}
复制代码
TCC失败情况 -- Try阶段失败
- 农行检查老王账户状态,再将老王卡里的10000块扣减3000块,剩下7000块,往老王的预转出账户里增加3000块。(Try)
- 工行检查儿子账户状态,发现儿子账户存在问题,转入金额失败。(Try)
- 儿子工行卡Try阶段失败,那么老王农行卡需要减去预扣减账户里的3000块,往卡里增加3000块。(Cancel)
- 若第3步Cancel失败,则需要重试。
class Transfer{
String transfer(){
//农行预转出
boolean nhTrySuccess = nonghang.tryReduce(3000);
if (!nhTrySuccess) {
return "fail";
}
//工行预转入
boolean ghTrySuccess = gonghang.tryAdd(3000);;
if (!ghTrySuccess) {
boolean nhCancelSuccess = false;
while(!nhCancelSuccess){
//农行取消转出
nhCancelSuccess = nonghang.cancelReduce(3000);
}
return "fail";
}
//农行确认转出
nonghang.confirmReduce(3000);
//工行确认转入
gonghang.confirmAdd(3000);
return "success";
}
}
复制代码
TCC失败情况 -- Confirm阶段失败
- 农行检查老王账户状态,再将老王卡里的10000块扣减3000块,剩下7000块,往老王的预转出账户里增加3000块。(Try)
- 工行检查儿子账户状态,再将儿子的预转入账户里增加3000块。(Try)
- 以上步骤全部成功,农行将老王的预转出账户减少3000块,此时工行的服务器挂了,儿子卡里未增加3000块,那么我们认为交易是成功的,只是需要不断重试通知工行将儿子的预转入账户减少3000块并往卡里添加3000块。
class Transfer{
String transfer(){
//农行预转出
boolean nhTrySuccess = nonghang.tryReduce(3000);
if (!nhTrySuccess) {
return "fail";
}
//工行预转入
boolean ghTrySuccess = gonghang.tryAdd(3000);;
if (!ghTrySuccess) {
boolean nhCancelSuccess = false;
while(!nhCancelSuccess){
//农行取消转出
nhCancelSuccess = nonghang.cancelReduce(3000);
}
return "fail";
}
//农行确认转出
boolean nhConfirmSuccess = false;
while(!nhConfirmSuccess){
nhConfirmSuccess = nonghang.confirmReduce(3000);
}
//工行确认转入
boolean ghConfirmSuccess = false;
while(!ghConfirmSuccess){
ghConfirmSuccess = gonghang.confirmAdd(3000);
}
return "success";
}
}
复制代码
总结
TCC事务与2PC事务对比,有什么区别?
从伪代码中我们不难看出,TCC实际上是将事务的提交和回滚方式搬到了应用代码层,将2PC的一个大的分布式事务,拆分成多个本地小事务执行,通过编码的方式来完成整个事务的生命周期。减少了对相关资源的长时间锁定,提高了可用性。
伪代码的TCC的实现方式,有什么缺陷?
- 对真正业务代码入侵大,真正的业务只涉及到4行代码,其他的都是补偿和确认流程的控制。难以更加复杂的场景需要多大的代码量。
- Confirm和Cancel接口方法需要做幂等性校验,保证数据一致性。
需要改进的地方
可将入侵的非业务代码,即补偿方式的核心思想抽象出来,形成类似2PC中协调器的组件,管控整个补偿流程,尽量减少代码的入侵。
TCC核心思想落地的框架
- Hmily(源码简单,容易阅读)