如何在@Async 中捕获事务异常？

Question

使用@Async 编写事务方法时，无法捕获@Transactional 异常。像ObjectOptimisticLockingFailureException，因为它们在事务提交期间被抛出方法本身之外。

例子：

public class UpdateService {
    @Autowired
    private CrudRepository<MyEntity> dao;

    //throws eg ObjectOptimisticLockingFailureException.class, cannot be caught
    @Async
    @Transactional
    public void updateEntity {
        MyEntity entity = dao.findOne(..);
        entity.setField(..);
    }
}

我知道我可以捕获@Async 异常一般如下：

@Component
public class MyHandler extends AsyncConfigurerSupport {
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (ex, method, params) -> {
            //handle
        };
    }
}

但我更愿意以不同的方式处理给定的异常，前提是它发生在 UpdateService 中。

问题：我如何在UpdateService内部捕捉它？

是唯一的机会：创建一个额外的 @Service 包装 UpdateService 并具有 try-catch 块？或者我可以做得更好吗？

Answer 1

你可以试试self-injecting 你的bean，它应该与Spring 4.3 一起工作。虽然自我注入通常不是一个好主意，但这可能是合法的用例之一。

@Autowired
private UpdateService self;

@Transactional
public void updateEntity() {
    MyEntity entity = dao.findOne(..);
    entity.setField(..);
}

@Async
public void updateEntityAsync(){
    try {
       self.updateEntity();
    } catch (Exception e) {
        // handle exception
    }
}