Java调用CouchDB Rest接口POST请求返回500错误求助

你的代码存在几个关键问题，导致CouchDB返回500错误，以下是问题分析和修复后的可运行代码：

问题点分析 #

• 字符集拼写错误：代码中两处将UTF-8误写为UFT-8（请求头的Content-Type字段、IOUtils读取流时的编码参数），这会导致CouchDB无法正确解析请求内容，触发服务器内部错误。
• URL认证兼容性问题：直接在URL中拼接Admin:Admin@的认证方式，部分版本的HttpURLConnection可能无法正确处理，建议改用标准的Basic认证请求头。
• 未处理错误响应：当服务器返回500错误时，调用getInputStream()会抛出异常，无法获取服务器返回的具体错误信息，不利于问题排查。

修复后的可运行代码 #

import org.apache.commons.io.IOUtils;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
import java.util.Base64;

public class CouchDBQuery {
    public static void postJson() throws IOException {
        String queryUrl = "http://127.0.0.1:5984/job/_find";
        String json = "{\"selector\": {\"number\": 100100}}";
        String username = "Admin";
        String password = "Admin";

        URL url = new URL(queryUrl);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setConnectTimeout(5000);
        // 修正字符集拼写错误
        conn.setRequestProperty("Content-Type", "application/json; charset=UTF-8");
        // 添加Basic认证头
        String auth = username + ":" + password;
        String encodedAuth = Base64.getEncoder().encodeToString(auth.getBytes(StandardCharsets.UTF_8));
        conn.setRequestProperty("Authorization", "Basic " + encodedAuth);
        
        conn.setDoOutput(true);
        conn.setDoInput(true);
        conn.setRequestMethod("POST");

        // 写入请求体
        try (OutputStream os = conn.getOutputStream()) {
            os.write(json.getBytes(StandardCharsets.UTF_8));
        }

        // 处理响应，先检查响应码
        int responseCode = conn.getResponseCode();
        if (responseCode >= 200 && responseCode < 300) {
            try (BufferedInputStream in = new BufferedInputStream(conn.getInputStream())) {
                String result = IOUtils.toString(in, StandardCharsets.UTF_8);
                System.out.println("查询结果：");
                System.out.println(result);
            }
        } else {
            // 读取错误流获取服务器错误信息
            try (BufferedInputStream errIn = new BufferedInputStream(conn.getErrorStream())) {
                String errorMsg = IOUtils.toString(errIn, StandardCharsets.UTF_8);
                System.out.println("服务器错误响应码：" + responseCode);
                System.out.println("错误信息：");
                System.out.println(errorMsg);
            }
        }

        conn.disconnect();
    }

    public static void main(String[] args) {
        try {
            postJson();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

关键修改说明 #

1. 修正了所有UFT-8为UTF-8，并改用StandardCharsets.UTF_8避免硬编码字符串错误。
2. 添加了标准的Basic认证头，替代URL中的认证信息，兼容性更好。
3. 增加了响应码判断，当返回错误码时读取错误流，方便查看服务器返回的具体错误原因。
4. 使用try-with-resources语法自动关闭流，避免资源泄漏。

内容的提问来源于stack exchange，提问作者Dan