使用Java和Apache HttpClient进行HTTP POST请求示例

在Java应用程序中，使用Apache HttpClient库进行HTTP POST请求是非常常见和有用的。本文将展示如何使用Apache HttpClient库发送带有JSON数据的POST请求，并处理返回的响应。

1. 引言

在现代软件开发中，与外部API进行通信是非常普遍的需求。本文将展示一个场景：如何使用Java编写代码，向一个API发送包含JSON数据的POST请求，并处理返回的响应数据。

2. 准备工作

确保你的开发环境中包含以下依赖：

Apache HttpClient库（版本4.5.7）
JSON处理库，例如阿里巴巴的FastJSON和Jackson ObjectMapper
在Maven项目中，可以通过以下方式引入Apache HttpClient库的依赖：

<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.7</version>
</dependency>

3. 示例代码解析

以下是一个示例代码，演示了如何使用Apache HttpClient发送HTTP POST请求，并处理返回的响应数据。

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.http.Header;
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.message.BasicHeader;
import org.apache.http.util.EntityUtils;
import java.util.LinkedHashMap;
import java.util.Map;

public class HttpClientExample {

    public static void main(String[] args) {
        // 准备请求体数据
        Map<String, Object> body = new LinkedHashMap<>();
        body.put("id", "123456");
        body.put("code", "CODE123");
        body.put("total", 10); // 示例：设置请求体中的total字段为商品数量
        ArrayList<Object> goodsList = new ArrayList<>();
        body.put("goods", goodsList); 

        // 生成当前时间戳
        String timestamp = String.valueOf(System.currentTimeMillis());
        // 将请求体数据转换为JSON格式的字符串
        String bodyStr = JSON.toJSONString(body, SerializerFeature.WriteMapNullValue);
        // 获取访问令牌
        String accessToken = getAccessToken();

        // 检查访问令牌是否获取成功
        if (accessToken == null) {
            System.out.println("获取accessToken失败");
            return;
        }

        // 生成随机数
        String randomNumber = createRandomNumber();
        
        // 假设appSecret是从配置中获取的应用密钥
        String appSecret = "your_app_secret"; 

        // 生成签名
        String sign = getSign(bodyStr, timestamp, accessToken, randomNumber, appSecret);

        // 创建请求头
        Header[] headers = new Header[]{
                new BasicHeader("Content-Type", "application/json"), // 设置Content-Type为JSON格式
                new BasicHeader("sign", sign), // 设置签名字段
                new BasicHeader("timestamp", timestamp), // 设置时间戳字段
                new BasicHeader("token", accessToken), // 设置访问令牌字段
                new BasicHeader("randomNumber", randomNumber) // 设置随机数字段
        };

        // 创建请求体
        StringEntity requestBody = new StringEntity(bodyStr, "UTF-8");

        // 假设config是从配置文件中获取的API接口URL
        String url = "your_api_url";

        // 创建HTTP客户端
        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            // 创建POST请求对象，并指定URL
            HttpPost httpPost = new HttpPost(url);
            // 设置请求体
            httpPost.setEntity(requestBody);
            // 设置请求头
            httpPost.setHeaders(headers);

            // 打印日志信息方便调试
            System.out.println("请求头信息: " + JSON.toJSONString(headers));
            System.out.println("请求体信息: " + bodyStr);
            System.out.println("请求URL: " + url);

            // 执行HTTP POST请求
            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
                // 判断HTTP响应状态码是否为200
                if (response.getStatusLine().getStatusCode() == 200) {
                    // 获取响应实体
                    HttpEntity responseEntity = response.getEntity();
                    String responseBody = EntityUtils.toString(responseEntity);
                    System.out.println("响应体信息: " + responseBody);

                    // 解析响应JSON数据到Map
                    ObjectMapper mapper = new ObjectMapper();
                    Map<String, Object> responseData = mapper.readValue(responseBody, Map.class);
                    String msg = (String) responseData.get("msg");
                    Integer code = (Integer) responseData.get("code");
                    System.out.println("响应消息: " + msg + ", 状态码: " + code);
                } else {
                    // 处理HTTP请求失败的情况
                    String code = String.valueOf(response.getStatusLine().getStatusCode());
                    String msg = response.getStatusLine().getReasonPhrase();
                    System.out.println("请求失败, 状态码: " + code + ", 原因: " + msg);
                }
            } catch (Exception e) {
                // 记录异常情况
                System.err.println("HTTP POST请求异常: " + e.getMessage());
            }
        } catch (Exception e) {
            // 记录异常情况
            System.err.println("创建HTTP客户端异常: " + e.getMessage());
        }
    }

    // 示例方法：获取访问令牌
    private static String getAccessToken() {
        // 实际场景中的具体实现
        return "your_access_token";
    }

    // 示例方法：生成随机数
    private static String createRandomNumber() {
        // 实际场景中的具体实现
        return "random_number";
    }

    // 示例方法：生成签名
    private static String getSign(String body, String timestamp, String accessToken, String randomNumber, String appSecret) {
        // 实际场景中的具体实现
        return "generated_sign";
    }
}