我有一个场景,其中我调用了三个@Transactional @Async方法。一切正常,除了所有三种方法都有自己的事务上下文。我想在调用方法的事务上下文中执行它们。

我的呼叫方法如下:

 @Transactional
 public void execute(BillingRequestDto requestDto) {
        try {
            LOGGER.info("Start Processing Request : {}", requestDto.getId());
            List<Future<?>> futures = new ArrayList<>();
            futures.add(inboundProcessingService.execute(requestDto));
            futures.add(orderProcessingService.execute(requestDto));
            futures.add(waybillProcessingService.execute(requestDto));
            futures.stream().parallel().forEach(future -> {
                try {
                    future.get();
                } catch (Exception e) {
                    futures.forEach(future1 -> future1.cancel(true));
                    throw new FBMException(e);
                }
            });
            requestDto.setStatus(RequestStatus.SUCCESS.name());
            requestDto.setCompletedAt(new Date());
            LOGGER.info("Done Processing Request : {}", requestDto.getId());

        } catch (Exception e) {
            requestDto.setStatus(RequestStatus.FAIL.name());
            requestDto.setCompletedAt(new Date());
            throw new FBMException(e);
        }
    }


并且所有调用的方法都用@Async@Transactional注释。

@Transactional
@Async
public Future<Void> execute(BillingRequestDto requestDto) {
    LOGGER.info("Start Waybill Processing {}", requestDto.getId());
    long count = waybillRepository.deleteByClientNameAndMonth(requestDto.getClientName(), requestDto.getMonth());
    LOGGER.info("Deleted  {} Records for Request {} ", count, requestDto.getId());
    try (InputStream inputStream = loadCsvAsInputStream(requestDto)) {
        startBilling(requestDto, inputStream);
    } catch (IOException e) {
        LOGGER.error("Error while processing");
        throw new FBMException(e);
    }
    LOGGER.info("Done Waybill Processing {}", requestDto.getId());
    return null;
}


这三种方法的实现或多或少都是相同的。

现在,如果这些方法中的任何一个失败,则仅回滚该方法的事务。

我的要求是在调用方法事务上下文中运行所有三个方法,因此一个方法中的任何异常都会回滚所有三个方法。

如果禁用@Async,此方案效果很好。有很多方法,所以我希望它们并行运行。

请为此提出任何解决方案。

最佳答案

我猜您应该使用spring TransactionTemplate进行程序控制。
主线程应执行控制,如果任何线程引发异常,则应通知其他线程应回滚。

说,执行后的每个“事务性”线程应为wait(),在没有例外的情况下,只需执行notifyAll(),并在线程中进行事务提交,在例外情况下,应调用Thread.interrupt()并回滚。

关于java - Spring中@Async方法上的@Transactional,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46270739/

10-09 00:32
查看更多