Java调用ChatGPT API实战：从接入到性能优化的完整指南

1次阅读

共计 2431 个字符，预计需要花费 7 分钟才能阅读完成。

ChatGPT API 为 Java 开发者提供了强大的自然语言处理能力，在多个场景下都能显著提升开发效率。智能客服系统是最常见的应用之一，通过 API 可以实现自动回复、意图识别和上下文理解，大大降低人工客服成本。另一个典型场景是代码生成，开发者可以通过 ChatGPT API 自动生成代码片段、完成代码补全甚至进行代码审查，这在 IDE 插件开发中尤其有用。

Java 生态中有多种 HTTP 客户端可供选择，各有优缺点：

RestTemplate：Spring 传统同步客户端，简单易用但性能较差
WebClient：Spring Reactive 非阻塞客户端，适合高并发场景
OkHttp：轻量高效，支持 HTTP/ 2 和连接池

对于 ChatGPT API 调用，如果项目已经使用 Spring 生态，WebClient 是最佳选择；否则 OkHttp 提供了更好的性能和灵活性。

/**
 * 使用 OAuth2 认证调用 ChatGPT API
 * @param prompt 用户输入
 * @return API 响应
 * @throws IOException 网络或解析异常
 */
public String callChatGPT(String prompt) throws IOException {ObjectMapper mapper = new ObjectMapper();
    HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("https://api.openai.com/v1/chat/completions"))
        .header("Content-Type", "application/json")
        .header("Authorization", "Bearer" + getApiKey())
        .POST(HttpRequest.BodyPublishers.ofString(
            mapper.writeValueAsString(Map.of(
                "model", "gpt-3.5-turbo",
                "messages", List.of(Map.of("role", "user", "content", prompt))
            ))
        ))
        .build();

    return HttpClient.newHttpClient()
        .send(request, HttpResponse.BodyHandlers.ofString())
        .body();}

// 使用 WebClient 处理流式响应
webClient.post()
    .uri(API_ENDPOINT)
    .header("Authorization", "Bearer" + apiKey)
    .bodyValue(requestBody)
    .accept(MediaType.TEXT_EVENT_STREAM)
    .retrieve()
    .bodyToFlux(String.class)
    .subscribe(chunk -> {
        // 处理每个数据块
        System.out.println("Received chunk:" + chunk);
    });

// 使用 ExponentialBackoff 策略
RetryConfig config = RetryConfig.custom()
    .maxAttempts(3)
    .intervalFunction(IntervalFunction.ofExponentialBackoff(1000, 2))
    .retryOnException(e -> e instanceof IOException)
    .build();

RetryRegistry registry = RetryRegistry.of(config);
Retry retry = registry.retry("chatgptApi");

Supplier<String> supplier = () -> callChatGPT(prompt);
return Decorators.ofSupplier(supplier)
    .withRetry(retry)
    .get();

# application.yml 配置示例
httpclient:
  max-total: 50
  default-max-per-route: 20
  connect-timeout: 5000
  socket-timeout: 10000

客户端类型	吞吐量 (req/s)	平均延迟 (ms)
WebClient	1200	45
OkHttp	1100	50
RestTemplate	600	90

推荐使用 HashiCorp Vault 或 Kubernetes Secrets 管理 API 密钥，次选方案是环境变量：

String apiKey = System.getenv("CHATGPT_API_KEY");

public boolean containsSensitiveContent(String text) {List<String> bannedWords = List.of("暴力", "色情", "政治敏感词");
    return bannedWords.stream().anyMatch(text::contains);
}