Spring AI实战：5分钟搞定OpenAI聊天机器人（附完整代码）

Spring AI实战5分钟构建智能对话系统的完整指南在Java生态系统中Spring框架一直是企业级应用开发的首选。随着AI技术的普及Spring社区推出了Spring AI项目让Java开发者能够轻松集成大语言模型能力。本文将带您从零开始用最短时间构建一个功能完备的智能对话系统。1. 环境准备与项目初始化开始前需要准备以下基础环境JDK 17或更高版本Maven 3.6或Gradle 7.x有效的OpenAI API密钥推荐使用Spring Initializr快速初始化项目curl https://start.spring.io/starter.zip \ -d dependenciesweb,openai \ -d typegradle-project \ -d languagejava \ -d bootVersion3.2.0 \ -d groupIdcom.example \ -d artifactIdai-demo \ -o ai-demo.zip解压后在application.properties中添加OpenAI配置spring.ai.openai.api-key${OPENAI_API_KEY} spring.ai.openai.chat.modelgpt-3.5-turbo spring.ai.openai.chat.temperature0.7提示将${OPENAI_API_KEY}替换为实际API密钥或通过环境变量注入2. 核心代码实现创建基础的REST控制器处理对话请求RestController RequestMapping(/api/chat) public class ChatController { private final OpenAiChatClient chatClient; public ChatController(OpenAiChatClient chatClient) { this.chatClient chatClient; } PostMapping public String generate(RequestBody String prompt) { return chatClient.call(prompt); } PostMapping(/stream) public FluxString generateStream(RequestBody String prompt) { return chatClient.stream(prompt); } }这段代码实现了两个核心端点/api/chat同步响应式接口/api/chat/stream流式响应接口3. 高级功能扩展3.1 对话上下文管理实现多轮对话需要维护上下文状态PostMapping(/context) public ChatResponse chatWithContext(RequestBody ChatRequest request) { ListMessage messages new ArrayList(); messages.add(new SystemMessage(你是一个专业的Java技术顾问)); messages.add(new UserMessage(request.prompt())); Prompt prompt new Prompt(messages); ChatResponse response chatClient.call(prompt); return response; }3.2 参数调优指南不同场景下推荐使用的参数组合场景类型温度值最大token数适用模型代码生成0.22048gpt-4创意写作0.81024gpt-3.5-turbo技术问答0.5512gpt-3.5-turbo-16k数据格式化0.14096gpt-4-turbo4. 生产环境最佳实践4.1 异常处理机制ExceptionHandler(OpenAiApiException.class) public ResponseEntityErrorResponse handleOpenAiException(OpenAiApiException ex) { return ResponseEntity.status(ex.getStatusCode()) .body(new ErrorResponse(ex.getMessage())); } ExceptionHandler(RateLimitException.class) public ResponseEntityErrorResponse handleRateLimit(RateLimitException ex) { return ResponseEntity.status(429) .header(Retry-After, String.valueOf(ex.getRetryAfter())) .body(new ErrorResponse(请求过于频繁请稍后重试)); }4.2 性能优化建议启用响应式编程模型实现请求批处理配置合理的超时设置spring.ai.openai.connect-timeout10s spring.ai.openai.read-timeout30s5. 测试与验证使用Testcontainers进行集成测试Testcontainers class ChatApplicationTests { Container static MockServerContainer mockOpenAi new MockServerContainer(DockerImageName.parse(mockserver/mockserver)); DynamicPropertySource static void properties(DynamicPropertyRegistry registry) { registry.add(spring.ai.openai.base-url, () - http://mockOpenAi.getHost():mockOpenAi.getServerPort()); } Test void shouldReturnChatResponse() { // 测试逻辑 } }6. 部署方案选型根据业务规模选择部署方式小型项目直接打包为可执行JAR./gradlew bootJar java -jar build/libs/ai-demo.jar中型项目Docker容器化FROM eclipse-temurin:17-jdk-jammy COPY build/libs/*.jar app.jar ENTRYPOINT [java,-jar,/app.jar]大型系统Kubernetes部署apiVersion: apps/v1 kind: Deployment metadata: name: ai-chatbot spec: replicas: 3 template: spec: containers: - name: app image: your-registry/ai-demo:latest envFrom: - secretRef: name: openai-secret在实际项目中我发现流式接口特别适合需要实时反馈的场景比如代码补全功能。通过合理设置响应缓冲区大小可以显著提升用户体验。