增加HTTP工具類

ruoyi-common/pom.xml

@@ -137,6 +137,12 @@
             <version>5.8.5</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>4.5.13</version>
+        </dependency>
+
     </dependencies>
 
 </project>

ruoyi-common/src/main/java/com/ruoyi/common/utils/http/HttpRequest.java

@@ -0,0 +1,172 @@
+package com.ruoyi.common.utils.http;
+
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.HttpEntity;
+import org.apache.http.NameValuePair;
+import org.apache.http.StatusLine;
+import org.apache.http.client.entity.UrlEncodedFormEntity;
+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.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+public class HttpRequest {
+
+    public static String addUrl(String head, String tail) {
+        if (head.endsWith("/")) {
+            if (tail.startsWith("/")) {
+                return head.substring(0, head.length() - 1) + tail;
+            } else {
+                return head + tail;
+            }
+        } else {
+            if (tail.startsWith("/")) {
+                return head + tail;
+            } else {
+                return head + "/" + tail;
+            }
+        }
+    }
+
+    public synchronized static String postData(String url, Map<String, String> params) throws Exception {
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        HttpPost httpPost = new HttpPost(url);
+        //拼接参数
+        List<NameValuePair> nvps = new ArrayList<NameValuePair>();
+
+        NameValuePair[] nameValuePairArray = assembleRequestParams(params);
+        for (NameValuePair value : nameValuePairArray
+        ) {
+            nvps.add(value);
+        }
+
+        httpPost.setEntity(new UrlEncodedFormEntity(nvps, "UTF-8"));
+        CloseableHttpResponse response = httpclient.execute(httpPost);
+        String result = "";
+        try {
+            StatusLine statusLine = response.getStatusLine();
+            HttpEntity entity = response.getEntity();
+            // do something useful with the response body
+            if (entity != null) {
+                result = EntityUtils.toString(entity, "UTF-8");
+            } else {
+                log.error("httpRequest postData1 error entity = null code = " + statusLine.getStatusCode());
+            }
+            // and ensure it is fully consumed
+            //消耗掉response
+            EntityUtils.consume(entity);
+        } finally {
+            response.close();
+        }
+
+        return result;
+    }
+
+    public synchronized static String postData(String url, String Json) throws Exception {
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setHeader("Content-Type", "application/json;charset=UTF-8");
+        StringEntity stringEntity = new StringEntity(Json);
+        stringEntity.setContentType("text/json");
+        httpPost.setEntity(stringEntity);
+        CloseableHttpResponse response = httpclient.execute(httpPost);
+        String result = "";
+        try {
+            StatusLine statusLine = response.getStatusLine();
+            HttpEntity entity = response.getEntity();
+            // do something useful with the response body
+            if (entity != null) {
+                result = EntityUtils.toString(entity, "UTF-8");
+            } else {
+                log.error("httpRequest postData2 error entity = null code = " + statusLine.getStatusCode());
+            }
+            // and ensure it is fully consumed
+            //消耗掉response
+            EntityUtils.consume(entity);
+        } finally {
+            response.close();
+        }
+
+        return result;
+    }
+
+    public synchronized static String postData(String url, String Json, String head) throws Exception {
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        HttpPost httpPost = new HttpPost(url);
+        httpPost.setHeader("Content-Type", "application/json;charset=UTF-8");
+        httpPost.setHeader("token", head);
+        StringEntity stringEntity = new StringEntity(Json);
+        stringEntity.setContentType("text/json");
+        httpPost.setEntity(stringEntity);
+        CloseableHttpResponse response = httpclient.execute(httpPost);
+        String result = "";
+        try {
+            StatusLine statusLine = response.getStatusLine();
+            HttpEntity entity = response.getEntity();
+            // do something useful with the response body
+            if (entity != null) {
+                result = EntityUtils.toString(entity, "UTF-8");
+            } else {
+                log.error("httpRequest postData2 error entity = null code = " + statusLine.getStatusCode());
+            }
+            // and ensure it is fully consumed
+            //消耗掉response
+            EntityUtils.consume(entity);
+        } finally {
+            response.close();
+        }
+
+        return result;
+    }
+
+    public synchronized static String postData(String url) throws Exception {
+        CloseableHttpClient httpclient = HttpClients.createDefault();
+        HttpPost httpPost = new HttpPost(url);
+        CloseableHttpResponse response = httpclient.execute(httpPost);
+        String result = "";
+        try {
+            StatusLine statusLine = response.getStatusLine();
+            HttpEntity entity = response.getEntity();
+            // do something useful with the response body
+            if (entity != null) {
+                result = EntityUtils.toString(entity, "UTF-8");
+            } else {
+                log.error("httpRequest postData2 error entity = null code = " + statusLine.getStatusCode());
+            }
+            // and ensure it is fully consumed
+            //消耗掉response
+            EntityUtils.consume(entity);
+        } finally {
+            response.close();
+        }
+
+        return result;
+    }
+
+    /**
+     * 组装http请求参数
+     *
+     * @return
+     */
+    private synchronized static NameValuePair[] assembleRequestParams(Map<String, String> data) {
+        final List<NameValuePair> nameValueList = new ArrayList<NameValuePair>();
+
+        Iterator<Map.Entry<String, String>> it = data.entrySet().iterator();
+        while (it.hasNext()) {
+            Map.Entry<String, String> entry = (Map.Entry<String, String>) it.next();
+            nameValueList.add(new BasicNameValuePair((String) entry.getKey(), (String) entry.getValue()));
+        }
+
+        return nameValueList.toArray(new NameValuePair[nameValueList.size()]);
+    }
+
+}