非Spring管理Runnable中调用仓库delete方法报事务异常求助

错误原因 #

异步执行的MyRunnable.run()方法里，调用deleteAll()时没有活跃的事务上下文。Spring事务默认绑定到当前线程，异步线程不会继承原线程的事务，再加上MyRunnable不是Spring托管Bean，无法自动触发事务代理，导致抛出TransactionRequiredException。

解决方案 #

方案1：用TransactionTemplate手动管理事务 #

通过TransactionTemplate手动在异步线程中开启事务，步骤如下：

1. 修改MyRunnable，添加TransactionTemplate依赖并在run()方法中包裹事务操作：

public class MyRunnable implements Runnable {
    
    private MyDAO myDao;
    private TransactionTemplate transactionTemplate;

    public MyRunnable(MyDAO myDao, TransactionTemplate transactionTemplate) {
        this.myDao = myDao;
        this.transactionTemplate = transactionTemplate;
    }

    @Override
    public void run() {
        transactionTemplate.execute(status -> {
            myDao.deleteAll();
            return null;
        });
    }
}

2. 在MyRunner中注入TransactionTemplate并传入MyRunnable：

@Component
public class MyRunner implements CommandLineRunner {
    
    @Autowired
    private TaskExecutor taskExecutor;

    @Autowired
    private MyDAO myDao;
    
    @Autowired
    private TransactionTemplate transactionTemplate;

    @Override
    public void run(String... args) throws Exception {
        taskExecutor.execute(new MyRunnable(myDao, transactionTemplate));
    }
}

方案2：把MyRunnable转为Spring托管Bean，用@Async+@Transactional #

让Spring接管MyRunnable的生命周期，自动处理异步和事务：

1. 给MyRunnable添加@Component注解，同时在run()方法上标注@Async和@Transactional：

@Component
public class MyRunnable implements Runnable {
    
    @Autowired
    private MyDAO myDao;

    @Override
    @Async
    @Transactional
    public void run() {
        myDao.deleteAll();
    }
}

2. 修改MyRunner，直接注入MyRunnable并调用（@Async会自动交给配置好的TaskExecutor执行）：

@Component
public class MyRunner implements CommandLineRunner {
    
    @Autowired
    private MyRunnable myRunnable;

    @Override
    public void run(String... args) throws Exception {
        myRunnable.run();
    }
}

3. 新增异步配置类开启@Async支持（可以自定义线程池参数）：

@Configuration
@EnableAsync
public class AsyncConfig {
    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(25);
        executor.initialize();
        return executor;
    }
}

方案3：在DAO层显式声明事务 #

如果不想修改MyRunnable，可以在MyDAO的deleteAll()方法上显式添加@Transactional注解，确保方法执行时强制开启事务：

@Repository
public interface MyDAO extends JpaRepository<MyClass, Long> {
    @Override
    @Transactional
    void deleteAll();
}

注意：这个方法最好配合方案1使用，因为异步线程本身没有事务上下文，单独使用可能仍无法生效。

内容的提问来源于stack exchange，提问作者iPhoneJavaDev