springboot通义千问流式

### 集成通义千问流式接口到Spring Boot中的方法 要在Spring Boot应用程序中集成阿里云的通义千问流式接口，可以按照以下方式实现。以下是详细的说明以及代码示例。 #### 依赖配置 首先，在`pom.xml`文件中引入必要的依赖项来支持HTTP请求操作。通常情况下会使用`spring-boot-starter-web`作为基础Web框架，并额外加入`HttpClient`库用于发起网络请求： ```xml <dependencies> <!-- Spring Web Starter --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- Apache HttpClient for making HTTP requests --> <dependency> <groupId>org.apache.httpcomponents.client5</groupId> <artifactId>httpclient5</artifactId> <version>5.2</version> </dependency> </dependencies> ``` 上述XML片段展示了如何通过Maven构建工具加载所需的JAR包[^2]。 #### 创建服务类处理调用逻辑 定义一个专门的服务类用来封装与通义千问交互的具体细节。这里采用异步的方式读取服务器返回的数据流并逐步解析输出结果。 ```java import org.apache.hc.core5.http.ClassicHttpResponse; import org.apache.hc.core5.http.HttpEntity; import org.apache.hc.core5.http.impl.bootstrap.HttpServer; import org.apache.hc.core5.http.io.entity.EntityUtils; import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.URI; import java.nio.charset.StandardCharsets; public class TongYiQianWenService { private static final String API_URL = "https://your-tongyi-qianwen-endpoint"; public void callStreamingApi(String prompt) throws Exception { try (var client = org.apache.hc.core5.http.impl.classic.CloseableHttpAsyncClient.create()) { client.start(); var requestBuilder = org.apache.hc.core5.http.message.RequestBuilder.post() .setUri(new URI(API_URL)) .addHeader("Content-Type", "application/json") .addHeader("Authorization", getBearerToken()); var jsonBody = """ {"prompt": "%s"} """.formatted(prompt); var entity = new org.apache.hc.core5.http.nio.support.AsyncRequestProducer( requestBuilder.setEntity(org.apache.hc.core5.http.nio.entity.StringAsyncEntity.create(jsonBody)).build(), null, StandardCharsets.UTF_8 ); var responseConsumer = new org.apache.hc.core5.http.nio.support.BasicResponseConsumer<>(); client.execute(entity, responseConsumer).get().thenAccept(response -> { try(var reader = new BufferedReader(new InputStreamReader(((ClassicHttpResponse)response).getEntity().getContent(), StandardCharsets.UTF_8))){ String line; while ((line=reader.readLine())!=null){ System.out.println(line); } } catch(Exception e){ throw new RuntimeException(e.getMessage()); } }); } } private String getBearerToken() { // Replace with actual token retrieval logic. return "Bearer YOUR_ACCESS_TOKEN"; } } ``` 此段代码实现了向指定URL发送POST请求的功能，并持续接收来自远程端点的消息直到连接关闭为止[^3]。 #### 控制器层暴露外部访问入口 最后一步是在控制器层面创建RESTful API以便其他应用能够触发该功能。 ```java @RestController @RequestMapping("/tongyi/qianwen/streaming") public class TongYiQianWenController { @Autowired private TongYiQianWenService service; @PostMapping(consumes="text/plain;charset=UTF-8", produces="text/event-stream;charset=UTF-8") public ResponseEntity<String> stream(@RequestBody(required=true) String inputText) { try{ this.service.callStreamingApi(inputText); return new ResponseEntity<>("Stream started.", HttpStatus.OK); }catch(Throwable t){ return new ResponseEntity<>(String.format("Error occurred:%s",t.getMessage()),HttpStatus.INTERNAL_SERVER_ERROR); } } } ``` 以上即为完整的解决方案概述及其组成部分[^1]^。