网络编程HttpClient----实现Http访问工具类

Bertha 。 2022-07-13 08:15 202阅读 0赞

HttpClient&Android网络编程----[实现Http访问工具类][Http]

大部分andriod应用需要与服务器进行数据交互，HTTP、FTP、SMTP或者是直接基于SOCKET编程都可以进行数据交互，但是HTTP必然是使用最广泛的协议。

一般的情况下我们都是使用IE或者Navigator浏览器来访问一个WEB服务器，用来浏览页面查看信息或者提交一些数据等等。所访问的这些页面有的仅仅是一些普通的页面，有的需要用户登录后方可使用，或者需要认证以及是一些通过加密方式传输。某些时候需要利用某些站点提供的页面来完成某种功能，例如说我们想知道某个手机号码的归属地而我们自己又没有这样的数据，因此只好借助其他公司已有的网站来完成这个功能，这个时候我们需要向网页提交手机号码并从返回的页面中解析出我们想要的数据来。这个时候就涉及到COOKIE问题的处理。我们知道目前流行的动态网页技术例如ASP、JSP无不是通过COOKIE来处理会话信息的。为了使我们的程序能使用别人所提供的服务页面，就要求程序首先登录后再访问服务页面，这过程就需要自行处理cookie，可以应用HttpClient来对付各种顽固的WEB服务器。httpclient项目就是专门设计来简化HTTP客户端与服务器进行各种通讯编程。

本文并不针对HTTP协议的具体内容，仅探讨android开发中使用HTTP协议访问网络的两种方式—— HttpURLConnection 和 HttpClient 。

1、标准[**Java**][Java]接口(java[**.NET**][.NET]) ----HttpURLConnection，可以实现简单的基于URL请求、响应功能；

2、Apache接口(org.appache.http)----HttpClient，使用起来更方面更强大。一般来说，用这种接口。但它它是基于第一种底层实现的。HttpClient相比传统JDK自带的URLConnection，增加了易用性和灵活性；它是ApacheJakarta Common下的子项目，用来提供高效的、最新的、功能丰富的支持HTTP协议的客户端编程工具包，并且它支持HTTP协议最新的版本和建议。

### URL请求的类别:  ###

分为两类,GET与POST请求。二者的区别在于：    
  1 、 get请求可以获取静态页面，也可以把参数放在URL字串后面，传递给servlet，    
  2 、post与get的不同之处在于post的参数不是放在URL字串里面，而是放在http请求的正文内。

### HttpClient的使用 ###

使用HttpClient发送请求、接收响应很简单，一般需要如下几步即可。

1.创建HttpClient对象。

2.创建请求方法的实例，并指定请求URL。如果需要发送GET请求，创建HttpGet对象；如果需要发送POST请求，创建HttpPost对象。

3.如果需要发送请求参数，可调用HttpGet、HttpPost共同的setParams(HetpParams params)方法来添加请求参数；对于HttpPost对象而言，也可调用setEntity(HttpEntityentity)方法来设置请求参数。

4.调用HttpClient对象的execute(HttpUriRequest request)发送请求，该方法返回一个HttpResponse。

5.调用HttpResponse的getAllHeaders()、getHeaders(String name)等方法可获取服务器的响应头；调用HttpResponse的getEntity()方法可获取HttpEntity对象，该对象包装了服务器的响应内容。程序可通过该对象获取服务器的响应内容。

6.释放连接。无论执行方法是否成功，都必须释放连接。

HttpClient:是一个接口

首先需要先创建一个DefaultHttpClient的实例

