Seata分布式事务出现ABA问题解决

更新时间：2022年11月09日 16:26:13 作者：梦想实现家_Z

这篇文章主要为大家介绍了Seata分布式事务出现ABA问题解决方法示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪

前言

兄弟们，最近处理了一个seata的issue，关于seata分布式事务长期回滚失败后，突然回滚成功了：

这个问题的出现需要以下两个契机：

在执行分布式事务期间，有本地事务与分布式事务操作同一张表中的数据导致脏写产生；
在回滚时，seata对比afterImage与当前数据不一致，导致回滚失败，此时会一直重试；
当手工校准数据后，某一时刻afterImage与当前数据一致，此时回滚重试成功，ABA问题产生；

从源码中定位原因

为了避免ABA问题的产生，通过与seata社区的大佬讨论，最终决定在回滚时，如果对比afterImage与当前数据不一致的情况下，不再尝试回滚重试。这样的话，即使后续通过人工校准后，也不会回滚了。但是这样有另一个问题，就是人工校准后，这个分布式事务就一直遗留在数据库中无法删除了。针对这个问题，seata应该要提供一个restful api让开发人员在数据校准后能够删除掉对应的分布式事务数据。

在seata源码中，如果校验afterImage与当前数据不一致后，会抛出SQLException，最终会被上层代码捕获包装成BranchTransactionException异常，但是里面的code属性是BranchRollbackFailed_Retriable，这也是导致seata一直重试回滚的根本原因：

Result<Boolean> afterEqualsCurrentResult = DataCompareUtils.isRecordsEquals(afterRecords, currentRecords);
        if (!afterEqualsCurrentResult.getResult()) {
            // 先比较afterImage与当前数据，如果不一致，那么再比较当前数据和beforeImage是否一致
            Result<Boolean> beforeEqualsCurrentResult = DataCompareUtils.isRecordsEquals(beforeRecords, currentRecords);
            // 如果当前数据和beforeImage一致，那么不需要回滚了，因为相当于已经回滚了
            if (beforeEqualsCurrentResult.getResult()) {
                if (LOGGER.isInfoEnabled()) {
                    LOGGER.info("Stop rollback because there is no data change " +
                            "between the before data snapshot and the current data snapshot.");
                }
                // no need continue undo.
                return false;
            } else {
                // 否则，直接抛出SQLException，并告知undo log脏写了
                if (LOGGER.isInfoEnabled()) {
                    if (StringUtils.isNotBlank(afterEqualsCurrentResult.getErrMsg())) {
                        LOGGER.info(afterEqualsCurrentResult.getErrMsg(), afterEqualsCurrentResult.getErrMsgParams());
                    }
                }
                if (LOGGER.isDebugEnabled()) {
                    LOGGER.debug("check dirty data failed, old and new data are not equal, " +
                            "tableName:[" + sqlUndoLog.getTableName() + "]," +
                            "oldRows:[" + JSON.toJSONString(afterRecords.getRows()) + "]," +
                            "newRows:[" + JSON.toJSONString(currentRecords.getRows()) + "].");
                }
                throw new SQLException("Has dirty records when undo.");
            }
        }

在上层调用代码中，我们可以找到这样一段：

catch (Throwable e) {
    if (conn != null) {
        try {
            conn.rollback();
        } catch (SQLException rollbackEx) {
            LOGGER.warn("Failed to close JDBC resource while undo ... ", rollbackEx);
        }
    }
    // 包装异常
    throw new BranchTransactionException(BranchRollbackFailed_Retriable, String
                    .format("Branch session rollback failed and try again later xid = %s branchId = %s %s", xid,
                        branchId, e.getMessage()), e);
}

根据源码分析，我们发现在数据校验后抛出的SQLException会被包装成code属性为BranchRollbackFailed_Retriable的BranchTransactionException异常，这样会导致seata不断重试回滚操作。

如何处理

我们需要将这个SQLException调整为一个更加具体的异常，比如SQLUndoDirtyException这种能够明确地表示undo log被脏写的异常，另外我们在上层代码中同样需要针对SQLUndoDirtyException做特殊处理，比如包装成new BranchTransactionException(BranchRollbackFailed_Unretriable)不可重试的状态。

先创建自定义的异常：SQLUndoDirtyException

import java.io.Serializable;
import java.sql.SQLException;
/**
 * @author zouwei
 */
class SQLUndoDirtyException extends SQLException implements Serializable {
    private static final long serialVersionUID = -5168905669539637570L;
    SQLUndoDirtyException(String reason) {
        super(reason);
    }
}

调整SQLException为SQLUndoDirtyException:

Result<Boolean> afterEqualsCurrentResult = DataCompareUtils.isRecordsEquals(afterRecords, currentRecords);
        if (!afterEqualsCurrentResult.getResult()) {
            // 先比较afterImage与当前数据，如果不一致，那么再比较当前数据和beforeImage是否一致
            Result<Boolean> beforeEqualsCurrentResult = DataCompareUtils.isRecordsEquals(beforeRecords, currentRecords);
            // 如果当前数据和beforeImage一致，那么不需要回滚了，因为相当于已经回滚了
            if (beforeEqualsCurrentResult.getResult()) {
                if (LOGGER.isInfoEnabled()) {
                    LOGGER.info("Stop rollback because there is no data change " +
                            "between the before data snapshot and the current data snapshot.");
                }
                // no need continue undo.
                return false;
            } else {
                // 否则，直接抛出SQLException，并告知undo log脏写了
                if (LOGGER.isInfoEnabled()) {
                    if (StringUtils.isNotBlank(afterEqualsCurrentResult.getErrMsg())) {
                        LOGGER.info(afterEqualsCurrentResult.getErrMsg(), afterEqualsCurrentResult.getErrMsgParams());
                    }
                }
                if (LOGGER.isDebugEnabled()) {
                    LOGGER.debug("check dirty data failed, old and new data are not equal, " +
                            "tableName:[" + sqlUndoLog.getTableName() + "]," +
                            "oldRows:[" + JSON.toJSONString(afterRecords.getRows()) + "]," +
                            "newRows:[" + JSON.toJSONString(currentRecords.getRows()) + "].");
                }
                // 替换为具体的SQLUndoDirtyException异常
                throw new SQLUndoDirtyException("Has dirty records when undo.");
            }
        }

