Spring Boot整合Spring AI：企业级AI应用开发指南

1. Spring Boot与Spring AI的快速整合指南在当今企业级应用开发领域Spring Boot已经成为Java生态中构建微服务的首选框架。而随着AI技术的普及Spring社区近期推出的Spring AI项目为开发者提供了将AI能力无缝集成到Spring应用中的便捷途径。本文将带你快速实现两者的整合并分享我在实际项目中的落地经验。Spring AI目前支持的主流AI服务包括OpenAI、Azure OpenAI和HuggingFace等通过统一的API抽象层开发者可以轻松切换不同供应商的AI服务。与传统的直接调用API方式相比Spring AI提供了更符合Spring习惯的编程模型特别是在处理提示词模板、函数调用和流式响应等方面表现出色。2. 环境准备与基础配置2.1 创建Spring Boot项目推荐使用Spring Initializrstart.spring.io创建基础项目选择以下依赖Spring Web用于构建REST接口Spring AI核心AI集成Lombok简化代码对于Gradle用户build.gradle中需添加implementation org.springframework.ai:spring-ai-openai-spring-boot-starterMaven用户则添加dependency groupIdorg.springframework.ai/groupId artifactIdspring-ai-openai-spring-boot-starter/artifactId /dependency2.2 配置API密钥在application.properties中配置OpenAI访问凭证spring.ai.openai.api-key你的API密钥 spring.ai.openai.chat.options.modelgpt-3.5-turbo重要提示实际项目中应将密钥存储在安全的配置中心或使用环境变量注入避免硬编码在配置文件中。对于生产环境建议通过Vault或Kubernetes Secrets管理敏感信息。3. 核心功能实现3.1 基础聊天功能实现创建ChatController处理AI对话请求RestController RequiredArgsConstructor public class ChatController { private final ChatClient chatClient; PostMapping(/chat) public String generate(RequestParam String message) { return chatClient.call(message); } }这个简单的实现已经可以处理基础对话。但实际项目中我们通常需要更复杂的交互逻辑。3.2 高级提示词工程Spring AI提供了强大的提示词模板功能。创建prompt-templates目录添加system-message.st你是一个专业的Java开发助手专门帮助解决Spring Boot相关问题。 请用中文回答保持回答专业且简洁。 问题{question}对应的Service层实现public String getTechAnswer(String question) { PromptTemplate promptTemplate new PromptTemplate(resourceLoader.getResource(classpath:prompt-templates/system-message.st)); Prompt prompt promptTemplate.create(Map.of(question, question)); return chatClient.call(prompt.getContents()); }3.3 流式响应处理对于长文本生成场景流式响应可以显著提升用户体验GetMapping(/stream) public SseEmitter streamChat(RequestParam String message) { SseEmitter emitter new SseEmitter(); chatClient.stream(message).subscribe( chunk - { try { emitter.send(chunk.getContents().getContent()); } catch (IOException e) { throw new RuntimeException(e); } }, emitter::completeWithError, emitter::complete ); return emitter; }4. 生产环境注意事项4.1 性能优化连接池配置spring.ai.openai.connect-timeout30s spring.ai.openai.read-timeout60s启用响应缓存结合Spring CacheCacheable(value aiResponses, key #question.hashCode()) public String getCachedAnswer(String question) { return getTechAnswer(question); }4.2 异常处理实现全局异常处理器RestControllerAdvice public class AIExceptionHandler { ExceptionHandler(ApiException.class) public ResponseEntityErrorResponse handleOpenAIException(ApiException ex) { return ResponseEntity.status(ex.getStatusCode()) .body(new ErrorResponse(ex.getMessage())); } Data AllArgsConstructor private static class ErrorResponse { private String message; } }4.3 监控与指标集成Micrometer暴露AI调用指标Bean public MeterRegistryCustomizerMeterRegistry metricsCommonTags() { return registry - registry.config().commonTags(application, spring-ai-demo); } Autowired private MeterRegistry meterRegistry; public String getMonitoredAnswer(String question) { return Timer.builder(ai.chat.time) .tag(model, gpt-3.5-turbo) .register(meterRegistry) .record(() - getTechAnswer(question)); }5. 实际应用场景扩展5.1 文档智能处理结合Spring AI的文档解析能力Bean public DocumentReader pdfReader() { return new PdfDocumentReader(new DocumentReaderConfig()); } public String analyzeDocument(MultipartFile file) { DocumentReader documentReader pdfReader(); String content documentReader.read(file.getResource()); return getTechAnswer(请总结以下文档内容 content); }5.2 知识库集成实现简单的向量搜索Bean public VectorStore vectorStore(EmbeddingClient embeddingClient) { return new SimpleVectorStore(embeddingClient); } public void populateKnowledgeBase(ListDocument docs, VectorStore vectorStore) { vectorStore.add(docs.stream() .map(doc - new Document(doc.getId(), doc.getContent(), doc.getMetadata())) .toList()); } public ListDocument searchKnowledge(String query, VectorStore vectorStore) { return vectorStore.similaritySearch(query); }6. 常见问题排查超时问题现象长时间无响应或报ReadTimeout解决方案调整timeout配置考虑实现重试机制Retryable(value {ApiException.class}, maxAttempts 3) public String getAnswerWithRetry(String question) { return getTechAnswer(question); }上下文长度限制现象返回结果被截断解决方案拆分长文档使用继续提示词分段获取计费异常现象API调用次数激增解决方案实现速率限制RateLimiter(name aiRateLimit) public String getRateLimitedAnswer(String question) { return getTechAnswer(question); }中文支持问题现象返回非预期语言解决方案在系统提示中明确语言要求检查模型配置7. 安全加固方案输入验证PostMapping(/secure-chat) public String secureGenerate(Valid RequestBody ChatRequest request) { // 白名单校验 if (!isSafeInput(request.getMessage())) { throw new InvalidInputException(包含不安全内容); } return chatClient.call(request.getMessage()); }输出过滤public String getFilteredResponse(String question) { String response getTechAnswer(question); return contentFilter.filter(response); }权限控制PreAuthorize(hasRole(AI_USER)) PostMapping(/admin/chat) public String adminChat(RequestBody AdminChatRequest request) { return chatClient.call(request.getMessage()); }8. 性能对比测试下表展示了不同配置下的响应时间对比测试环境AWS t3.medium100并发请求模型平均响应时间最大内存占用适合场景gpt-3.5-turbo1.2s450MB常规业务对话gpt-43.5s780MB复杂逻辑处理claude-instant0.8s320MB快速响应场景在实际项目中我建议根据具体需求选择合适的模型。对于大多数业务场景gpt-3.5-turbo已经能够提供良好的性价比。