HttpClienthttpClient=new DefaultHttpClient();这也是最简单的方式。当然Apache也提供了PoolingHttpClientConnectionManager，允许我们创建HttpClient连接池，使得HttpClient用时不是每次都new一个，而是直接从配置好的HttpClient连接池取一个，这个是不是很强大，具体可参考[http://blog.csdn.net/hwwzyh/article/details/39184677][http_blog.csdn.net_hwwzyh_article_details_39184677]。

### 实例--Http访问工具类 ###

public class HttpUtil {
        private static PoolingHttpClientConnectionManagernManager cm;
        private static String EMPTY_STR = "";
        private static String UTF_8 = "UTF-8";
    
        private static void init() {
            if (cm == null) {
                cm = new PoolingHttpClientConnectionManager();
                cm.setMaxTotal(50);// 整个连接池最大连接数
                cm.setDefaultMaxPerRoute(5);// 每路由最大连接数，默认值是2
            }
        }
    
        /**
         * 通过连接池获取HttpClient。需要用到HttpClient的地方调用此方法即可
         */
        private static CloseableHttpClient getHttpClient() {
            init();
            return HttpClients.custom().setConnectionManager(cm).build();
        }
    
        /**
         * HttpClient连接SSL
         */
        public void ssl() {
            CloseableHttpClient httpclient = null;
            try {
                KeyStore trustStore = KeyStore.getInstance(KeyStore.getDefaultType());
                FileInputStream instream = new FileInputStream(new File("d:\\tomcat.keystore"));
                try {
                    // 加载keyStore d:\\tomcat.keystore
                    trustStore.load(instream, "123456".toCharArray());
                } catch (CertificateException e) {
                    e.printStackTrace();
                } finally {
                    try {
                        instream.close();
                    } catch (Exception ignore) {
                    }
                }
                // 相信自己的CA和所有自签名的证书
                SSLContext sslcontext = SSLContexts.custom().loadTrustMaterial(trustStore, new TrustSelfSignedStrategy()).build();
                // 只允许使用TLSv1协议
                SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(sslcontext, new String[] { "TLSv1" }, null,
                        SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
                httpclient = HttpClients.custom().setSSLSocketFactory(sslsf).build();
                // 创建http请求(get方式)
                HttpGet httpget = new HttpGet("https://localhost:8443/myDemo/Ajax/serivceJ.action");
                System.out.println("executing request" + httpget.getRequestLine());
                CloseableHttpResponse response = httpclient.execute(httpget);
                try {
                    HttpEntity entity = response.getEntity();
                    System.out.println("----------------------------------------");
                    System.out.println(response.getStatusLine());
                    if (entity != null) {
                        System.out.println("Response content length: " + entity.getContentLength());
                        System.out.println(EntityUtils.toString(entity));
                        EntityUtils.consume(entity);
                    }
                } finally {
                    response.close();
                }
            } catch (ParseException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (KeyManagementException e) {
                e.printStackTrace();
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            } catch (KeyStoreException e) {
                e.printStackTrace();
            } finally {
                if (httpclient != null) {
                    try {
                        httpclient.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    
        /**
         * post方式提交表单（模拟用户登录请求）
         */
        public void postForm() {
            // 创建默认的httpClient实例.
            CloseableHttpClient httpclient = HttpClients.createDefault();
            // 创建httppost
            HttpPost httppost = new HttpPost("http://localhost:8080/myDemo/Ajax/serivceJ.action");
            // 创建参数队列
            List<namevaluepair> formparams = new ArrayList<namevaluepair>();
            formparams.add(new BasicNameValuePair("username", "admin"));
            formparams.add(new BasicNameValuePair("password", "123456"));
            UrlEncodedFormEntity uefEntity;
            try {
                uefEntity = new UrlEncodedFormEntity(formparams, "UTF-8");
                httppost.setEntity(uefEntity);
                System.out.println("executing request " + httppost.getURI());
                CloseableHttpResponse response = httpclient.execute(httppost);
                try {
                    HttpEntity entity = response.getEntity();
                    if (entity != null) {
                        System.out.println("--------------------------------------");
                        System.out.println("Response content: " + EntityUtils.toString(entity, "UTF-8"));
                        System.out.println("--------------------------------------");
                    }
                } finally {
                    response.close();
                }
            } catch (ClientProtocolException e) {
                e.printStackTrace();
            } catch (UnsupportedEncodingException e1) {
                e1.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 关闭连接,释放资源
                try {
                    httpclient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    
        /**
         * 发送 get请求
         */
        public void get() {
            CloseableHttpClient httpclient = HttpClients.createDefault();
            try {
                // 创建httpget.
                HttpGet httpget = new HttpGet("http://www.baidu.com/");
                System.out.println("executing request " + httpget.getURI());
                // 执行get请求.
                CloseableHttpResponse response = httpclient.execute(httpget);
                try {
                    // 获取响应实体
                    HttpEntity entity = response.getEntity();
                    System.out.println("--------------------------------------");
                    // 打印响应状态
                    System.out.println(response.getStatusLine());
                    if (entity != null) {
                        // 打印响应内容长度
                        System.out.println("Response content length: " + entity.getContentLength());
                        // 打印响应内容
                        System.out.println("Response content: " + EntityUtils.toString(entity));
                    }
                    System.out.println("------------------------------------");
                } finally {
                    response.close();
                }
            } catch (ClientProtocolException e) {
                e.printStackTrace();
            } catch (ParseException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                // 关闭连接,释放资源
                try {
                    httpclient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    
        /**
         * 上传文件
         */
        public void upload() {
            CloseableHttpClient httpclient = HttpClients.createDefault();
            try {
                HttpPost httppost = new HttpPost("http://localhost:8080/myDemo/Ajax/serivceFile.action");
    
                FileBody bin = new FileBody(new File("F:\\image\\sendpix0.jpg"));
                StringBody comment = new StringBody("A binary file of some kind", ContentType.TEXT_PLAIN);
    
                HttpEntity reqEntity = MultipartEntityBuilder.create().addPart("bin", bin).addPart("comment", comment).build();
    
                httppost.setEntity(reqEntity);
    
                System.out.println("executing request " + httppost.getRequestLine());
                CloseableHttpResponse response = httpclient.execute(httppost);
                try {
                    System.out.println("----------------------------------------");
                    System.out.println(response.getStatusLine());
                    HttpEntity resEntity = response.getEntity();
                    if (resEntity != null) {
                        System.out.println("Response content length: " + resEntity.getContentLength());
                    }
                    EntityUtils.consume(resEntity);
                } finally {
                    response.close();
                }
            } catch (ClientProtocolException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                try {
                    httpclient.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    
    
    }

### 多线程模式下使用 ###

多线程同时访问httpclient，例如同时从一个站点上下载多个文件。对于同一个HttpConnection同一个时间只能有一个线程访问，为了保证多线程工作环境下不产生冲突，httpclient使用了一个多线程连接管理器的类：MultiThreadedHttpConnectionManager，要使用这个类很简单，只需要在构造HttpClient实例的时候传入即可，代码如下：

MultiThreadedHttpConnectionManager connectionManager = new MultiThreadedHttpConnectionManager();
    HttpClient client = new HttpClient(connectionManager);//以后尽管在需要的时候，使用client实例即可。

注意：Android 6.0(API23)版本的SDK已将Apache HttpClient相关类移除，解决办法自行GOOGLE，推荐使用HTTPURLConnection。若还需使用该类，点击查看[解决办法][Link 1]。

[Http]: http://blog.csdn.net/wangnan537/article/details/50374061
[Java]: http://lib.csdn.net/base/javase
[.NET]: http://lib.csdn.net/base/dotnet
[http_blog.csdn.net_hwwzyh_article_details_39184677]: http://blog.csdn.net/hwwzyh/article/details/39184677
[Link 1]: http://blog.csdn.net/yangqingqo/article/details/48214865