From c0f04beab24087071438a4fff38fc0615a0109ed Mon Sep 17 00:00:00 2001 From: huangge1199 Date: Sat, 17 May 2025 14:22:54 +0800 Subject: [PATCH] =?UTF-8?q?ChatClient=E8=BF=94=E5=9B=9E=E5=93=8D=E5=BA=94?= =?UTF-8?q?=EF=BC=9A=E6=B5=81=E5=BC=8F=E5=93=8D=E5=BA=94=EF=BC=9A=E9=80=82?= =?UTF-8?q?=E7=94=A8=E4=BA=8E=E6=89=93=E5=AD=97=E6=9C=BA=E6=95=88=E6=9E=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../aiagent/controller/ResController.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/src/main/java/com/huangge1199/aiagent/controller/ResController.java b/src/main/java/com/huangge1199/aiagent/controller/ResController.java index 379b5ec..0cae6a2 100644 --- a/src/main/java/com/huangge1199/aiagent/controller/ResController.java +++ b/src/main/java/com/huangge1199/aiagent/controller/ResController.java @@ -10,6 +10,7 @@ import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import reactor.core.publisher.Flux; import java.util.List; @@ -63,4 +64,15 @@ public class ResController { }); return R.ok(actorFilms); } + + + @PostMapping("/fluxRes") + @Operation(summary = "流式响应：适用于打字机效果") + public R> fluxRes(@RequestBody String question) { + Flux output = chatClient.prompt() + .user(question) + .stream() + .content(); + return R.ok(output); + } }