自定义HttpClient工具类

小灰灰 2024-03-24 19:08 68阅读 0赞

## 自定义HttpClient工具类 ##

### 简介 ###

*      依赖
        <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.6</version>
        </dependency>

### api ###

*  发送get请求: **doGet(String url);**
 *  发送post请求，传参数json: ***\*doPostJson(String url, String jsonParam);\****

### 源码 ###

*      import java.util.HashMap;
        import java.util.Map;
         
        import org.apache.http.HttpEntity;
        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.protocol.HTTP;
        import org.apache.http.util.EntityUtils;
         
        import com.alibaba.fastjson.JSON;
         
        /* 依赖
        <dependency>
        <groupId>org.apache.httpcomponents</groupId>
        <artifactId>httpclient</artifactId>
        <version>4.5.6</version>
        </dependency>
        */
        public class HttpClientUtils {
        	
        	public static void main(String[] args) {
        		doGet("http://127.0.0.1/test1");
        		
        		Map<String, Object> data = new HashMap<String, Object>();
        		data.put("code", "002");
        		data.put("name", "测试");
        		doPostJson("http://127.0.0.1/test2", Object2String(data));
        		
        	}
        	
        	public static void doPostJson(String url, String jsonParam){
                try {
                    CloseableHttpClient client = null;
                    CloseableHttpResponse response = null;
                    try {
                        HttpPost httpPost = new HttpPost(url);
                        httpPost.setHeader(HTTP.CONTENT_TYPE, "application/json");
                        httpPost.setEntity(new StringEntity(jsonParam, ContentType.create("text/json", "UTF-8")));
                        client = HttpClients.createDefault();
                        response = client.execute(httpPost);
                        int code = response.getStatusLine().getStatusCode();
                        HttpEntity entity = response.getEntity();
                        String result = EntityUtils.toString(entity);
                        System.err.println(code);
                        System.err.println(result);
                    } finally {
                        if (response != null) {
                            response.close();
                        }
                        if (client != null) {
                            client.close();
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
        	}
        	
        	
        	public static void doGet(String url){
                try {
                    CloseableHttpClient client = null;
                    CloseableHttpResponse response = null;
                    try {
                        HttpGet httpGet = new HttpGet(url);
                        client = HttpClients.createDefault();
                        response = client.execute(httpGet);
                        HttpEntity entity = response.getEntity();
                        String result = EntityUtils.toString(entity);
                        int code = response.getStatusLine().getStatusCode();
                        System.err.println(result);
                        System.err.println(code);
                    } finally {
                        if (response != null) {
                            response.close();
                        }
                        if (client != null) {
                            client.close();
                        }
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
        	}
        	
        	/** 将输入参数  转换为json字符串 */
        	public static String Object2String(Object obj){
        //		try {
        //			return new ObjectMapper().writeValueAsString(obj);
        //		} catch (JsonProcessingException e) {
        //			e.printStackTrace();
        //		}
        		
        		return JSON.toJSONString(obj);
        	}
        	
        	
        	//TODO 待解决： 服务端接收后有中文款乱码问题
        //	public static void doPostForm(String url, String formParam){
        //        try {
        //            CloseableHttpClient client = null;
        //            CloseableHttpResponse response = null;
        //            try {
        //                // 创建一个提交数据的容器
        //                List<BasicNameValuePair> parames = new ArrayList<>();
        //                parames.add(new BasicNameValuePair("userId", "001"));
        //                parames.add(new BasicNameValuePair("userName", "测试"));
        //                
        //                HttpPost httpPost = new HttpPost(url);
        //                httpPost.setHeader(HTTP.CONTENT_TYPE, "application/x-www-form-urlencoded;charset=UTF-8");
        //                httpPost.setEntity(new UrlEncodedFormEntity(parames, "UTF-8"));
        //                client = HttpClients.createDefault();
        //                response = client.execute(httpPost);
        //                HttpEntity entity = response.getEntity();
        //                String result = EntityUtils.toString(entity);
        //                System.err.println(result);
        //            } finally {
        //                if (response != null) {
        //                    response.close();
        //                }
        //                if (client != null) {
        //                    client.close();
        //                }
        //            }
        //        } catch (Exception e) {
        //            e.printStackTrace();
        //        }
        //	}
        }
 *