From 24681c81c09022f584a57006f2534b5f74723414 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期二, 30 六月 2026 09:27:31 +0800
Subject: [PATCH] 初始化项目
---
yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/GeminiChatModelTests.java | 75 +++++++++++++++++++++++++++++--------
1 files changed, 58 insertions(+), 17 deletions(-)
diff --git a/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/GeminiChatModelTests.java b/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/GeminiChatModelTests.java
index f9bd70a..8337157 100644
--- a/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/GeminiChatModelTests.java
+++ b/yudao-module-ai/src/test/java/cn/iocoder/yudao/module/ai/framework/ai/core/model/chat/GeminiChatModelTests.java
@@ -1,7 +1,9 @@
package cn.iocoder.yudao.module.ai.framework.ai.core.model.chat;
-import cn.iocoder.yudao.module.ai.framework.ai.core.model.gemini.GeminiChatModel;
-import com.openai.client.okhttp.OpenAIOkHttpClient;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.system.SystemUtil;
+import com.google.genai.Client;
+import com.google.genai.types.HttpOptions;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.ai.chat.messages.Message;
@@ -9,36 +11,48 @@
import org.springframework.ai.chat.messages.UserMessage;
import org.springframework.ai.chat.model.ChatResponse;
import org.springframework.ai.chat.prompt.Prompt;
-import org.springframework.ai.openai.OpenAiChatModel;
-import org.springframework.ai.openai.OpenAiChatOptions;
+import org.springframework.ai.google.genai.GoogleGenAiChatModel;
+import org.springframework.ai.google.genai.GoogleGenAiChatOptions;
import reactor.core.publisher.Flux;
import java.util.ArrayList;
import java.util.List;
+import java.util.Objects;
+
+import static cn.iocoder.yudao.module.ai.util.AiUtils.validateApiKey;
/**
- * {@link GeminiChatModel} 闆嗘垚娴嬭瘯
+ * {@link GoogleGenAiChatModel} 闆嗘垚娴嬭瘯
*
* @author 鑺嬮亾婧愮爜
*/
public class GeminiChatModelTests {
- private final OpenAiChatModel openAiChatModel = OpenAiChatModel.builder()
- .openAiClient(OpenAIOkHttpClient.builder()
- .baseUrl(GeminiChatModel.BASE_URL)
- .apiKey("AIzaSyAVoBxgoFvvte820vEQMma2LKBnC98bqMQ")
- .build())
- .options(OpenAiChatOptions.builder()
- .model(GeminiChatModel.MODEL_DEFAULT) // 妯″瀷
- .temperature(0.7)
- .build())
- .build();
+ private static final String BASE_URL = SystemUtil.get("GEMINI_BASE_URL");
+ private static final String API_KEY = SystemUtil.get("GEMINI_API_KEY",
+ "sk-xxxx"); // 鎸夐渶鏀规垚浣犵殑 Gemini API Key
+ private static final String MODEL = "gemini-3.5-flash";
- private final GeminiChatModel chatModel = new GeminiChatModel(openAiChatModel);
+ private final GoogleGenAiChatModel chatModel = GoogleGenAiChatModel.builder()
+ .genAiClient(buildClient())
+ .options(GoogleGenAiChatOptions.builder()
+ .model(MODEL) // 妯″瀷
+ .temperature(0.7)
+ .build())
+ .build();
+
+ private static Client buildClient() {
+ Client.Builder builder = Client.builder().apiKey(API_KEY);
+ if (StrUtil.isNotBlank(BASE_URL)) {
+ builder.httpOptions(HttpOptions.builder().baseUrl(BASE_URL).build());
+ }
+ return builder.build();
+ }
@Test
@Disabled
public void testCall() {
+ validateApiKey(API_KEY);
// 鍑嗗鍙傛暟
List<Message> messages = new ArrayList<>();
messages.add(new SystemMessage("浣犳槸涓�涓紭璐ㄧ殑鏂囪█鏂囦綔鑰咃紝鐢ㄦ枃瑷�鏂囨弿杩扮潃鍚勫煄甯傜殑浜烘枃椋庢櫙銆�"));
@@ -48,11 +62,13 @@
ChatResponse response = chatModel.call(new Prompt(messages));
// 鎵撳嵃缁撴灉
System.out.println(response);
+ System.out.println(Objects.requireNonNull(response.getResult()).getOutput());
}
@Test
@Disabled
public void testStream() {
+ validateApiKey(API_KEY);
// 鍑嗗鍙傛暟
List<Message> messages = new ArrayList<>();
messages.add(new SystemMessage("浣犳槸涓�涓紭璐ㄧ殑鏂囪█鏂囦綔鑰咃紝鐢ㄦ枃瑷�鏂囨弿杩扮潃鍚勫煄甯傜殑浜烘枃椋庢櫙銆�"));
@@ -61,7 +77,32 @@
// 璋冪敤
Flux<ChatResponse> flux = chatModel.stream(new Prompt(messages));
// 鎵撳嵃缁撴灉
- flux.doOnNext(System.out::println).then().block();
+ flux.doOnNext(response -> {
+ System.out.println(response);
+// System.out.println(Objects.requireNonNull(response.getResult()).getOutput());
+ }).then().block();
+ }
+
+ @Test
+ @Disabled
+ public void testStream_thinking() {
+ validateApiKey(API_KEY);
+ // 鍑嗗鍙傛暟
+ List<Message> messages = new ArrayList<>();
+ messages.add(new UserMessage("璇︾粏鍒嗘瀽涓嬶紝濡備綍璁捐涓�涓數鍟嗙郴缁燂紵"));
+ GoogleGenAiChatOptions options = GoogleGenAiChatOptions.builder()
+ .model(MODEL)
+ .thinkingBudget(1024)
+ .includeThoughts(true)
+ .build();
+
+ // 璋冪敤
+ Flux<ChatResponse> flux = chatModel.stream(new Prompt(messages, options));
+ // 鎵撳嵃缁撴灉
+ flux.doOnNext(response -> {
+ System.out.println(response);
+// System.out.println(Objects.requireNonNull(response.getResult()).getOutput());
+ }).then().block();
}
}
--
Gitblit v1.9.3