HttpClientUtil,基于httpclient-4.5.3

今天药忘吃喽~ 2022-10-12 01:08 164阅读 0赞

# httpclient可以做什么 #

HTTP 和相关协议的低级 Java 组件工具集

# maven引入 #

<dependency>
                <groupId>org.apache.httpcomponents</groupId>
                <artifactId>httpclient</artifactId>
                <version>4.5.3</version>
            </dependency>

# 代码 #

import net.sf.json.JSONObject;
    import org.apache.commons.lang3.StringUtils;
    import org.apache.http.NameValuePair;
    import org.apache.http.client.ClientProtocolException;
    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.HttpDelete;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    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.HttpClients;
    import org.apache.http.message.BasicNameValuePair;
    import org.apache.http.util.EntityUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import java.io.IOException;
    import java.net.URI;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    public class HttpClientUtil { 
    
        private static Logger log = LoggerFactory.getLogger(HttpClientUtil.class);
    
        private HttpClientUtil() { 
        }
    
        private static RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(5000).setConnectionRequestTimeout(1000)
                .setSocketTimeout(60000).build();
    
        public static String doGet(String url, Map<String, String> param) { 
    
            // 创建Httpclient对象
            CloseableHttpClient httpclient = HttpClients.createDefault();
    
            String resultString = null;
            CloseableHttpResponse response = null;
            try { 
                // 创建uri
                URIBuilder builder = new URIBuilder(url);
                if (param != null) { 
                    for (String key : param.keySet()) { 
                        builder.addParameter(key, param.get(key));
                    }
                }
                URI uri = builder.build();
    
                // 创建http GET请求
                HttpGet httpGet = new HttpGet(uri);
                httpGet.setConfig(requestConfig);
                // 执行请求
                response = httpclient.execute(httpGet);
                // 判断返回状态是否为200
                if (response.getStatusLine().getStatusCode() == 200) { 
                    resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
                }
            } catch (Exception e) { 
                log.error(e.getMessage(), e);
            } finally { 
                try { 
                    if (response != null) { 
                        response.close();
                    }
                    httpclient.close();
                } catch (IOException e) { 
                    log.error(e.getMessage(), e);
                }
            }
            return resultString;
        }
    
        public static String doGet(String url) { 
            return doGet(url, null);
        }
    
        public static String doPost(String url, Map<String, Object> param) { 
            // 创建Httpclient对象
            CloseableHttpClient httpClient = HttpClients.createDefault();
            CloseableHttpResponse response = null;
            String resultString = "";
            try { 
                // 创建Http Post请求
                HttpPost httpPost = new HttpPost(url);
                httpPost.setConfig(requestConfig);
                // 创建参数列表
                if (param != null) { 
                    List<NameValuePair> paramList = new ArrayList<>();
                    for (String key : param.keySet()) { 
                        paramList.add(new BasicNameValuePair(key, (String) param.get(key)));
                    }
                    // 模拟表单
                    UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList);
                    httpPost.setEntity(entity);
                }
                // 执行http请求
                response = httpClient.execute(httpPost);
                resultString = EntityUtils.toString(response.getEntity(), "utf-8");
            } catch (Exception e) { 
                log.error(e.getMessage(), e);
            } finally { 
                try { 
                    if (response != null) { 
                        response.close();
                    }
                    httpClient.close();
                } catch (IOException e) { 
                    log.error(e.getMessage(), e);
                }
            }
    
            return resultString;
        }
    
        public static void main(String[] args) throws Exception { 
            HashMap hashMap = new HashMap();
            hashMap.put("username", "taoqing7008@aliyun.com");
            hashMap.put("password", "sysadmin");
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("username", "taoqing7008@aliyun.com");
            jsonObject.put("password", "sysadmin");
            System.out.println(doPostJson("http://iot.ahysdz.com:9995/api/auth/login", jsonObject.toString(), null));
        }
    
        public static String doPost(String url) { 
            return doPost(url, null);
        }
    
        public static JSONObject doPostJson(String url, String json, String token_header) throws Exception { 
            // 创建Httpclient对象
            CloseableHttpClient httpClient = HttpClients.createDefault();
            CloseableHttpResponse response = null;
            JSONObject jsonObject = new JSONObject();
            String responseBody = "";
            try { 
                // 创建Http Post请求
                HttpPost httpPost = new HttpPost(url);
                httpPost.setConfig(requestConfig);
                // 创建请求内容
                httpPost.setHeader("Connection", "Keep-Alive");
                httpPost.setHeader("Content-Type", "application/json;charset=utf-8");
                if (StringUtils.isNotEmpty(token_header)) { 
                    httpPost.setHeader("X-Authorization", "Bearer " + token_header);
                }
                StringEntity entity = new StringEntity(json);
                entity.setContentType("application/json;charset=utf-8");
                httpPost.setEntity(entity);
                // 执行http请求
                response = httpClient.execute(httpPost);
                log.info("Executing request {},--> status:{}", url, response.getStatusLine().getStatusCode());
                jsonObject.put("status", response.getStatusLine().getStatusCode());
                jsonObject.put("content", EntityUtils.toString(response.getEntity(), "UTF-8"));
                return jsonObject;
            } catch (Exception e) { 
                log.error(e.getMessage(), e);
                throw e;
            } finally { 
                try { 
                    if (response != null) { 
                        response.close();
                    }
                } catch (IOException e) { 
                    log.error(e.getMessage(), e);
                }
            }
        }
    
        public static JSONObject doDelete(final String url, String token_header) throws Exception { 
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpDelete httpDelete = new HttpDelete(url);
            RequestConfig requestConfig = RequestConfig.custom().setConnectTimeout(35000).setConnectionRequestTimeout(35000).setSocketTimeout(60000).build();
            httpDelete.setConfig(requestConfig);
            JSONObject jsonObject = new JSONObject();
            httpDelete.setHeader("Connection", "Keep-Alive");
            httpDelete.setHeader("Content-Type", "application/json;charset=utf-8");
            if (StringUtils.isNotEmpty(token_header)) { 
                httpDelete.setHeader("X-Authorization", "Bearer " + token_header);
            }
            CloseableHttpResponse httpResponse = null;
            String resultString = null;
            try { 
                log.info("Executing request : " + url);
                httpResponse = httpClient.execute(httpDelete);
                log.info("Executing request {},--> status:{}", url, httpResponse.getStatusLine().getStatusCode());
                jsonObject.put("status", httpResponse.getStatusLine().getStatusCode());
                jsonObject.put("content", EntityUtils.toString(httpResponse.getEntity(), "UTF-8"));
                return jsonObject;
            } catch (ClientProtocolException e) { 
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) { 
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally { 
                if (httpResponse != null) { 
                    try { 
                        httpResponse.close();
                    } catch (IOException e) { 
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if (null != httpClient) { 
                    try { 
                        httpClient.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
            return null;
        }
    }

# 参考的网站 #

[添加链接描述][Link 1]

# 结束语 #

欢迎有问题及时交流~  
希望对大家的学习有所帮助，也希望大家多多交流，欢迎留言。

[Link 1]: http://hc.apache.org/