HttpClient笔记以及Hutool的HttpUtil

港控/mmm° 2022-09-08 11:51 674阅读 0赞

# 1. HttpClient 的使用 #

*  添加HttpClient依赖

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

*  测试类

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.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    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.HttpClients;
    import org.apache.http.message.BasicNameValuePair;
    import org.apache.http.util.EntityUtils;
    
    import java.io.IOException;
    import java.util.*;
    
    public class HttpUtil { 
    
        public static String get(String url) { 
            String result = "{}";
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpGet httpGet = new HttpGet(url);
            try { 
                CloseableHttpResponse response = httpClient.execute(httpGet);
                StatusLine statusLine = response.getStatusLine();
                int status = statusLine.getStatusCode();
                if(status == 200) { 
                    HttpEntity entity = response.getEntity();
                    result = EntityUtils.toString(entity);
                }
            } catch (IOException e) { 
                e.printStackTrace();
            }
    
            return result;
        }
    
        public static String postKV(String url, Map<String, Object> paramMap) { 
            String result = "{}";
    
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpPost post = new HttpPost(url);
            post.setHeader("Content-Type","");
            List<NameValuePair> params = new ArrayList<>();
    
            Set<Map.Entry<String, Object>> entries = paramMap.entrySet();
            Iterator<Map.Entry<String, Object>> iterator = entries.iterator();
            while (iterator.hasNext()) { 
                Map.Entry<String, Object> entry = iterator.next();
                params.add(new BasicNameValuePair(entry.getKey(),
                        String.valueOf(entry.getValue())));
            }
    
            try { 
                // 设置请求体
                post.setEntity(new UrlEncodedFormEntity(params));
                CloseableHttpResponse response = httpClient.execute(post);
                StatusLine statusLine = response.getStatusLine();
                if(statusLine.getStatusCode() == 200) { 
                    result = EntityUtils.toString(response.getEntity());
                }
            } catch (Exception e) { 
                e.printStackTrace();
            }
    
            return result;
        }
    
        public static String postJson(String url, String json) { 
            String result = "{}";
    
            CloseableHttpClient httpClient = HttpClients.createDefault();
            HttpPost post = new HttpPost(url);
    
            // 参数
            post.setEntity(new StringEntity(json,
                    ContentType.create("application/json", "UTF-8")));
            try { 
                CloseableHttpResponse response = httpClient.execute(post);
                StatusLine statusLine = response.getStatusLine();
                if(statusLine.getStatusCode() == 200) { 
                    result = EntityUtils.toString(response.getEntity(), "UTF-8");
                    System.out.println("result - " + result);
                }
            } catch (IOException e) { 
                e.printStackTrace();
            }
            return result;
        }
    	
    	public static String getWithParams(String url,Map<String,Stirng> paramsMap){ 
    		 CloseableHttpClient httpClient = HttpClients.createDefault();
            URIBuilder uriBuilder = null;
            try { 
                uriBuilder = new URIBuilder(url);
                List<NameValuePair> paramsList = new ArrayList<>();
                paramsMap.foreach((key,val) -> { 
                	paramsList.add(new BasicNameValuePair(key, val));
                });
                //可以加很多参数
                uriBuilder.setParameters(paramsList);
                // url为自定义服务地址
                HttpGet get = new HttpGet(url);
                CloseableHttpResponse httpResponse = httpClient.execute(get);
                if (httpResponse.getStatusLine().getStatusCode() == 0) { 
                    return EntityUtils.toString(httpResponse.getEntity());
                }
            } catch (URISyntaxException e) { 
                e.printStackTrace();
            } catch (ClientProtocolException e) { 
                e.printStackTrace();
            } catch (IOException e) { 
                e.printStackTrace();
            }
    	}
    
    }

# 2. Hutool工具类使用 #

> 首先需要引入hutool 的工具包
> 
>     <dependency>
>        <groupId>cn.hutool</groupId>
>       <artifactId>hutool-all</artifactId>
>       <version>5.7.11</version>
>     </dependency>

package net.lesscoding;
    
    import cn.hutool.http.HttpRequest;
    import cn.hutool.http.HttpUtil;
    
    import java.io.File;
    import java.io.InputStream;
    import java.util.Map;
    
    /** * @author eleven * @date 2021/9/8 20:52 * @apiNote */
    public class HuToolTest { 
        
        public String testSimpleGet(String url){ 
            return HttpUtil.get(url);
        }
        
        public String testSimplePost(String url,String jsonBody){ 
            return HttpUtil.post(url,jsonBody,60);
        }
        
        public String testGet(String url, Map<String,Object> paramsMap){ 
            return HttpRequest.get(url)
                    .header("Content-Type", "application/json")
                    .form(paramsMap)
                    .execute()
                    .body();
        }
        
        public InputStream testPost(String url){ 
            return HttpRequest.post(url)
                    .form("file", new File())
                    .execute()
                    .bodyStream();
        }
    }