spring OpneAi流式响应

### 实现Spring Boot集成OpenAI API的流式响应 为了实现在Spring Boot应用程序中与OpenAI API进行流式响应交互，可以采用基于`WebClient`组件的方式发送HTTP请求，并利用`Server-Sent Events (SSE)`来接收来自API的数据流。这种方式能够有效地减少延迟并提高用户体验。 #### 配置依赖项 首先，在项目的`pom.xml`文件里加入必要的Maven依赖： ```xml <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency> <!-- OpenFeign用于简化RESTful服务客户端开发 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> ``` 这些依赖允许使用Spring WebFlux来进行非阻塞I/O操作以及通过Feign Client更方便地定义对外部微服务的访问接口[^2]。 #### 设置OpenAI API连接属性 编辑`src/main/resources/application.yml`以包含如下配置信息： ```yaml spring: ai: openai: api-key: "sk-yourapikeyhere" base-url: "https://api.openai.com/v1/" ``` 此部分设置确保了后续代码能正确获取到所需的认证密钥和其他必要参数[^3]。 #### 编写Controller类处理请求 下面是一个简单的控制器例子，展示了如何发起对OpenAI Chat Completion端点带有stream选项的支持： ```java @RestController @RequestMapping("/chat") public class ChatController { @Value("${spring.ai.openai.api-key}") private String apiKey; @Value("${spring.ai.openai.base-url}") private String baseUrl; @GetMapping(value = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE) public Flux<String> streamChat(@RequestParam String message) { WebClient webClient = WebClient.builder() .baseUrl(baseUrl) .defaultHeader(HttpHeaders.AUTHORIZATION, "Bearer " + apiKey) .build(); return webClient.post().uri("/completions?stream=true") .body(BodyInserters.fromFormData("prompt", message)) .retrieve() .bodyToFlux(String.class); } } ``` 上述代码片段中的关键在于设置了正确的媒体类型为`text/event-stream`以便浏览器或其他客户端识别这是一个服务器推送事件；同时指定了`/completions?stream=true`作为目标URL路径，这告诉OpenAI API期望的是一个持续更新的结果集而不是一次性完成的任务[^1]。