这样的话，我们在上层代码中，就可以针对性地处理了：

catch (Throwable e) {
    if (conn != null) {
        try {
            conn.rollback();
        } catch (SQLException rollbackEx) {
            LOGGER.warn("Failed to close JDBC resource while undo ... ", rollbackEx);
        }
     }
     // 如果捕捉的异常为SQLUndoDirtyException，那么包装为BranchRollbackFailed_Unretriable
     if (e instanceof SQLUndoDirtyException) {
         throw new BranchTransactionException(BranchRollbackFailed_Unretriable, String.format(
                        "Branch session rollback failed because of dirty undo log, please delete the relevant undolog after manually calibrating the data. xid = %s branchId = %s",
                        xid, branchId), e);
      }
      throw new BranchTransactionException(BranchRollbackFailed_Retriable,
                    String.format("Branch session rollback failed and try again later xid = %s branchId = %s %s", xid,
                        branchId, e.getMessage()),
                    e);
}

我们在上层调用代码中捕捉指定的SQLUndoDirtyException，直接包装为BranchRollbackFailed_Unretriable状态的BranchTransactionException，这样我们的分布式事务就不会一直重试回滚操作了。

下一步就需要开发人员人工介入校准数据后删除对应的undo log，在一系列操作处理完毕后，另外还需要seata tc端提供对应的restful api开放对应的手工触发回滚的操作，以便保证校准后的分布式事务正常结束。

小结

我们根据seata使用人员反馈的问题，通过源码分析找到了造成问题的原因：

开发人员在使用seata的时候，对于同一张表的操作没有使用@GlobalTransactional注解覆盖到，导致了undo log被脏写；
当产生回滚时，在进行数据校验时，发现afterImage与当前数据不一致进而无法正常回滚，抛出SQLException，最终包装成BranchRollbackFailed_Retriable异常，导致seata一直重试回滚；
在数据校准后，某一刻的数据与afterImage一致，此时seata就回滚成功，形成ABA问题；

该pr将在1.6版本后解决seata分布式事务一直尝试回滚的问题，可以避免ABA问题的产生，后续还需要提供一些其他功能辅助开发人员回滚数据。

以上就是Seata分布式事务出现ABA问题解决的详细内容，更多关于Seata分布式事务ABA的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

mybatisPlus中apply的使用以进行联表等复杂sql语句详解
在MyBatis-Plus中,`apply()`方法可以用于添加任意的SQL片段,包括联表查询,使用`apply()`方法的好处是可以直接添加原生的SQL片段,而不受MyBatis-Plus提供的常规查询条件构建方法的限制,但是,使用`apply()`方法需要注意安全性和性能问题
2025-03-03
SpringBoot整合Redis的步骤
这篇文章主要介绍了SpringBoot整合Redis的步骤，帮助大家更好的理解和使用springboot框架，感兴趣的朋友可以了解下
2020-11-11
Mybatis映射文件之常用标签及特殊字符的处理方法
这篇文章主要介绍了Mybatis映射文件常用标签及特殊字符的处理,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2023-05-05
Spring中@RequestMapping、@PostMapping、@GetMapping的实现
RequestMapping、@PostMapping和@GetMapping是三个非常常用的注解,本文就来介绍一下这三种注解的具体使用,具有一定的参考价值,感兴趣的可以了解一下
2024-07-07
java8新特性 stream流的方式遍历集合和数组操作
这篇文章主要介绍了java8新特性 stream流的方式遍历集合和数组操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-08-08
SpringBoot使用Log4j的知识点整理
在本篇文章里小编给大家整理的是关于SpringBoot使用Log4j的知识点，需要的朋友们可以参考学习下。
2020-02-02
$MyBatis特殊字符转义拦截器问题针对(_、\、%)$
MyBatis特殊字符转义拦截器问题针对(_、\、%)
这篇文章主要介绍了MyBatis特殊字符转义拦截器问题针对(_、\、%)，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-02-02
从零开始讲解Java微信公众号消息推送实现
微信公众号分为订阅号和服务号,无论有没有认证,订阅号每天都能推送一条消息,也就是每天只能推送一次消息给粉丝,这篇文章主要给大家介绍了关于Java微信公众号消息推送实现的相关资料,需要的朋友可以参考下
2022-09-09
servlet异步请求的实现
本文主要介绍了servlet异步请求的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-07-07
Java利用AlphaComposite类合并图像
这篇文章主要介绍了Java利用AlphaComposite类合并图像，帮助大家更好的利用Java处理图像，感兴趣的朋友可以了解下
2020-10-10

Seata分布式事务出现ABA问题解决

目录

前言

从源码中定位原因

如何处理

小结

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具