当前位置：首页 > news >正文

Controller返回CompletableFuture到底是怎么样的

news 2025/9/5 0:57:48

以下是关于 CompletableFuture<String> 返回值和前端接收值的详细解析：

1. 后端返回的本质‌

‌返回类型‌：CompletableFuture<String> 是一个 ‌未完成的异步任务容器‌，不是直接返回结果值
‌实际传输‌：Spring 会等待 Future 完成，最终将 ‌String 类型的实际结果‌ 序列化为 JSON/文本响应

‌2. 前端接收的表现‌

场景	前端接收值	说明
‌正常完成‌	`"resultData"` (String)	如 `processRequest()` 返回 `"data123"`
‌异步超时‌	HTTP 504 超时错误	需配置 `spring.mvc.async.request-timeout`
‌执行异常‌	HTTP 500 错误 + 异常信息	可通过 `@ExceptionHandler` 捕获

‌3. 完整交互流程‌

javaCopy Code

// 后端示例 @GetMapping("/data") public CompletableFuture<String> getData(@RequestParam String key) { return CompletableFuture.supplyAsync(() -> { return "Processed: " + key; // 实际业务逻辑 }, asyncExecutor); }

javascriptCopy Code

// 前端调用示例 (使用 Fetch API) fetch('/api/data?key=test123') .then(response => response.text()) // 获取String结果 .then(data => console.log(data)) // 输出: "Processed: test123" .catch(error => console.error(error));

‌4. 关键特性对比‌

特性	`CompletableFuture` 返回值	传统同步返回值
‌HTTP 协议‌	仍然是同步响应	同步响应
‌线程占用‌	立即释放主线程	阻塞至完成
‌前端感知‌	无差异（最终结果相同）	无差异
‌超时控制‌	需额外配置	自动跟随servlet超时

‌5. 进阶用法‌

若需要真正流式响应，应改用 ‌ResponseBodyEmitter‌:

javaCopy Code

@GetMapping("/stream") public ResponseBodyEmitter streamData() { ResponseBodyEmitter emitter = new ResponseBodyEmitter(); CompletableFuture.runAsync(() -> { try { emitter.send("Chunk1"); Thread.sleep(1000); emitter.send("Chunk2"); emitter.complete(); } catch (Exception e) { emitter.completeWithError(e); } }); return emitter; }