feat(ai\spring-ai-alibaba1): Spring AI Alibaba 的使用

Author: atengk

ai/spring-ai-alibaba1/README_CATALOG.md

@@ -57,7 +57,7 @@
             <version>${hutool.version}</version>
         </dependency>
 
-        <!-- Spring AI Alibaba 依赖 -->
+        <!-- Spring AI Alibaba DashScope -->
         <dependency>
             <groupId>com.alibaba.cloud.ai</groupId>
             <artifactId>spring-ai-alibaba-starter-dashscope</artifactId>

ai/spring-ai-alibaba1/README_NEW.md

@@ -0,0 +1,33 @@
+package io.github.atengk.ai.config;
+
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.cloud.ai.graph.RunnableConfig;
+
+/**
+ * Agent 执行配置工厂
+ *
+ * @author Ateng
+ * @since 2026-04-24
+ */
+public class AgentRunnableConfigFactory {
+
+    /**
+     * 创建 Agent 执行配置
+     *
+     * @param threadId 会话 ID
+     * @param userId   用户 ID
+     * @param tenantId 租户 ID
+     * @return Agent 执行配置
+     */
+    public static RunnableConfig create(String threadId, String userId, String tenantId) {
+        String conversationId = StrUtil.blankToDefault(threadId, "default-thread");
+
+        return RunnableConfig.builder()
+                .threadId(conversationId)
+                .addMetadata("user_id", userId)
+                .addMetadata("tenant_id", tenantId)
+                .addMetadata("source", "spring-ai-alibaba-demo")
+                .build();
+    }
+
+}

ai/spring-ai-alibaba1/README_TMP.md

@@ -1,37 +1,52 @@
 package io.github.atengk.ai.config;
 
-import com.alibaba.cloud.ai.dashscope.chat.DashScopeChatModel;
 import com.alibaba.cloud.ai.graph.agent.ReactAgent;
+import com.alibaba.cloud.ai.graph.agent.hook.modelcalllimit.ModelCallLimitHook;
 import com.alibaba.cloud.ai.graph.checkpoint.savers.MemorySaver;
-import org.springframework.ai.tool.ToolCallback;
+import io.github.atengk.ai.model.AnalysisResult;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.ai.chat.model.ChatModel;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
-import java.util.List;
-
+/**
+ * ReactAgent 配置
+ *
+ * @author Ateng
+ * @since 2026-04-24
+ */
+@Slf4j
 @Configuration
 public class ReactAgentConfig {
 
     @Bean
-    public ReactAgent reactAgent(DashScopeChatModel dashScopeChatModel) {
+    public ReactAgent reactAgent(ChatModel chatModel) {
+        log.info("初始化 ReactAgent");
+
         return ReactAgent.builder()
-                .name("default_agent")
-                .model(dashScopeChatModel)
+                .name("dashscope_react_agent")
+                .model(chatModel)
+                .description("基于 DashScope 的 ReAct 智能体")
+                .instruction("""
+                        你是一个专业的 Java 技术助手。
+                        需要先理解用户意图，再根据任务复杂度决定是否调用工具。
+                        如果工具结果不足以支撑结论，需要明确说明不确定性。
+                        """)
+                .hooks(ModelCallLimitHook.builder().runLimit(5).build())
                 .saver(new MemorySaver())
                 .build();
     }
 
     @Bean
-    public ReactAgent toolReactAgent(
-            DashScopeChatModel dashScopeChatModel,
-            List<ToolCallback> toolCallbacks
-    ) {
+    public ReactAgent structuredReactAgent(ChatModel chatModel) {
         return ReactAgent.builder()
-                .name("tool_agent")
-                .tools(toolCallbacks)
-                .model(dashScopeChatModel)
+                .name("structured_react_agent")
+                .model(chatModel)
+                .description("返回结构化分析结果的 Agent")
+                .instruction("你需要分析用户问题，并按照指定结构返回结果。")
+                .outputType(AnalysisResult.class)
                 .saver(new MemorySaver())
                 .build();
     }
 
-}
+}

ai/spring-ai-alibaba1/pom.xml

@@ -0,0 +1,63 @@
+package io.github.atengk.ai.controller;
+
+import cn.hutool.core.util.StrUtil;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.ai.chat.messages.UserMessage;
+import org.springframework.ai.chat.model.ChatModel;
+import org.springframework.ai.chat.model.ChatResponse;
+import org.springframework.ai.chat.prompt.Prompt;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+
+import java.util.Map;
+
+/**
+ * 文本对话接口
+ *
+ * @author Ateng
+ * @since 2026-04-24
+ */
+@Slf4j
+@RestController
+@RequiredArgsConstructor
+public class ChatController {
+
+    private final ChatModel chatModel;
+
+    /**
+     * 普通文本生成接口
+     *
+     * @param message 用户输入内容
+     * @return 模型生成结果
+     */
+    @GetMapping("/ai/generate")
+    public Map<String, String> generate(@RequestParam(value = "message", required = false) String message) {
+        String userMessage = StrUtil.blankToDefault(message, "请用一句话介绍 Spring AI Alibaba");
+        log.info("收到普通聊天请求，message={}", userMessage);
+
+        String content = chatModel.call(userMessage);
+        return Map.of("generation", content);
+    }
+
+    /**
+     * 流式文本生成接口
+     *
+     * @param message 用户输入内容
+     * @return 流式模型响应
+     */
+    @GetMapping(value = "/ai/generateStream", produces = "text/event-stream;charset=UTF-8")
+    public Flux<String> generateStream(@RequestParam(value = "message", required = false) String message) {
+        String userMessage = StrUtil.blankToDefault(message, "请列出 Spring AI Alibaba 的三个核心能力");
+        log.info("收到流式聊天请求，message={}", userMessage);
+
+        Prompt prompt = new Prompt(new UserMessage(userMessage));
+        return chatModel.stream(prompt)
+                .map(ChatResponse::getResult)
+                .map(result -> result.getOutput().getText())
+                .filter(StrUtil::isNotBlank);
+    }
+
+}