diff --git a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/controller/admin/conversation/ConversationController.java b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/controller/admin/conversation/ConversationController.java index 555951f8b..cb4cd11ec 100644 --- a/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/controller/admin/conversation/ConversationController.java +++ b/yudao-module-llm/yudao-module-llm-biz/src/main/java/cn/iocoder/yudao/module/llm/controller/admin/conversation/ConversationController.java @@ -109,27 +109,8 @@ public class ConversationController { @PostMapping("/stream-chat") public SseEmitter streamChat (@Valid @RequestBody ChatReqVO chatReqVO, HttpServletResponse response) { log.info("收到对话推理请求,请求参数: {}", chatReqVO); - SseEmitter emitter = new SseEmitter(120_000L); - // ExecutorService executor = Executors.newSingleThreadExecutor(); - // try { - // executor.execute(() -> { - // try { - // conversationService.chatStream(chatReqVO, emitter, response); - // } catch (Exception e) { - // emitter.completeWithError(e); - // } finally { - // executor.shutdown(); - // } - // }); - // } catch (Exception e) { - // log.error("处理对话推理请求时发生异常", e); - // try { - // emitter.completeWithError(e); - // } catch (Exception ex) { - // log.error("无法完成 SseEmitter 错误处理", ex); - // } - // } - // log.info("返回 SseEmitter 对象,准备进行流式响应"); + SseEmitter emitter = new SseEmitter(120_0000L); + // 异步处理,避免阻塞主线程 CompletableFuture.runAsync(() -> { try {