Java调用Claude API完整代码（Spring Boot + WebClient + 流式输出）
一句话总结：本文提供Spring Boot调用Claude API的完整代码，覆盖同步调用、SSE流式输出、多轮对话，可直接复制运行。
一、Claude vs OpenAI：为什么选Claude？
| 维度 | Claude | OpenAI GPT |
|---|---|---|
| 中文质量 | 优秀（指令遵循强） | 优秀 |
| 代码能力 | 极强（Claude 3.5 Sonnet） | 强 |
| 上下文长度 | 200K tokens | 128K |
| 价格 | 略低 | 标准 |
| 国内访问 | 需要代理 | 需要代理 |
Claude特别适合：长文档分析、复杂代码生成、需要严格遵循格式的场景。
二、依赖引入
<!-- pom.xml --><dependencies><!-- Spring Boot WebFlux（用于WebClient） --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId></dependency><!-- 可选：Spring AI Anthropic（如果官方支持） --><dependency><groupId>org.springframework.ai</groupId><artifactId>spring-ai-anthropic-spring-boot-starter</artifactId><version>1.0.0</version></dependency><!-- Lombok（简化代码） --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency></dependencies>三、配置文件
# application.ymlanthropic:api-key:${ANTHROPIC_API_KEY}base-url:https://api.anthropic.comversion:2023-06-01# API版本model:claude-3-5-sonnet-20241022# 最新模型max-tokens:4096temperature:0.7# 超时配置spring:webflux:client:connect-timeout:30000read-timeout:60000四、核心代码
4.1 配置类：ClaudeClientConfig
importorg.springframework.beans.factory.annotation.Value;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.web.reactive.function.client.WebClient;importreactor.core.publisher.Mono;@ConfigurationpublicclassClaudeClientConfig{@Value("${anthropic.api-key}")privateStringapiKey;@Value("${anthropic.base-url:https://api.anthropic.com}")privateStringbaseUrl;@Value("${anthropic.version:2023-06-01}")privateStringapiVersion;@BeanpublicWebClientclaudeWebClient(){returnWebClient.builder().baseUrl(baseUrl).defaultHeader("x-api-key",apiKey).defaultHeader("anthropic-version",apiVersion).defaultHeader("Content-Type","application/json").build();}}4.2 同步调用：ClaudeChatService
importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.beans.factory.annotation.Value;importorg.springframework.stereotype.Service;importorg.springframework.web.reactive.function.client.WebClient;importreactor.core.publisher.Mono;importlombok.Data;importjava.util.List;@ServicepublicclassClaudeChatService{@AutowiredprivateWebClientclaudeWebClient;@Value("${anthropic.model:claude-3-5-sonnet-20241022}")privateStringmodel;@Value("${anthropic.max-tokens:4096}")privateintmaxTokens;/** * 同步单轮对话 */publicStringchat(Stringmessage){ClaudeRequestrequest=newClaudeRequest();request.setModel(model);request.setMaxTokens(maxTokens);request.setMessages(List.of(newMessage("user",message)));ClaudeResponseresponse=claudeWebClient.post().uri("/v1/messages").bodyValue(request).retrieve().bodyToMono(ClaudeResponse.class).block();// 同步阻塞returnextractContent(response);}/** * 同步多轮对话 */publicStringchatWithHistory(List<Message>history,StringnewMessage){history.add(newMessage("user",newMessage));ClaudeRequestrequest=newClaudeRequest();request.setModel(model);request.setMaxTokens(maxTokens);request.setMessages(history);ClaudeResponseresponse=claudeWebClient.post().uri("/v1/messages").bodyValue(request).retrieve().bodyToMono(ClaudeResponse.class).block();// 把AI回复加入历史history.add(newMessage("assistant",extractContent(response)));returnextractContent(response);}privateStringextractContent(ClaudeResponseresponse){if(response==null||response.getContent()==null||response.getContent().isEmpty()){return"";}returnresponse.getContent().get(0).getText();}// DTO类@DatapublicstaticclassClaudeRequest{privateStringmodel;privateintmaxTokens;privateList<Message>messages;}@DatapublicstaticclassMessage{privateStringrole;// "user" or "assistant"privateStringcontent;publicMessage(Stringrole,Stringcontent){this.role=role;this.content=content;}}@DatapublicstaticclassClaudeResponse{privateStringid;privateStringmodel;privateList<ContentBlock>content;privateUsageusage;}@DatapublicstaticclassContentBlock{privateStringtype;// "text"privateStringtext;}@DatapublicstaticclassUsage{privateintinputTokens;privateintoutputTokens;}}4.3 流式调用：ClaudeStreamService（SSE）
importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.stereotype.Service;importorg.springframework.web.reactive.function.client.WebClient;importreactor.core.publisher.Flux;importcom.fasterxml.jackson.databind.ObjectMapper;importlombok.Data;importjava.util.List;@ServicepublicclassClaudeStreamService{@AutowiredprivateWebClientclaudeWebClient;@AutowiredprivateObjectMapperobjectMapper;/** * 流式对话（SSE） * 返回Flux<String>，每个元素是一个token片段 */publicFlux<String>chatStream(Stringmessage){ClaudeRequestrequest=newClaudeRequest();request.setModel("claude-3-5-sonnet-20241022");request.setMaxTokens(4096);request.setMessages(List.of(newMessage("user",message)));request.setStream(true);// 关键：开启流式returnclaudeWebClient.post().uri("/v1/messages").bodyValue(request).retrieve().bodyToFlux(String.class)// 按行读取SSE数据.filter(line->line.startsWith("data:"))// 只处理data:行.map(line->line.substring(5).trim())// 去掉"data: "前缀.filter(data->!data.equals("[DONE]"))// 过滤结束标记.map(this::extractDeltaText).filter(text->text!=null&&!text.isEmpty());}/** * 从SSE事件中提取文本增量 */privateStringextractDeltaText(StringjsonData){try{StreamEventevent=objectMapper.readValue(jsonData,StreamEvent.class);if("content_block_delta".equals(event.getType())&&event.getDelta()!=null){returnevent.getDelta().getText();}return"";}catch(Exceptione){return"";}}// 流式事件DTO@DatapublicstaticclassStreamEvent{privateStringtype;// "content_block_delta", "message_start", etc.privateStringindex;privateDeltadelta;}@DatapublicstaticclassDelta{privateStringtype;// "text_delta"privateStringtext;// 实际的文本增量}// 复用ClaudeChatService的DTO@DatapublicstaticclassClaudeRequest{privateStringmodel;privateintmaxTokens;privateList<ClaudeChatService.Message>messages;privatebooleanstream;}@DatapublicstaticclassMessage{privateStringrole;privateStringcontent;publicMessage(Stringrole,Stringcontent){this.role=role;this.content=content;}}}4.4 Controller层：REST API暴露
importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.http.MediaType;importorg.springframework.web.bind.annotation.*;importreactor.core.publisher.Flux;importreactor.core.publisher.Mono;importjava.util.ArrayList;importjava.util.List;@RestController@RequestMapping("/api/claude")publicclassClaudeController{@AutowiredprivateClaudeChatServicechatService;@AutowiredprivateClaudeStreamServicestreamService;/** * 同步对话 */@PostMapping("/chat")publicMono<String>chat(@RequestBodyChatRequestrequest){returnMono.just(chatService.chat(request.getMessage()));}/** * 流式对话（SSE） */@PostMapping(value="/chat/stream",produces=MediaType.TEXT_EVENT_STREAM_VALUE)publicFlux<String>chatStream(@RequestBodyChatRequestrequest){returnstreamService.chatStream(request.getMessage());}/** * 多轮对话（带历史） */privatefinalList<ClaudeChatService.Message>conversationHistory=newArrayList<>();@PostMapping("/chat/history")publicMono<String>chatWithHistory(@RequestBodyChatRequestrequest){Stringresponse=chatService.chatWithHistory(conversationHistory,request.getMessage());returnMono.just(response);}@PostMapping("/chat/history/clear")publicMono<String>clearHistory(){conversationHistory.clear();returnMono.just("历史记录已清空");}@DatapublicstaticclassChatRequest{privateStringmessage;}}五、测试验证
5.1 同步调用测试
curl-XPOST http://localhost:8080/api/claude/chat-H"Content-Type: application/json"-d'{"message": "用Java写一个单例模式，要求线程安全"}'5.2 流式调用测试（SSE）
curl-XPOST http://localhost:8080/api/claude/chat/stream-H"Content-Type: application/json"-d'{"message": "讲一个程序员笑话"}'# 输出：# data: 有# data: 一# data: 个# data: 程序员...5.3 前端EventSource消费
consteventSource=newEventSource('/api/claude/chat/stream',{method:'POST',body:JSON.stringify({message:'你好'})});eventSource.onmessage=(event)=>{console.log('收到:',event.data);appendToUI(event.data);// 追加到页面};eventSource.onerror=()=>{console.log('连接结束');eventSource.close();};六、与OpenAI对比
@ServicepublicclassAIChatService{@AutowiredprivateClaudeChatServiceclaudeService;// 可切换的AI ProviderpublicStringchat(Stringprovider,Stringmessage){switch(provider){case"claude":returnclaudeService.chat(message);case"openai":// return openAIService.chat(message);default:returnclaudeService.chat(message);}}}七、常见问题
7.1 403 Forbidden
Claude API需要申请访问权限，新账户可能无法直接调用。
解决：在Anthropic官网申请API访问，或使用第三方代理。
7.2 流式输出乱码
SSE事件格式与OpenAI不同，注意解析content_block_delta事件。
7.3 上下文长度超限
Claude 3.5支持200K tokens，但超过后会被截断。
解决：实现滑动窗口历史管理，只保留最近N轮对话。
八、完整项目结构
claude-java-demo/ ├── pom.xml ├── src/ │ ├── main/ │ │ ├── java/ │ │ │ └── com/example/claude/ │ │ │ ├── ClaudeJavaDemoApplication.java │ │ │ ├── config/ │ │ │ │ └── ClaudeClientConfig.java │ │ │ ├── service/ │ │ │ │ ├── ClaudeChatService.java │ │ │ │ └── ClaudeStreamService.java │ │ │ └── controller/ │ │ │ └── ClaudeController.java │ │ └── resources/ │ │ └── application.yml │ └── test/ │ └── java/ │ └── ClaudeChatServiceTest.java👤 关于作者
JavaAgent架构师— 十年Java分布式架构老兵，专注AI Agent企业级落地。
主导过数字员工、SOP智能引擎等项目，开发过RPC框架、消息中间件、ORM框架。
📚正在输出三个专栏：
- 《前端AI工程化》— SSE/流式渲染/Function Calling/企业级架构
- 《Java体系也能玩转AI》— Spring AI/Agent框架/MCP/工作流
- 《从0构建Agent系统》— 数字员工/SOP模型库/生产部署
让Java开发者不转Python，让前端工程师掌握AI核心竞争力。
📮关注专栏｜🔔点赞收藏｜💬评论区见