添加httpget/post请求类

pom.xml

@@ -120,22 +120,6 @@
             <artifactId>mybatis-dynamic-sql</artifactId>
             <version>1.1.4</version>
         </dependency>
-
-		<dependency>
-            <groupId>org.apache.httpcomponents</groupId>
-            <artifactId>httpcore</artifactId>
-            <version>4.0.1</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.httpcomponents</groupId>
-            <artifactId>httpclient</artifactId>
-            <version>4.5.14</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.httpcomponents</groupId>
-            <artifactId>httpmime</artifactId>
-            <version>4.5.2</version>
-        </dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/kxs/adminap/controller/DesController.java

@@ -1,9 +1,14 @@
 package com.kxs.adminap.controller;
 
+import java.io.IOException;
+
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import com.kxs.adminap.util.DesUtil;
+import com.kxs.adminap.util.HttpRestUtils;
 
 
 @RestController
@@ -12,13 +17,25 @@ public class DesController {
 
 	@RequestMapping("/des")
 	public String des() {
-		String req = "";
-		try {
-			req = DesUtil.encrypt("{\"UserId\":12}");
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
+		String value = DesUtil.encrypt("{\"UserId\":5438}");
+		//发送请求
+		// try {
+		// 	String content = HttpClientOriginUtil.doGet("https://ap.yunmic.com/api/v1/users/querybalance?value=" + value);
+		// 	//解析返回结果
+		// 	JSONObject jsonObject = JSONObject.parseObject(content);
+		// 	Integer status = (Integer) jsonObject.get("status");
+
+		// 	if(status == 1) {
+		// 		JSONObject obj = jsonObject.getJSONObject("data");
+		// 	}
+		// } catch (Exception e) {
+		// 	e.printStackTrace();
+		// }
+		String content = "";
+		MultiValueMap<String, String> param = new LinkedMultiValueMap<String, String>();
+		param.add("value", value);
+		content = HttpRestUtils.post("https://ap.yunmic.com/api/v1/users/querybalance", param);
 		
-		return "ok";
+		return content;
 	}
 }

src/main/java/com/kxs/adminap/util/DesUtil.java

@@ -35,7 +35,7 @@ public class DesUtil {
 
         return result;
     }
-    public static String encrypt(String str) throws Exception {
+    public static String encrypt(String str) {
         String result = "";
         try {
             result = encrypt(str, Des.key, Des.iv);

src/main/java/com/kxs/adminap/util/HttpClientOriginUtil.java

@@ -1,379 +0,0 @@
-package com.kxs.adminap.util;
-
-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.*;
-import org.apache.http.client.utils.URIBuilder;
-import org.apache.http.entity.StringEntity;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClientBuilder;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.message.BasicNameValuePair;
-import org.apache.http.util.EntityUtils;
-
-import java.io.IOException;
-import java.io.UnsupportedEncodingException;
-import java.nio.charset.StandardCharsets;
-import java.util.*;
-
-import static org.springframework.http.MediaType.APPLICATION_JSON_UTF8_VALUE;
-import static org.springframework.http.MediaType.APPLICATION_JSON_VALUE;
-
-/**
- * @author yuan dian
- * @date 2018/12/12
- * @time 10:44
- */
-public class HttpClientOriginUtil {
-    // 编码格式。发送编码格式统一用UTF-8
-    private static final String ENCODING = "UTF-8";
-
-    // 设置连接超时时间，单位毫秒。
-    private static final int CONNECT_TIMEOUT = 6000;
-
-    // 请求获取数据的超时时间(即响应时间)，单位毫秒。
-    private static final int SOCKET_TIMEOUT = 6000;
-
-    /**
-     * 发送get请求；不带请求头和请求参数
-     *
-     * @param url 请求地址
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doGet(String url) throws Exception {
-        return doGet(url, null, null);
-    }
-
-    /**
-     * 发送get请求；带请求参数
-     *
-     * @param url    请求地址
-     * @param params 请求参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doGet(String url, Map<String, String> params) throws Exception {
-        return doGet(url, null, params);
-    }
-
-    /**
-     * 发送get请求；带请求头和请求参数
-     *
-     * @param url     请求地址
-     * @param headers 请求头集合
-     * @param params  请求参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doGet(String url, Map<String, String> headers, Map<String, String> params) throws Exception {
-        // 创建httpResponse对象
-        CloseableHttpResponse httpResponse = null;
-        // 创建httpClient对象
-        CloseableHttpClient httpClient = null;
-        try {
-            httpClient = HttpClients.createDefault();
-
-            // 创建访问的地址
-            URIBuilder uriBuilder = new URIBuilder(url);
-            if (params != null) {
-                Set<Map.Entry<String, String>> entrySet = params.entrySet();
-                for (Map.Entry<String, String> entry : entrySet) {
-                    uriBuilder.setParameter(entry.getKey(), entry.getValue());
-                }
-            }
-
-            // 创建http对象
-            HttpGet httpGet = new HttpGet(uriBuilder.build());
-            RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT)
-                    .setSocketTimeout(SOCKET_TIMEOUT).build();
-            httpGet.setConfig(requestConfig);
-
-            // 设置请求头
-            packageHeader(headers, httpGet);
-
-           // 执行请求并获得响应结果
-                return getHttpClientResult(httpResponse, httpClient, httpGet);
-        }catch (Exception e){
-
-        }finally {
-            // 释放资源
-            // 释放资源
-
-            if (httpClient != null) {
-                httpClient.close();
-            }
-        }
-        return null;
-    }
-
-    /**
-     * 发送post请求；不带请求头和请求参数
-     *
-     * @param url 请求地址
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPost(String url) throws Exception {
-        return doPost(url, null, null);
-    }
-
-    /**
-     * 发送post请求；带请求参数
-     *
-     * @param url    请求地址
-     * @param params 参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPost(String url, Map<String, String> params) throws Exception {
-        return doPost(url, null, params);
-    }
-
-    /**
-     * 发送post请求；带请求头和请求参数
-     *
-     * @param url     请求地址
-     * @param headers 请求头集合
-     * @param params  请求参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPost(String url, Map<String, String> headers, Map<String, String> params) throws Exception {
-        // 创建httpClient对象
-        // 创建httpResponse对象
-        CloseableHttpResponse httpResponse = null;
-        CloseableHttpClient  httpClient = null;
-       try{
-           httpClient = HttpClients.createDefault();
-
-           // 创建http对象
-           HttpPost httpPost = new HttpPost(url);
-           RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
-           httpPost.setConfig(requestConfig);
-           packageHeader(headers, httpPost);
-
-           // 封装请求参数
-           packageParam(params, httpPost);
-
-
-              // 执行请求并获得响应结果
-           return getHttpClientResult(httpResponse, httpClient, httpPost);
-
-       }catch (Exception e){
-
-       }finally {
-           // 释放资源
-
-
-
-           if (httpClient != null) {
-               httpClient.close();
-           }
-       }
-       return  null;
-    }
-
-    /**
-     * 发送put请求；不带请求参数
-     *
-     * @param url 请求地址
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPut(String url) throws Exception {
-        return doPut(url);
-    }
-
-    /**
-     * 发送put请求；带请求参数
-     *
-     * @param url    请求地址
-     * @param params 参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPut(String url, Map<String, String> params) throws Exception {
-        CloseableHttpClient httpClient =null;
-        CloseableHttpResponse httpResponse = null;
-
-        try{
-            httpClient = HttpClients.createDefault();
-            HttpPut httpPut = new HttpPut(url);
-            RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
-            httpPut.setConfig(requestConfig);
-
-            packageParam(params, httpPut);
-            return getHttpClientResult(httpResponse, httpClient, httpPut);
-        }catch (Exception e){
-        }finally {
-            // 释放资源
-
-
-
-            if (httpClient != null) {
-                httpClient.close();
-            }
-        }
-          return  null;
-
-    }
-
-    /**
-     * 发送delete请求；不带请求参数
-     *
-     * @param url 请求地址
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doDelete(String url) throws Exception {
-        CloseableHttpClient httpClient = HttpClients.createDefault();
-        HttpDelete httpDelete = new HttpDelete(url);
-        RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(CONNECT_TIMEOUT).setSocketTimeout(SOCKET_TIMEOUT).build();
-        httpDelete.setConfig(requestConfig);
-
-        CloseableHttpResponse httpResponse = null;
-        try {
-            return getHttpClientResult(httpResponse, httpClient, httpDelete);
-        } finally {
-            release(httpResponse, httpClient);
-        }
-    }
-
-    /**
-     * 发送delete请求；带请求参数
-     *
-     * @param url    请求地址
-     * @param params 参数集合
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doDelete(String url, Map<String, String> params) throws Exception {
-        if (params == null) {
-            params = new HashMap<>();
-        }
-
-        params.put("_method", "delete");
-        return doPost(url, params);
-    }
-
-    /**
-     * Description: 封装请求头
-     *
-     * @param params
-     * @param httpMethod
-     */
-    private static void packageHeader(Map<String, String> params, HttpRequestBase httpMethod) {
-        // 封装请求头
-        if (params != null) {
-            Set<Map.Entry<String, String>> entrySet = params.entrySet();
-            for (Map.Entry<String, String> entry : entrySet) {
-                // 设置到请求头到HttpRequestBase对象中
-                httpMethod.setHeader(entry.getKey(), entry.getValue());
-            }
-        }
-    }
-
-    /**
-     * Description: 封装请求参数
-     *
-     * @param params
-     * @param httpMethod
-     */
-    private static void packageParam(Map<String, String> params, HttpEntityEnclosingRequestBase httpMethod)
-            throws UnsupportedEncodingException {
-
-        // 封装请求参数
-        if (params != null) {
-            List<NameValuePair> nameValuePairs = new ArrayList<>();
-            Set<Map.Entry<String, String>> entrySet = params.entrySet();
-            for (Map.Entry<String, String> entry : entrySet) {
-                nameValuePairs.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
-            }
-
-            // 设置到请求的http对象中
-            httpMethod.setEntity(new UrlEncodedFormEntity(nameValuePairs, ENCODING));
-        }
-    }
-
-    /**
-     * Description: 获得响应结果
-     *
-     * @param httpResponse
-     * @param httpClient
-     * @param httpMethod
-     * @return
-     * @throws Exception
-     */
-    private static HttpClientResult getHttpClientResult(CloseableHttpResponse httpResponse, CloseableHttpClient
-            httpClient, HttpRequestBase httpMethod) throws Exception {
-
-        // 执行请求
-        try {
-            httpResponse = httpClient.execute(httpMethod);
-
-            // 获取返回结果
-            if (httpResponse != null && httpResponse.getStatusLine() != null) {
-                String content = "";
-                if (httpResponse.getEntity() != null) {
-                    content = EntityUtils.toString(httpResponse.getEntity(), ENCODING);
-                }
-                return new HttpClientResult(httpResponse.getStatusLine().getStatusCode(), content);
-            }
-
-        } catch (Exception e) {
-            throw new Exception();
-        } finally {
-            // 释放资源
-            if (httpResponse != null) {
-                httpResponse.close();
-            }
-
-
-        }
-        return null;
-    }
-
-    /**
-     * Description: 释放资源
-     *
-     * @param httpResponse
-     * @param httpClient
-     * @throws IOException
-     */
-    private static void release(CloseableHttpResponse httpResponse, CloseableHttpClient httpClient) throws IOException {
-        // 释放资源
-        if (httpResponse != null) {
-            httpResponse.close();
-        }
-        if (httpClient != null) {
-            httpClient.close();
-        }
-    }
-
-
-    /**
-     * post请求
-     *
-     * @param url
-     * @param json
-     * @return
-     * @throws Exception
-     */
-    public static HttpClientResult doPost(String url, String json) throws Exception {
-        HttpClientResult httpClientResult;
-        try (CloseableHttpClient httpClient = HttpClientBuilder.create().build();
-             CloseableHttpResponse httpResponse = null) {
-
-            HttpPost httpPost = new HttpPost(url);
-            httpPost.addHeader("Content-type", APPLICATION_JSON_UTF8_VALUE);
-            httpPost.setHeader("Accept", APPLICATION_JSON_VALUE);
-            httpPost.setEntity(new StringEntity(json, StandardCharsets.UTF_8));
-            httpClientResult = getHttpClientResult(httpResponse, httpClient, httpPost);
-        } catch (Exception e) {
-            throw new Exception(e);
-        }
-        return httpClientResult;
-    }
-}

src/main/java/com/kxs/adminap/util/HttpClientResult.java

@@ -1,28 +0,0 @@
-package com.kxs.adminap.util;
-
-public class HttpClientResult {
-    /**
-     * 响应状态码
-     */
-    private int code;
-
-    /**
-     * 响应数据
-     */
-    private String content;
-
-
-    HttpClientResult() {
-
-    }
-
-
-    HttpClientResult(int code, String content) {
-        this.code = code;
-        this.content = content;
-    }
-
-    HttpClientResult(int code) {
-        this.code = code;
-    }
-}

src/main/java/com/kxs/adminap/util/HttpRestUtils.java

@@ -0,0 +1,45 @@
+package com.kxs.adminap.util;
+
+import org.springframework.http.*;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.client.RestTemplate;
+
+public class HttpRestUtils {
+
+    /**
+     * http post
+     */
+    public static String post(String url, MultiValueMap<String, String> params) {
+        return httpRestClient(url, HttpMethod.POST, params);
+    }
+
+    /**
+     * http get
+     */
+    public static String get(String url, MultiValueMap<String, String> params) {
+        return httpRestClient(url, HttpMethod.GET, params);
+    }
+
+    /**
+     * HttpMethod post/get
+     */
+    private static String httpRestClient(String url, HttpMethod method, MultiValueMap<String, String> params) {
+        try {
+            SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
+            requestFactory.setConnectTimeout(10 * 1000);
+            requestFactory.setReadTimeout(10 * 1000);
+            RestTemplate client = new RestTemplate(requestFactory);
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
+            // headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
+            HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<MultiValueMap<String, String>>(params, headers);
+            // 执行HTTP请求
+            ResponseEntity<String> response = client.exchange(url, HttpMethod.POST, requestEntity, String.class);
+            return response.getBody();
+        } catch (Exception e) {
+            return "";
+        }
+    }
+}