发送http请求工具类

超、凢脫俗 2022-05-29 08:09 427阅读 0赞

import java.io.IOException;
    import java.net.URI;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.http.HttpEntity;
    import org.apache.http.NameValuePair;
    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.ContentType;
    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.BasicHeader;
    import org.apache.http.message.BasicNameValuePair;
    import org.apache.http.util.EntityUtils;
    
    /**
     * Title:      HttpClientUtil
     * @author:    gaodeqiang
     * @date       2018年10月24日
     * @version    V1.0
     * Description: 发送请求的工具类
     */
    public class HttpClientUtil {
    
    	public static String doGet(String url, Map<String, String> param,String token) {
    		// 创建Httpclient对象
    		CloseableHttpClient httpclient = HttpClients.createDefault();
    		CloseableHttpResponse response = null;
    		String resultString = "";
    		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);
    			if(StringUtils.isNotBlank(token)) {				
    				httpGet.setHeader("token", token);
    			}
    			// 执行请求
    			response = httpclient.execute(httpGet);
    			// 判断返回状态是否为200
    			if (response.getStatusLine().getStatusCode() == 200) {
    				resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
    				//inputStream = response.getEntity().getContent();
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				if (response != null) {
    					response.close();
    				}
    				httpclient.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    		return resultString;
    	}
    
    	public static String doGet(String url,String token) {
    		return doGet(url,null,token);
    	}
    
    	public static String doPost(String url, Map<String, String> param,String token) {
    		// 创建Httpclient对象
    		CloseableHttpClient httpClient = HttpClients.createDefault();
    		CloseableHttpResponse response = null;
    		String resultString = "";
    		try {
    			// 创建Http Post请求
    			HttpPost httpPost = new HttpPost(url);
    			if(StringUtils.isNotBlank(token)) {				
    				httpPost.setHeader("token", token);
    			}
    			httpPost.setHeader(new BasicHeader("Content-Type", "application/x-www-form-urlencoded; charset=utf-8"));
    			// 创建参数列表
    			if (param != null) {
    				List<NameValuePair> paramList = new ArrayList<>();
    				for (String key : param.keySet()) {
    					paramList.add(new BasicNameValuePair(key, param.get(key)));
    				}
    				// 模拟表单
    				UrlEncodedFormEntity entity = new UrlEncodedFormEntity(paramList,"utf-8");
    				httpPost.setEntity(entity);
    			}
    			// 执行http请求
    			response = httpClient.execute(httpPost);
    			if (response.getStatusLine().getStatusCode() == 200) {
    				resultString = EntityUtils.toString(response.getEntity(), "UTF-8");
    			}
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				response.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    		return resultString;
    	}
    
    	public static String doPost(String url,String token) {
    		return doPost(url, null,token);
    	}
    
    	public static String doPostJson(String url, String json,String token) {
    		// 创建Httpclient对象
    		CloseableHttpClient httpClient = HttpClients.createDefault();
    		CloseableHttpResponse response = null;
    		String resultString = "";
    		try {
    			// 创建Http Post请求
    			HttpPost httpPost = new HttpPost(url);
    			if(StringUtils.isNotBlank(token)) {				
    				httpPost.setHeader("token",token);
    			}
    			// 创建请求内容
    			StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON);
    			httpPost.setEntity(entity);
    			// 执行http请求
    			response = httpClient.execute(httpPost);
    			resultString = EntityUtils.toString(response.getEntity(), "utf-8");
    		} catch (Exception e) {
    			e.printStackTrace();
    		} finally {
    			try {
    				response.close();
    			} catch (IOException e) {
    				e.printStackTrace();
    			}
    		}
    
    		return resultString;
    	}
    	
    	/**  
    	* @author gaodeqiang
    	* @Description 发送delete请求 
    	* @date 2018年12月26日上午10:35:34
    	*/
    	public static String doDelete(String url,Map<String,String> headers,String encode){    
            if(encode == null){    
                encode = "utf-8";    
            }    
            String content = null;       
            CloseableHttpClient closeableHttpClient = HttpClientBuilder.create().build();     
            HttpDelete httpdelete = new HttpDelete(url);    
            //设置header  
            if (headers != null && headers.size() > 0) {  
                for (Map.Entry<String, String> entry : headers.entrySet()) {  
                    httpdelete.setHeader(entry.getKey(),entry.getValue());  
                }  
            }  
            CloseableHttpResponse httpResponse = null;    
            try {    
                httpResponse = closeableHttpClient.execute(httpdelete);    
                HttpEntity entity = httpResponse.getEntity();    
                content = EntityUtils.toString(entity, encode);           
            } catch (Exception e) {    
                e.printStackTrace();    
            }finally{    
                try {    
                    httpResponse.close();    
                } catch (IOException e) {    
                    e.printStackTrace();    
                }    
            }    
            try {   //关闭连接、释放资源    
                closeableHttpClient.close();    
            } catch (IOException e) {    
                e.printStackTrace();    
            }      
            return content;    
        }    
    }