apache httpclient 4.5 的简单实用

大湖之子

　　1 创建一个 maven 项目


org.apache.httpcomponents
httpclient
4.5.2

　　2. 测试代码如下
package com.iraid.test;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
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.HttpGet;
import org.apache.http.client.methods.HttpPost;
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;
/**
* apache httpclient-4.5 简单使用。
* CloseableHttpClient 此类线程安全，且采用 连接池 管理
* @author wangfeihu
*
*/
public class HttpClientTest {
public static void main(String[] args) throws Exception {
        CloseableHttpClient httpclient = HttpClients.createDefault();
        try {
            HttpGet httpGet = new HttpGet("http://127.0.0.1:8080/greet");
            CloseableHttpResponse response1 = httpclient.execute(httpGet);
            //
            try {
                System.out.println(response1.getStatusLine());
                HttpEntity entity1 = response1.getEntity();
                // 处理响应内容
                InputStream is = entity1.getContent();
                String content = convertStreamToString(is);
                System.out.println(content);
                //关闭流
                EntityUtils.consume(entity1);
            } finally {
                response1.close();
            }
            HttpPost httpPost = new HttpPost("http://127.0.0.1:8080/login");
            List  params = new ArrayList ();
            params.add(new BasicNameValuePair("username", "ryan"));
            params.add(new BasicNameValuePair("password", "secret"));
            httpPost.setEntity(new UrlEncodedFormEntity(params));
            CloseableHttpResponse response2 = httpclient.execute(httpPost);
            try {
                System.out.println(response2.getStatusLine());
                HttpEntity entity2 = response2.getEntity();
                // do something useful with the response body
                // and ensure it is fully consumed
                InputStream is = entity2.getContent();
                String content = convertStreamToString(is);
                System.out.println(content);
                EntityUtils.consume(entity2);
            } finally {
                response2.close();
            }
        } finally {
            httpclient.close();
        }
    }
   public static String convertStreamToString(InputStream is) {      
        BufferedReader reader = new BufferedReader(new InputStreamReader(is));      
        StringBuilder sb = new StringBuilder();      
        String line = null;      
        try {      
            while ((line = reader.readLine()) != null) {  
                sb.append(line + "\n");      
            }      
        } catch (IOException e) {      
            e.printStackTrace();      
        } finally {      
            try {      
                is.close();      
            } catch (IOException e) {      
               e.printStackTrace();      
            }      
        }      
        return sb.toString();      
    }  
}　　

　　3 连接池管理
/**
* 带 htttp 请求连接池
*/
public static void pooling() {
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
// Increase max total connection to 200
cm.setMaxTotal(200);
// Increase default max connection per route to 20
cm.setDefaultMaxPerRoute(20);
// Increase max connections for localhost:80 to 50
HttpHost localhost = new HttpHost("locahost", 80);
cm.setMaxPerRoute(new HttpRoute(localhost), 50);
// 初始化连接
CloseableHttpClient httpClient = HttpClients.custom()
.setConnectionManager(cm).build();
}