🚀 PIG AI 新版来袭:AI能力全面升级! 点击了解一下?
<dependencyManagement> <dependencies> <dependency> <groupId>com.squareup.okhttp3</groupId> <artifactId>okhttp</artifactId> <version>4.12.0</version> </dependency> <dependency> <groupId>com.squareup.okhttp3</groupId> <artifactId>okhttp-sse</artifactId> <version>4.12.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson</groupId> <artifactId>jackson-bom</artifactId> <version>2.12.4</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement>
@GetMapping(value = "/chat", produces = MediaType.TEXT_EVENT_STREAM_VALUE + ";charset=UTF-8") public Flux<ChatCompletionResponse> chat(String prompt) { // 你的业务逻辑 }
@Bean public DeepSeekClient aliyunDeepSeekClient() { DeepSeekClient.Builder builder = DeepSeekClient.builder().baseUrl(deepSeekProperties.getBaseUrl()) .model(deepSeekProperties.getModel()).openAiApiKey(deepSeekProperties.getApiKey()) .logRequests(deepSeekProperties.isLogRequests()).logResponses(deepSeekProperties.isLogResponses()); return builder.build(); } @Bean public DeepSeekClient txDeepSeekClient() { DeepSeekClient.Builder builder = DeepSeekClient.builder().baseUrl(deepSeekProperties.getBaseUrl()) .model(deepSeekProperties.getModel()).openAiApiKey(deepSeekProperties.getApiKey()) .logRequests(deepSeekProperties.isLogRequests()).logResponses(deepSeekProperties.isLogResponses()); return builder.build(); }
return deepSeekClient.chatFluxCompletion(prompt) .doOnNext(response -> { if (Objects.nonNull(response.usage())) { // 在这里处理用量统计信息 // 可以记录到日志或数据库中 } });