Spring Boot中如何在@Transactional与@Async方法中强制立即保存实体

我来帮你拆解下你遇到的问题，其实这是Spring代理机制和事务、异步注解组合使用时的常见坑。你加了@Transactional(propagation = Propagation.REQUIRES_NEW)却没生效，核心原因是同一个类内部调用@Async方法时，Spring的动态代理不会拦截这个调用，导致异步和新事务的切面逻辑都没触发，自然save不会立即提交。

下面给你几个可行的解决办法，按推荐优先级排序：

一、把异步事务方法抽离到单独的Service类（最推荐） #

Spring的AOP代理只对跨Bean的调用生效，所以把需要异步+独立事务的方法放到另一个Spring管理的Bean里，调用时通过注入的方式触发代理，就能让注解正常工作。

示例代码： #

1. 新建一个专门处理异步保存的Service：

@Service
public class AsyncCustomerHandler {
    @Autowired
    private CustomerRepository customerRepository;

    // 异步执行 + 开启新事务，确保save立即提交
    @Async
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveCustomerRightNow(Customer customer) {
        customerRepository.save(customer);
        // 这里的save操作会在独立事务中立即提交，不会等待原方法的事务结束
    }
}

2. 修改原来的CustomerServiceImpl，注入新Service并调用：

@Service
@Transactional
public class CustomerServiceImpl implements CustomerService {
    @Autowired
    private AsyncCustomerHandler asyncCustomerHandler;

    @Override
    public void sendAllWithQueryParam(Customer customer) {
        // some code
        // 调用跨Bean的异步方法，触发代理逻辑
        asyncCustomerHandler.saveCustomerRightNow(customer);
        // extra code
    }
}

二、通过AopContext获取代理对象调用内部方法（不推荐，代码耦合度高） #

如果实在不想抽离类，可以开启代理暴露，通过AopContext拿到当前类的代理对象，再调用方法，这样就能触发切面逻辑。

步骤： #

1. 在Spring Boot启动类上添加注解，允许暴露代理对象：

@SpringBootApplication
@EnableAspectJAutoProxy(exposeProxy = true) // 开启代理暴露
@EnableAsync // 确保异步功能开启
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}

2. 修改原来的Service方法：

@Service
@Transactional
public class CustomerServiceImpl implements CustomerService {
    @Autowired
    private CustomerRepository customerRepository;

    @Override
    public void sendAllWithQueryParam(Customer customer) {
        // some code
        // 通过代理对象调用内部方法，触发@Async和新事务
        ((CustomerServiceImpl) AopContext.currentProxy()).saveCustomerAsync(customer);
        // extra code
    }

    @Async
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void saveCustomerAsync(Customer customer) {
        customerRepository.save(customer);
    }
}

⚠️ 注意：这种方式代码可读性差，耦合度高，后续维护起来麻烦，非必要不建议用。

三、使用TransactionTemplate手动执行事务（特殊场景用） #

如果不想依赖声明式事务，可以用TransactionTemplate手动管理事务，强制立即提交save操作。

示例代码： #

@Service
@Transactional
public class CustomerServiceImpl implements CustomerService {
    @Autowired
    private CustomerRepository customerRepository;
    @Autowired
    private TransactionTemplate transactionTemplate;

    @Override
    @Async
    public void sendAllWithQueryParam(Customer customer) {
        // some code
        // 手动执行独立事务，立即提交save
        transactionTemplate.execute(status -> {
            customerRepository.save(customer);
            return null;
        });
        // extra code
    }
}

⚠️ 备注：这种方式跳过了Spring声明式事务的优雅封装，需要自己处理事务异常等情况，仅适合特殊场景下使用。

总结一下，最稳妥、最符合Spring设计理念的还是第一种方法——抽离异步事务方法到单独Bean，既能保证代码清晰，又能让注解正常生效，解决你需要立即保存实体的需求。

备注：内容来源于stack exchange，提问作者Ibrahim Ali Mohamed