Controller返回ResponseEntity后如何异步执行长耗时SQL存储过程？

你之前手动开新线程仍然阻塞的核心原因 #

本质是新启动的线程没有和原请求的上下文彻底隔离：要么是复用了绑定在原请求ThreadLocal上的数据库连接、隐式挂在了原请求的事务上下文下，原请求必须等所有关联连接释放才能完成响应；要么是没给长查询单独配置数据库连接参数，连接池/数据库驱动的默认超时时间远小于1小时，查询中途被掐断还会抛异常。

以下是经过生产验证的可行方案，按落地成本从低到高排序：

别手动new Thread()，用Spring自带的异步能力做线程隔离，步骤很简单：

• 在项目启动类上加@EnableAsync注解开启异步支持
• 自定义专门给长耗时任务用的独立线程池，不要用默认线程池：核心线程数按你允许同时执行的存储过程并发上限设置（比如最多同时跑3个就设3），队列长度设置合理阈值避免任务堆积OOM，线程池要配置拒绝策略（比如超过队列上限直接返回任务繁忙提示）
• 新建独立的长任务Service类，把调用存储过程的逻辑写在这个类的方法上，给方法加@Async("你自定义的长任务线程池名称")注解，这个方法单独声明事务（@Transactional(propagation = Propagation.REQUIRES_NEW)），完全和外层请求的事务隔离开
• Controller层注入这个长任务Service，收到请求后先做参数校验，调用一下异步方法，立刻组装ResponseEntity返回即可，异步逻辑会在独立线程里执行，完全不阻塞请求响应
  注意：异步方法不能写在Controller类内部直接自调用，不然Spring AOP不生效，还是会同步执行。另外要给这个长任务单独配专用数据源，把连接的socketTimeout、连接池的最大持有时间、空闲回收阈值都调到大于1小时，避免跑一半连接被回收。

如果你的数据库支持异步作业能力（MySQL事件、PostgreSQL的pg_background扩展、SQL Server代理作业都支持），完全不用在应用层等查询返回：

• Controller收到请求校验完参数后，只需要执行一条轻量SQL，向数据库提交一个一次性异步作业，作业内容就是调用你要跑的存储过程，设置作业执行完成后自动销毁
• 这条提交作业的SQL几毫秒就能执行完，Controller可以立刻给客户端返回响应，存储过程全程在数据库侧运行，哪怕你的应用重启都不会中断执行
  注意：要建一张任务日志表，存储过程执行成功、失败、进度都写到这张表里，额外提供一个状态查询接口，让客户端可以通过任务ID查询执行结果。

如果后续长耗时任务会持续增多，直接用持久化任务方案：

• Controller收到请求后，把存储过程需要的参数、任务信息落到专门的任务表，初始状态设为「待执行」，直接把生成的任务ID返回给客户端
• 用调度器（Spring Scheduler、嵌入式的任务调度组件都可以）定时轮询任务表里的待执行任务，捞到任务后用独立的工作线程调用存储过程，执行过程中实时更新任务状态、执行结果到任务表
• 客户端拿到任务ID后，可以轮询状态接口获取进度和结果，哪怕执行过程中应用重启，调度器重启后会自动捞取未完成的任务继续执行，不会丢任务。

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