休眠事务提交是否异步更改，独立于程序流？

Question

我有一个测试方法，在部署过程中有时会失败，有时不会。我从未见过它在我的本地失败。你可以在下面看到我的代码。

我有以下从另一个服务异步调用的重试机制：

@Transactional
public boolean retry(NotificationOrder order) {
    notificationService.send(order);
    return true;
}

public void resolveOnFailedAttempt(Long orderId) {  //automatically called if `retry` method fails
    notificationOrderCommonTransactionsService.updateNotificationOrderRetryCount(orderId);
}

通知服务是这样的：

@Service
@RequiredArgsConstructor
public class NotificationServiceImpl implements NotificationService {

    private final NotificationOrderCommonTransactionsService notificationOrderCommonTransactionsService;

    @Override
    @Transactional
    public NotificationResponse send(NotificationOrder order) {
        NotificationRequest request;
        try {
            request = prepareNotificationRequest(order);
        } catch (Exception e) {
            notificationOrderCommonTransactionsService.saveNotificationOrderErrorMessage(order.getId(),
                          e.getMessage());
            throw e;
        }

        ...
 
        return response;
    }

        private void prepareNotificationRequest(NotificationOrder order) {
            ...
            throw new Exception("ERROR");
        }
}

而常见的交易服务是这样的：

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public NotificationOrder saveNotificationOrderErrorMessage(Long orderId, String errorMessage) {
        NotificationOrder order = notificationRepository.findOne(orderId);
        order.setErrorDescription(errorMessage);
        notificationRepository.save(order);
        return order;
    }

    public NotificationOrder updateNotificationOrderRetryCount(Long orderId) {
        NotificationOrder order = notificationRepository.findOne(orderId);
        order.setRetryCount(order.getRetryCount() + 1);
        order.setOrderStatus(NotificationOrderStatus.IN_PROGRESS);
        notificationRepository.save(order);
        return order;
    }

这是我的集成测试：

    @Test
    public void test() {
 
        NotificationOrderRequest invalidRequest = invalidRequest();

        ResponseEntity<NotificationOrderResponse> responseEntity = send(invalidRequest);

        NotificationOrder notificationOrder = notificationOrderRepository.findOne(1);

        softly.assertThat(notificationOrder.getOrderStatus().isEqualTo(NotificationOrderStatus.IN_PROGRESS))
        softly.assertThat(notificationOrder.getErrorDescription())
                 .isEqualTo("ERROR");  //This the line that fails.

        softly.assertThat(responseEntity.getStatusCode()).isEqualTo(HttpStatus.OK);
    }

在测试方法中确认调用updateNotificationOrderRetryCount，订单状态更新为IN_PROGRESS。但是，错误消息为空，我收到以下断言错误：

    -- failure 1 --
    Expecting:
     <null>
    to be equal to:
     <"ERROR">
    but was not.

我希望saveNotificationOrderErrorMessage 事务完成并且在调用updateNotificationOrderRetryCount 方法之前提交更改。但它似乎确实是这样工作的。谁能帮我找出我的代码为什么会这样？

如何在本地重现此错误？我能做些什么来解决它？

谢谢。

Answer 1

尝试启用 SQL 日志记录和参数绑定日志记录并查看语句。我不知道你所有的代码，但也许你在某处将消息设置为空？也可能是，这些动作以某种方式交错，使得updateNotificationOrderRetryCount 在saveNotificationOrderErrorMessage 之前/同时被调用，导致这种情况发生。如果两者都在提交之前运行，但 saveNotificationOrderErrorMessage 在 updateNotificationOrderRetryCount 之前提交，您可能会看到错误消息被 null 覆盖。

Answer 2

如果问题的代码sn-p是准确的，请注意你是在重新抛出prepareNotificationRequest方法中引发的异常，我假设是为了启用重试机制：

NotificationRequest request;
try {
    request = prepareNotificationRequest(order);
} catch (Exception e) {
    notificationOrderCommonTransactionsService.saveNotificationOrderErrorMessage(order.getId(),
                  e.getMessage());
    throw e; // You are rethrowing the exception
}

对于您的评论，抛出的异常扩展RuntimeException。

正如Spring documentation 所示：

在其默认配置中，Spring 框架的事务基础结构代码仅在运行时、未经检查的异常情况下将事务标记为回滚。也就是说，当抛出的异常是 RuntimeException 的实例或子类时。 （默认情况下，错误实例也会导致回滚）。从事务方法抛出的检查异常不会导致默认配置回滚。

可能 Spring 正在执行与 saveNotificationOrderErrorMessage 关联的初始事务的回滚。我意识到这个方法被注释为@Transactional(propagation = Propagation.REQUIRES_NEW) 并且它被注释为is initiating a new transaction，但也许问题可能与它有关。

当重试机制发生时，另一个与updateNotificationOrderRetryCount方法调用相关的事务被执行，并且这个事务被成功提交。这就是正确提交在第二种方法中执行的更改的原因。

问题的解决方案将取决于您的重试机制是如何实现的，但是您可以，例如，引发原始异常，并作为重试机制的第一步，在数据库中跟踪问题，或者引发一个已检查异常 - 默认情况下 Spring 不会对其执行回滚 - 并酌情处理它。

更新

问题的另一个可能原因可能是send 方法中的事务分界。

这个方法被注释为@Transactional。因此，Spring 将为它启动一个新事务。

发生错误，您在数据库中跟踪错误，在新事务中，但请注意初始事务仍然存在。

虽然您的代码中没有描述，但在某种程度上，重试机制发生了，并更新了重试计数。如果此操作在初始事务（或更高级别的事务）中执行，由于事务边界、数据库隔离级别和相关内容，此事务（初始）可能会从事务边界观点，NotificationOrder。而这个信息是最终提交的，覆盖了错误的信息。我希望你能明白。

一个简单的解决方案（可能同时适用于这两种可能性）可能是将错误消息包含在 updateNotificationOrderRetryCount 方法本身中，从而将问题简化为单个事务：

/* If appropriate, mark it as Transactional */
@Transactional
public NotificationOrder updateNotificationOrderRetryCount(Long orderId, String errorMessage) {
  NotificationOrder order = notificationRepository.findOne(orderId);
  order.setRetryCount(order.getRetryCount() + 1);
  order.setOrderStatus(NotificationOrderStatus.IN_PROGRESS);
  order.setErrorDescription(errorMessage);
  // It is unnecessary, all the changes performed in the entity within the transaction will be committed
  // notificationRepository.save(order); 
  return order;
}