Springboot封装HTTPClient中get,post,json,put请求方法

谁践踏了优雅 2023-09-25 14:01 75阅读 0赞

pom.xml依赖如下

  1. <!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
  2.         <dependency>
  3.             <groupId>org.apache.httpcomponents</groupId>
  4.             <artifactId>httpclient</artifactId>
  5.             <version>4.5.6</version>
  6.         </dependency>
  7.    <!-- https://mvnrepository.com/artifact/com.alibaba/fastjson -->
  8.         <dependency>
  9.             <groupId>com.alibaba</groupId>
  10.             <artifactId>fastjson</artifactId>
  11.             <version>1.2.75</version>
  12.         </dependency>
  13.     <!-- https://mvnrepository.com/artifact/com.jayway.jsonpath/json-path -->
  14.         <dependency>
  15.             <groupId>com.jayway.jsonpath</groupId>
  16.             <artifactId>json-path</artifactId>
  17.             <version>2.4.0</version>
  18.         </dependency>

封装get,post请求，贴代码

  1. public class HttpRequestUtil {
  3.     public static String getRequest(String url, Map<String,String> params){
  5.         String res = "";
  6.         boolean flag = true;
  7.         Set<String> keys = params.keySet();
  8.         for (String key : keys) {
  10.             if (flag){
  12.                 url += "?" + key + "=" + params.get(key);
  13.                 flag = false;
  14.             }else {
  16.                 url += "&" + key + "=" + params.get(key);
  17.             }
  18.         }
  19.         HttpGet httpGet = new HttpGet(url);
  20.         HttpClient httpClient = HttpClients.createDefault();
  22.         try {
  24.             HttpResponse response = httpClient.execute(httpGet);
  25.             res = EntityUtils.toString(response.getEntity());
  26.         } catch (IOException e) {
  28.             e.printStackTrace();
  29.         } finally {
  31.             try {
  33.                 ((CloseableHttpClient) httpClient).close();
  34.             } catch (IOException e) {
  36.                 e.printStackTrace();
  37.             }
  38.         }
  39.         return res;
  40.     }
  42.     public static String postRequest(String url, Map<String,String> params){
  44.         String res = "";
  45.         HttpPost httpPost = new HttpPost(url);
  46.         ArrayList<BasicNameValuePair> basicNameValuePairs = new ArrayList<BasicNameValuePair>();
  48.         // 遍历map，放到basicNameValuePairs中
  49.         Set<String> keys = params.keySet();
  50.         for (String key : keys) {
  52.             basicNameValuePairs.add(new BasicNameValuePair(key,params.get(key)));
  53.         }
  54.         HttpClient httpClient = HttpClients.createDefault();
  55.         try {
  57.             httpPost.setEntity(new UrlEncodedFormEntity(basicNameValuePairs,"utf-8"));
  58.             HttpResponse httpResponse = httpClient.execute(httpPost);
  59.             res = EntityUtils.toString(httpResponse.getEntity());
  60.         } catch (Exception e) {
  62.             e.printStackTrace();
  63.         } finally {
  65.             try {
  67.                 ((CloseableHttpClient) httpClient).close();
  68.             } catch (IOException e) {
  70.                 e.printStackTrace();
  71.             }
  72.         }
  73.         return res;
  74.     }
  76.     public static String sendRequest(String url, String requestType, Map<String, String> parameters){
  78.         String response = "";
  79.         if ("get".equalsIgnoreCase(requestType)){
  81.             response = getRequest(url, parameters);
  82.         }else if ("post".equalsIgnoreCase(requestType)){
  84.             response = postRequest(url, parameters);
  85.         }else {
  87.             response = "error request type!!!";
  88.         }
  89.         return response;
  90.     }
  91. }

封装json,put请求，贴代码

  1. public class HttpRequestJsonUtil {
  4.     // 声明为静态方法
  5.     public static String postRequest(String url, JSONObject jsonObject, JSONObject headers){
  7.         String res = "";
  8.         HttpPost httpPost = new HttpPost(url);
  9.         // 通过形参设置请求头
  10.         Set<String> headerkeys = headers.keySet();
  11.         for (String headerkey : headerkeys) {
  13.             httpPost.addHeader(headerkey.trim(),headers.getString(headerkey).trim());
  14.         }
  15.         // 发送 json 类型数据
  16.         httpPost.setEntity(new StringEntity(jsonObject.toString(),"UTF-8"));
  18.         CloseableHttpClient httpClient = HttpClients.createDefault();
  19.         // 发送请求
  20.         HttpResponse httpResponse = null;
  21.         try {
  23.             httpResponse = httpClient.execute(httpPost);
  24.             res = EntityUtils.toString(httpResponse.getEntity());
  25.         } catch (IOException e) {
  27.             e.printStackTrace();
  28.         } finally {
  30.             try {
  32.                 httpClient.close();
  33.             } catch (IOException e) {
  35.                 e.printStackTrace();
  36.             }
  37.         }
  39.         return res;
  40.     }
  42.     public static String sendRequest(String url, String requestType, JSONObject jsonObject, JSONObject headers){
  44.         String response = "";
  45.         if ("post".equalsIgnoreCase(requestType)){
  47.             response = postRequest(url, jsonObject, headers);
  48.         }else {
  50.             response = "error request type!!!";
  51.         }
  52.         return response;
  53.     }
  54. }

下一章会出很详细的！

发表评论

表情：
评论列表 （有 0 条评论，75人围观）

还没有评论，来说两句吧...

相关阅读