增加http请求功能

pom.xml

@@ -120,6 +120,22 @@
             <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

@@ -0,0 +1,24 @@
+package com.kxs.adminap.controller;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.kxs.adminap.util.DesUtil;
+
+
+@RestController
+public class DesController {
+
+
+	@RequestMapping("/des")
+	public String des() {
+		String req = "";
+		try {
+			req = DesUtil.encrypt("{\"UserId\":12}");
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		
+		return "ok";
+	}
+}

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

@@ -0,0 +1,379 @@
+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

@@ -0,0 +1,28 @@
+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;
+    }
+}