在构建spring boot应用程序时，我们经常会遇到需要执行耗时操作的api请求，例如大数据处理、复杂计算或与第三方服务的长时间交互。当这些操作以同步方式在api请求线程中执行时，会带来以下问题：
- 资源占用： 请求线程被长时间阻塞，导致线程池耗尽，影响其他请求的处理。
- 用户体验： 客户端需要长时间等待响应，可能导致超时或用户体验不佳。
- 取消难题： 用户可能在操作完成前希望中断或取消请求，但同步执行的API难以提供这种控制能力。
传统的做法是让客户端等待直到操作完成或超时。然而，对于用户希望主动停止某些耗时任务的场景（如取消一个正在进行的报表生成），我们需要一种机制来识别并中断这些任务。直接“杀死”线程是危险且不推荐的做法，因为这可能导致资源泄露或数据不一致。因此，我们需要一种更优雅、协作式的解决方案。
2. 核心策略：异步化与协作式取消解决长时间运行API请求取消问题的核心策略是将其分解为两个主要部分：
- 异步执行任务： 将耗时操作从API请求线程中剥离，在独立的线程或线程池中异步执行。
- 实现协作式取消： 在异步任务内部定期检查取消信号，并响应此信号，主动停止执行。
Spring Boot提供了多种方式来实现任务的异步执行，其中最常用的是使用ExecutorService或Spring的@Async注解。
- 使用ExecutorService： 提供对线程池的精细控制，可以直接提交Callable或Runnable任务，并获得一个Future对象用于跟踪任务状态和结果。
- 使用@Async： Spring Boot提供的一种更简便的异步化方式。通过在方法上添加@Async注解，Spring会自动使用一个线程池来执行该方法。
对于需要跟踪和取消的任务，直接使用ExecutorService提交任务并获取Future对象更为直接和灵活。
2.2 实现协作式取消协作式取消意味着任务本身需要主动配合取消请求。Java中的标准机制是利用线程中断。当一个线程被中断时，它的中断状态会被设置为true，并且如果它正在执行可中断的阻塞操作（如Thread.sleep(), Object.wait(), Future.get()等），会抛出InterruptedException。
在任务逻辑中，我们需要：
- 定期检查中断状态： 在耗时循环或关键操作之间，通过Thread.currentThread().isInterrupted()检查当前线程的中断状态。
- 处理InterruptedException： 如果任务执行了可中断的阻塞操作并捕获到InterruptedException，应立即停止当前任务，并可以选择重新设置中断状态（Thread.currentThread().interrupt()），以便调用栈上层的代码也能感知到中断。
为了能够取消特定的任务，我们需要一个机制来跟踪正在运行的任务。这通常涉及到：
- 生成唯一任务ID： 为每个提交的长时间运行任务生成一个唯一的标识符（例如UUID）。
- 存储任务引用： 使用一个并发安全的数据结构（如ConcurrentHashMap）来存储任务ID与对应的Future对象之间的映射。
当客户端发起一个任务时，API返回这个任务ID。当客户端希望取消任务时，它会带上这个任务ID来请求取消。
Post AI
博客文章AI生成器
50
查看详情
4. 构建取消API端点
我们需要一个专门的API端点来接收取消请求。这个端点会根据客户端提供的任务ID，从任务管理容器中找到对应的Future对象，并尝试取消它。
调用Future.cancel(boolean mayInterruptIfRunning)方法是实现取消的关键。
- mayInterruptIfRunning参数：如果为true，则尝试中断正在运行此任务的线程。如果为false，则只取消尚未开始的任务。对于长时间运行的任务，通常设置为true。
下面通过一个简单的Spring Boot应用示例来演示上述概念。
首先，定义一个服务类来管理和执行异步任务：
import org.springframework.stereotype.Service;
import java.util.Map;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
@Service
public class LongRunningTaskService {
// 使用固定大小的线程池来执行长时间运行的任务
private final ExecutorService executorService = Executors.newFixedThreadPool(5);
// 存储任务ID和对应的Future对象，用于跟踪和取消
private final Map<String, Future<?>> runningTasks = new ConcurrentHashMap<>();
/**
* 提交一个长时间运行的任务
* @param timeToRun 模拟任务运行的秒数
* @return 任务的唯一ID
*/
public String submitTask(int timeToRun) {
String taskId = UUID.randomUUID().toString();
System.out.println("提交任务，ID: " + taskId + ", 预计运行 " + timeToRun + " 秒");
Future<?> future = executorService.submit(() -> {
try {
for (int i = 0; i < timeToRun; i++) {
// 模拟耗时操作
Thread.sleep(1000);
System.out.println("任务 " + taskId + " 正在运行，第 " + (i + 1) + " 秒...");
// 检查线程是否被中断，实现协作式取消
if (Thread.currentThread().isInterrupted()) {
System.out.println("任务 " + taskId + " 收到中断信号，正在退出。");
// 抛出InterruptedException以便外部捕获或中断链上传递
throw new InterruptedException("Task was interrupted by cancellation request.");
}
}
System.out.println("任务 " + taskId + " 已完成。");
} catch (InterruptedException e) {
System.out.println("任务 " + taskId + " 在执行过程中被中断。");
// 捕获InterruptedException后，通常需要重新设置中断状态
// 因为捕获InterruptedException会清除中断标志
Thread.currentThread().interrupt();
} catch (Exception e) {
System.err.println("任务 " + taskId + " 发生异常: " + e.getMessage());
} finally {
// 任务完成或被取消后，从管理列表中移除
runningTasks.remove(taskId);
System.out.println("任务 " + taskId + " 已从管理列表移除。");
}
});
runningTasks.put(taskId, future);
return taskId;
}
/**
* 取消指定ID的任务
* @param taskId 任务ID
* @return 如果任务被成功取消或已完成/不存在，返回true；否则返回false
*/
public boolean cancelTask(String taskId) {
Future<?> future = runningTasks.get(taskId);
if (future != null) {
// 尝试取消任务。true表示如果任务正在运行，则中断其线程
boolean cancelled = future.cancel(true);
if (cancelled) {
System.out.println("已尝试取消任务: " + taskId);
// 立即从管理列表中移除，或者等待finally块自行移除
// runningTasks.remove(taskId);
} else {
System.out.println("任务 " + taskId + " 无法取消 (可能已完成或已取消)。");
}
return cancelled;
}
System.out.println("未找到任务ID: " + taskId);
return false;
}
/**
* 获取任务状态
* @param taskId 任务ID
* @return 任务状态字符串
*/
public String getTaskStatus(String taskId) {
Future<?> future = runningTasks.get(taskId);
if (future == null) {
return "NOT_FOUND";
}
if (future.isDone()) {
return future.isCancelled() ? "CANCELLED" : "COMPLETED";
}
return "RUNNING";
}
} 然后，创建REST控制器来暴露任务提交和取消的API：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("/api/tasks")
public class TaskController {
@Autowired
private LongRunningTaskService taskService;
/**
* 提交一个长时间运行的任务
* POST /api/tasks/run/{timeToRun}
* @param timeToRun 模拟任务运行的秒数
* @return 任务ID
*/
@PostMapping("/run/{timeToRun}")
public ResponseEntity<String> runTask(@PathVariable int timeToRun) {
if (timeToRun <= 0) {
return ResponseEntity.badRequest().body("timeToRun 必须大于0.");
}
String taskId = taskService.submitTask(timeToRun);
return ResponseEntity.ok("任务已提交，ID: " + taskId);
}
/**
* 取消指定ID的任务
* POST /api/tasks/cancel/{taskId}
* @param taskId 要取消的任务ID
* @return 取消结果信息
*/
@PostMapping("/cancel/{taskId}")
public ResponseEntity<String> cancelTask(@PathVariable String taskId) {
if (taskService.cancelTask(taskId)) {
return ResponseEntity.ok("任务 " + taskId + " 的取消请求已发送。");
} else {
return ResponseEntity.badRequest().body("无法取消任务 " + taskId + " (可能不存在或已完成)。");
}
}
/**
* 获取指定ID任务的状态
* GET /api/tasks/status/{taskId}
* @param taskId 任务ID
* @return 任务状态
*/
@GetMapping("/status/{taskId}")
public ResponseEntity<String> getTaskStatus(@PathVariable String taskId) {
String status = taskService.getTaskStatus(taskId);
return ResponseEntity.ok("任务 " + taskId + " 状态: " + status);
}
} 6. 注意事项与最佳实践
- 线程池配置： ExecutorService的配置至关重要。根据应用负载和服务器资源合理设置线程池大小（corePoolSize, maxPoolSize）、队列容量和拒绝策略。不当的配置可能导致资源耗尽或任务积压。
- 资源清理： 确保任务无论完成、异常还是被取消，都能从runningTasks映射中移除，防止内存泄漏。在finally块中进行清理是一个好习惯。
- 错误处理： 异步任务中的异常需要妥善处理。Future.get()方法在任务抛出异常时会重新抛出ExecutionException。在任务内部，应捕获并记录异常，以避免任务静默失败。
-
客户端状态同步： 客户端如何得知任务的最终状态（完成、失败、取消）？
- 轮询： 客户端可以定期调用/api/tasks/status/{taskId}接口查询任务状态。
- WebSocket/SSE： 对于实时性要求高的场景，可以使用WebSocket或Server-Sent Events (SSE) 在任务状态变更时主动推送给客户端。
- 安全性： 确保只有授权用户才能提交或取消任务。在API层添加适当的认证和授权机制（如Spring Security）。
- 幂等性： 考虑多次提交相同取消请求的情况。Future.cancel()本身具有一定的幂等性，多次调用对同一Future不会产生额外副作用。
- 可中断性： 确保所有长时间运行的阻塞操作都是可中断的。如果使用了自定义的耗时计算逻辑，务必在其中定期检查Thread.currentThread().isInterrupted()。
- Spring @Async注解： 如果任务逻辑相对简单，且不需直接获取Future对象进行精细控制，可以使用@Async注解。但如果需要取消，@Async方法通常需要返回Future类型，以便外部调用者获取并调用cancel()。
在Spring Boot中优雅地取消长时间运行的API请求，关键在于将耗时操作异步化，并结合Java的线程中断机制实现协作式取消。通过构建一个任务管理服务来跟踪异步任务，并提供一个取消API端点，我们可以为用户提供更灵活、响应更及时的应用体验。遵循上述最佳实践，可以确保系统在高并发环境下稳定运行，并有效管理各种异步任务。
以上就是Spring Boot中长时间运行API请求的优雅取消与管理的详细内容，更多请关注知识资源分享宝库其它相关文章！
相关标签： java 大数据 app websocket ai spring security red Java spring spring boot Boolean Object 标识符 循环 数据结构 接口 栈 finally 线程 Thread 并发 对象 异步 websocket 大家都在看： Java中访问控制符的本质和作用 Java中final关键字在类和方法中的作用 Java中super关键字的核心作用 Java中如何进行字符串比较和判断 Java中如何开发一个天气查询小工具
发表评论:
◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。