Java调用通义千问API的详细步骤

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.13</version>
</dependency>
<dependency>
    <groupId>org.json</groupId>
    <artifactId>json</artifactId>
    <version>20231013</version>
</dependency>

import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.json.JSONObject;
public class TongyiQianwenClient {
    // 从环境变量获取API Key（推荐）
    private static final String API_KEY = System.getenv("DASHSCOPE_API_KEY");
    private static final String API_URL = "https://dashscope.aliyuncs.com/api/v1/services/aigc/text-generation/generation";
    public static void main(String[] args) {
        try {
            String response = callQianwenAPI("解释一下量子计算");
            System.out.println("API 响应：\n" + response);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static String callQianwenAPI(String userInput) throws Exception {
        // 1. 创建HTTP客户端
        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            // 2. 构建请求
            HttpPost httpPost = new HttpPost(API_URL);
            httpPost.setHeader("Authorization", "Bearer " + API_KEY);
            httpPost.setHeader("Content-Type", "application/json");
            httpPost.setHeader("X-DashScope-SSE", "enable"); // 启用流式输出（可选）
            // 3. 构建请求体
            JSONObject requestBody = new JSONObject();
            requestBody.put("model", "qwen-turbo"); // 模型名称
            JSONObject input = new JSONObject();
            JSONObject message = new JSONObject();
            message.put("role", "user");
            message.put("content", userInput);
            input.put("messages", new Object[]{message});
            JSONObject parameters = new JSONObject();
            parameters.put("result_format", "text"); // 返回纯文本格式
            requestBody.put("input", input);
            requestBody.put("parameters", parameters);
            httpPost.setEntity(new StringEntity(requestBody.toString()));
            // 4. 发送请求并处理响应
            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
                HttpEntity entity = response.getEntity();
                if (entity != null) {
                    String result = EntityUtils.toString(entity);
                    // 5. 解析响应
                    JSONObject jsonResponse = new JSONObject(result);
                    return jsonResponse.getJSONObject("output")
                                      .getString("text");
                }
            }
        }
        return "未收到有效响应";
    }
}

httpPost.setHeader("X-DashScope-SSE", "enable");

# 设置环境变量（Linux/macOS）
export DASHSCOPE_API_KEY=your_api_key
# Windows
set DASHSCOPE_API_KEY=your_api_key

{
  "output": {
    "text": "量子计算是一种利用量子力学原理...",
    "finish_reason": "stop"
  },
  "usage": {
    "input_tokens": 10,
    "output_tokens": 210
  }
}

// 添加流式支持
httpPost.setHeader("X-DashScope-SSE", "enable");

// 处理流式响应
InputStream content = entity.getContent();
try (BufferedReader reader = new BufferedReader(new InputStreamReader(content))) {
    String line;
    while ((line = reader.readLine()) != null) {
        if (line.startsWith("data: ")) {
            String jsonStr = line.substring(6);
            JSONObject data = new JSONObject(jsonStr);
            if (!data.has("output")) continue;
            System.out.print(data.getJSONObject("output")
                                 .getString("text"));
        }
    }
}

if (response.getStatusLine().getStatusCode() != 200) {
    String errorBody = EntityUtils.toString(entity);
    throw new RuntimeException("API调用失败: " + errorBody);
}

RequestConfig config = RequestConfig.custom()
    .setConnectTimeout(30000)
    .setSocketTimeout(60000)
    .build();
httpPost.setConfig(config);