HttpPost使用setEntity传递参数传了个寂寞

╰+哭是因爲堅強的太久メ 2024-03-17 20:00 87阅读 0赞

package com.unicom.apartment.util;
    
    import cn.hutool.core.collection.CollectionUtil;
    
    import com.alibaba.fastjson.JSONObject;
    import org.apache.http.HttpEntity;
    import org.apache.http.HttpStatus;
    import org.apache.http.client.ClientProtocolException;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.entity.ContentType;
    import org.apache.http.entity.StringEntity;
    import org.apache.http.entity.mime.HttpMultipartMode;
    import org.apache.http.entity.mime.MultipartEntityBuilder;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.util.EntityUtils;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.UnsupportedEncodingException;
    import java.net.URLEncoder;
    import java.nio.charset.Charset;
    import java.nio.charset.StandardCharsets;
    import java.util.HashMap;
    import java.util.Map;
    
    public class HttpUtils {
        /**
         * post请求
         * @param url  请求地址
         * @param maps 参数字典
         * @param file 文件
         * @return
         */
        public String post(String url, Map<String,Object> maps, File file){
            String requestJson = "";
            CloseableHttpClient httpClient= HttpClients.createDefault();
            HttpPost httpPost=new HttpPost(url);
            MultipartEntityBuilder entityBuilder  = MultipartEntityBuilder.create().setMode(HttpMultipartMode.RFC6532);
            ContentType strContent=ContentType.create("text/plain", Charset.forName("UTF-8"));
            for (Map.Entry<String,Object> item:maps.entrySet()){
                entityBuilder.addTextBody(item.getKey(),item.getValue().toString(),strContent);
            }
            if(file!=null) {
                entityBuilder.addBinaryBody("photoFile", file, ContentType.APPLICATION_ATOM_XML, file.getName());
            }
            HttpEntity reqEntity=entityBuilder.build();
            httpPost.setEntity(reqEntity);
            try(CloseableHttpResponse httpResponse = httpClient.execute(httpPost)){
                int code = httpResponse.getStatusLine().getStatusCode();
                if(code == HttpStatus.SC_OK){
                    HttpEntity httpEntity = httpResponse.getEntity();
    
                    byte[] json= EntityUtils.toByteArray(httpEntity);
                    requestJson = new String(json, "UTF-8");
                    //关闭流
                    EntityUtils.consume(httpEntity);
                    return requestJson;
                }
                else{
    
                }
            } catch (ClientProtocolException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
    
            return requestJson;
    
        }
    
    
        public String post(String url,String jsonPayload){
            String requestJson = "";
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpPost httpPost = new HttpPost(url);
    //        RequestConfig requestConfig = RequestConfig.custom()
    //                .setConnectTimeout(CONNECT_TIME_OUT).setConnectionRequestTimeout(CONNECT_REQ_TIME_OUT)
    //                .setSocketTimeout(SOCKET_TIME_OUT).build();
    //        httpPost.setConfig(requestConfig);
            httpPost.addHeader("Content-type", "application/json; charset=utf-8");
            httpPost.setHeader("Accept", "application/json");
            // 传入的header参数
    //        if (null != headerParamsMap)
    //        {
    //            for (Map.Entry entry : headerParamsMap.entrySet())
    //            {
    //                String key = entry.getKey();
    //                String value = entry.getValue();
    //                httpPost.setHeader(key, value);
    //            }
    //        }
    
            httpPost.setEntity(new StringEntity(jsonPayload, Charset.forName("UTF-8")));
            try
            {
                CloseableHttpResponse httpResponse = httpClient.execute(httpPost);
                HttpEntity httpEntity = httpResponse.getEntity();
                byte[] json= EntityUtils.toByteArray(httpEntity);
                requestJson = new String(json, "UTF-8");
                //关闭流
                EntityUtils.consume(httpEntity);
                // return requestJson;
    
    //            InputStream is = response.getEntity().getContent();
    //            String responseStr = IOUtils.toString(is, "UTF-8");
    //            if (httpResponse.getStatusLine().getStatusCode() != 200 && httpResponse.getStatusLine().getStatusCode() != 201)
    //            {
    //                throw new Exception(requestJson, "SERVICE_POST_ERR");
    //            }
                httpResponse.close();
            }
            catch (IOException e)
            {
                String errorMsg = url + ":httpPostWithJSON connect faild";
                //throwsRouteException(errorMsg, e, "POST_CONNECT_FAILD");
            }
            finally
            {
                try
                {
                    httpClient.close();
                }
                catch (IOException e)
                {
                    String errorMsg = url + ":close  httpClient faild";
                    //throwsRouteException(errorMsg, e, "CLOSE_CONNECT_FAILD");
                }
            }
            return requestJson;
        }
    
    
        public String post(String url,HashMap<String,String> headerParamsMap, String jsonPayload){
            String requestJson = "";
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpPost httpPost = new HttpPost(url);
    //        RequestConfig requestConfig = RequestConfig.custom()
    //                .setConnectTimeout(CONNECT_TIME_OUT).setConnectionRequestTimeout(CONNECT_REQ_TIME_OUT)
    //                .setSocketTimeout(SOCKET_TIME_OUT).build();
    //        httpPost.setConfig(requestConfig);
            httpPost.addHeader("Content-type", "application/json; charset=utf-8");
            httpPost.setHeader("Accept", "application/json");
    //        httpPost.addHeader(headers);
    
    
    
            // 传入的header参数
            if (null != headerParamsMap)
            {
                for (Map.Entry<String,String> entry : headerParamsMap.entrySet())
                {
                    String key = entry.getKey();
                    String value = entry.getValue();
                    httpPost.setHeader(key, value);
                }
            }
    
            httpPost.setEntity(new StringEntity(jsonPayload, Charset.forName("UTF-8")));
            try
            {
                CloseableHttpResponse httpResponse = httpClient.execute(httpPost);
                HttpEntity httpEntity = httpResponse.getEntity();
                byte[] json= EntityUtils.toByteArray(httpEntity);
                requestJson = new String(json, "UTF-8");
                //关闭流
                EntityUtils.consume(httpEntity);
                // return requestJson;
    
    //            InputStream is = response.getEntity().getContent();
    //            String responseStr = IOUtils.toString(is, "UTF-8");
    //            if (httpResponse.getStatusLine().getStatusCode() != 200 && httpResponse.getStatusLine().getStatusCode() != 201)
    //            {
    //                throw new Exception(requestJson, "SERVICE_POST_ERR");
    //            }
                httpResponse.close();
            }
            catch (IOException e)
            {
                String errorMsg = url + ":httpPostWithJSON connect faild";
                //throwsRouteException(errorMsg, e, "POST_CONNECT_FAILD");
            }
            finally
            {
                try
                {
                    httpClient.close();
                }
                catch (IOException e)
                {
                    String errorMsg = url + ":close  httpClient faild";
                    //throwsRouteException(errorMsg, e, "CLOSE_CONNECT_FAILD");
                }
            }
            return requestJson;
        }
    
    
    
        public static HashMap generateHttpHeader(  String appKey, String secretKey, String path,Map<String,String> ext ) {
            String timeStamp = String.valueOf(System.currentTimeMillis());
    //        String sign = SignBuildUtil.buildSign(secretKey, timeStamp, path);
            HashMap hashMap = new HashMap();
    //        hashMap.put(CommonConstant.TIMESTAMP, timeStamp);
    //        hashMap.put(CommonConstant.VERSION, "1.0.0");
    //        hashMap.put(CommonConstant.APP_KEY, appKey);
    //        hashMap.put(CommonConstant.SIGN, sign);
            if(CollectionUtil.isNotEmpty(ext)) {
                ext.forEach((key,val)->hashMap.put(key,val));
            }
          return hashMap;
        }
    
    
    
    
    
        public static void main(String[] args) throws IOException {
    //        String url = "http://localhost:8000/wechatApp/powerBalance/getPowerGenerationCurveData";
    //        JSONObject paramMap = new JSONObject();
    //        paramMap.put("date", "2021-03-08");
            String result = httpRequest(url, "GET", paramMap);
    //        String result = httpRequest(url, "POST", paramMap);
    //        JSONObject resultObject = JSONObject.parseObject(result);
    //        System.out.println(11);
        }
    
        /**
         * 发送http请求
         *
         * @param requestUrl    请求地址
         * @param params        请求参数
         * @param requestMethod 请求方式  POST/GET
         */
        public static String httpRequest(String requestUrl, JSONObject params, String requestMethod) {
            String result = null;
            StringBuilder paramsStr = new StringBuilder();
            params.forEach((key, value) -> {
                try {
                    paramsStr.append(URLEncoder.encode(key, "UTF-8")).append("=").append(URLEncoder.encode(String.valueOf(value), "UTF-8")).append("&");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            });
            if("POST".equals(requestMethod)) {
    
                RequestConfig requestConfig = RequestConfig.custom()
                        .setSocketTimeout(30 * 1000)
                        .setConnectTimeout(30 * 1000)
                        .setConnectionRequestTimeout(30 * 1000)
                        .build();
                HttpPost httpPost = new HttpPost(requestUrl);
                httpPost.setConfig(requestConfig);
                httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
                httpPost.setEntity(new StringEntity(paramsStr.substring(0, paramsStr.length() - 1), StandardCharsets.UTF_8));
    
                try (CloseableHttpClient httpclient = HttpClients.custom().setDefaultRequestConfig(requestConfig).build();
                     CloseableHttpResponse response = httpclient.execute(httpPost)) {
                    HttpEntity entity = response.getEntity();
                    result = EntityUtils.toString(entity, "UTF-8");
                } catch (IOException e) {
                    e.printStackTrace();
                }
    
            } else if("GET".equals(requestMethod)) {
    
                String requestUrlWithParam = requestUrl + "?" + paramsStr.substring(0, paramsStr.length() - 1);
                HttpGet httpGet = new HttpGet(requestUrlWithParam);
                try(CloseableHttpClient httpClient = HttpClients.createDefault();
                    CloseableHttpResponse httpResponse = httpClient.execute(httpGet)) {
                    HttpEntity httpEntity = httpResponse.getEntity();
                    result = EntityUtils.toString(httpEntity, "UTF-8");
                } catch (IOException e) {
                    e.printStackTrace();
                }
    
            }
    
            return result;
        }
    
    
    }

[HttpPost使用setEntity传递参数传了个寂寞\_httppost.setentity\_菜狗小仪的博客-CSDN博客][HttpPost_setEntity_httppost.setentity_-CSDN]

package com.ieslab.wechatapi;
    
    import com.alibaba.fastjson.JSONObject;
    import org.apache.http.HttpEntity;
    import org.apache.http.NameValuePair;
    import org.apache.http.client.config.RequestConfig;
    import org.apache.http.client.entity.UrlEncodedFormEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    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.BasicNameValuePair;
    import org.apache.http.util.EntityUtils;
    
    import java.io.*;
    import java.net.*;
    import java.nio.charset.StandardCharsets;
    import java.util.ArrayList;
    import java.util.List;
    
    /**
     * @description: Http请求工具类
     * @author: yiwenli
     * @create: 2021-04-08 09:32
     **/
    public class HttpRequestUtil {
    
        public static void main(String[] args) throws IOException {
            String url = "http://localhost:8000/wechatApp/powerBalance/getPowerGenerationCurveData";
            JSONObject paramMap = new JSONObject();
            paramMap.put("date", "2021-03-08");
    //        String result = httpRequest(url, "GET", paramMap);
            String result = httpRequest(url, "POST", paramMap);
            JSONObject resultObject = JSONObject.parseObject(result);
            System.out.println(11);
        }
    
    	/**
         * 发送http请求
         * 
         * @param requestUrl    请求地址
         * @param params        请求参数
         * @param requestMethod 请求方式  POST/GET
         */
        public static String httpRequest(String requestUrl, JSONObject params, String requestMethod) {
            String result = null;
            StringBuilder paramsStr = new StringBuilder();
            params.forEach((key, value) -> {
                try {
                    paramsStr.append(URLEncoder.encode(key, "UTF-8")).append("=").append(URLEncoder.encode(String.valueOf(value), "UTF-8")).append("&");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            });
            if("POST".equals(requestMethod)) {
    
                RequestConfig requestConfig = RequestConfig.custom()
                        .setSocketTimeout(30 * 1000)
                        .setConnectTimeout(30 * 1000)
                        .setConnectionRequestTimeout(30 * 1000)
                        .build();
                HttpPost httpPost = new HttpPost(requestUrl);
                httpPost.setConfig(requestConfig);
                httpPost.setHeader("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
                httpPost.setEntity(new StringEntity(paramsStr.substring(0, paramsStr.length() - 1), StandardCharsets.UTF_8));
                
                try (CloseableHttpClient httpclient = HttpClients.custom().setDefaultRequestConfig(requestConfig).build();
                     CloseableHttpResponse response = httpclient.execute(httpPost)) {
                    HttpEntity entity = response.getEntity();
                    result = EntityUtils.toString(entity, "UTF-8");
                } catch (IOException e) {
                    e.printStackTrace();
                }
    
            } else if("GET".equals(requestMethod)) {
    
                String requestUrlWithParam = requestUrl + "?" + paramsStr.substring(0, paramsStr.length() - 1);
                HttpGet httpGet = new HttpGet(requestUrlWithParam);
                try(CloseableHttpClient httpClient = HttpClients.createDefault();
                    CloseableHttpResponse httpResponse = httpClient.execute(httpGet)) {
                    HttpEntity httpEntity = httpResponse.getEntity();
                    result = EntityUtils.toString(httpEntity, "UTF-8");
                } catch (IOException e) {
                    e.printStackTrace();
                }
    
            }
    
            return result;
        }
    
    }

[HttpPost_setEntity_httppost.setentity_-CSDN]: https://blog.csdn.net/ewl0116/article/details/115513180