HttpClient之POST、GET

HttpClient之GET、POST

1、概述

    1.1 简述

        Apache的httpComponents 项目是专一于http协议的的java组件。原生的URLConnection和server通讯，表单和文件传送支持很差。因而就有了新的HttpClient，而且在新的httpclient里面加入了以NIO为基础实现的非阻塞的I/O实现。本章内容只设计经常使用的get、post通讯。

    1.2 名词：        

        http请求包括内容: 请求行、请求头、请求体：

        http响应包括内容：响应行、响应头、响应体：

    tips:详细的http协议，请你们自行百度。这里使用的IE9来访问是http://www.sina.com.cn/展现

    1.3 组成模块

            以4.5.1 发布版为准:

        a）httpComponents core

            HttpCore 是一组基础的http通讯组件，能在客服端和服务器之间传送数据。支持：I/O模块：阻塞I/O和非阻塞I/O（以JAVA的NIO为基础）。

        b）httpComponents client

            HttpClient是一个在httpcore的基础实现的以http/1.1 协议设置的http代理。提供了可重复利用的组件：客服端身份验证、地址管理、http链接管理。HttpComponents Client代替了HttpClient 3.x的的使用，建议用户都升级。

        c）httpComponents asynclient

            异步HttpClient是以NIO和httpClient为基础并听从http/1.1协议的代理。在那些须要大量链接、重要数据经过的使用，有很好的表现。

2、实例

    2.1 模版

这个模版是官方提供，全部的Httpclient实现方式都是这样开始
public void FunctionTemplate() throws ClientProtocolException, IOException {
	CloseableHttpClient httpclient = HttpClients.createDefault();    //固定开始
	//请求方式处理：请求类型（get/post）,uri,请求头、参数类型和数据（请求体）
	//HttpGet httpget = new HttpGet("http://localhost/");               
	HttpPost httpget = new HttpPost("http://localhost/");
	//响应处理:响应行
	CloseableHttpResponse response = httpclient.execute(httpget);
	try {
		// 响应数据处理
	} catch (Exception e) {
		// TODO: handle exception
	} finally {
		response.close();
	}
}

    2.2 get请求

1.get的参数传递能够在uri中
//uri处理
public void TestUrl() throws URISyntaxException {
  // get--url:"http://www.google.com/search?hl=en&q=httpclient&btnG=Google+Search&aq=f&oq="
  // 方法一:贴全链接
  // HttpGet httpGet = new
  // HttpGet("http://www.google.com/search?hl=en&q=httpclient&btnG=Google+Search&aq=f&oq=");
  // 方法二：经过URI来组装
  URI uri = new URIBuilder().setScheme("http")// 协议
				.setHost("www.google.com")// 主机
				.setPath("/search")// 路径
				.setParameter("q", "httpclient")// ？后面的参数
				.setParameter("btnG", "Google Search")// ？后面的参数
				.setParameter("aq", "f")// ？后面的参数
				.setParameter("oq", "")// ？后面的参数
				.build();
  HttpGet httpGet = new HttpGet(uri);
}
//处理请求头
	public void requestHeader() throws IOException {
		CloseableHttpClient httpclient = HttpClients.createDefault();// 建立httpclient
		// 请求处理(主要是本身生成的请求头和请求体)
		HttpGet httpget = new HttpGet("http://localhost/");
		// 请求头
		Header header = new BasicHeader("Accpet-Encoiding", "gzip, deflate, sdch");
		httpget.setHeader(header);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httpget);// 响应处理
			// 数据处理
		} catch (Exception e) {
			// TODO: handle exception
		} finally {
			response.close();
		}
	}

    2.3 post请求

1.post发送数据须要用到HttpClient接口的总结

//传送文件
	public void fileEntity() throws IOException {
		CloseableHttpClient httpclient = HttpClients.createDefault();// 建立httpclient
		// 请求处理(主要是本身生成的请求头和请求体)
		HttpPost httpPost = new HttpPost("http://localhost/");
		// 请求头
		Header header = new BasicHeader("Accpet-Encoiding", "gzip, deflate, sdch");
		httpPost.setHeader(header);
		// 文件
		File file = new File("test.txt");
		FileEntity entity = new FileEntity(file, ContentType.create("text/plain", "UTF-8"));
		httpPost.setEntity(entity);
		CloseableHttpResponse response = null;
		try {
			response = httpclient.execute(httpPost);// 响应处理
			// 数据处理
		} catch (Exception e) {
			// TODO: handle exception
		} finally {
			response.close();
		}
	}
	
//传送form数据
	public void formEntity() throws IOException {
		// 建立httpclient
		CloseableHttpClient httpclient = HttpClients.createDefault();
		// 请求处理(主要是本身生成的请求头和请求体)
		HttpPost httpPost = new HttpPost("http://localhost/");
		// 表单
		List<NameValuePair> formparams = new ArrayList<NameValuePair>();
		formparams.add(new BasicNameValuePair("param1", "value1"));
		formparams.add(new BasicNameValuePair("param2", "value2"));
		// 格式化成 param1=value&param2=value2
		UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams);
		// 当请求数据大小不定的时候能够设置chunk为true
		entity.setChunked(true);
		httpPost.setEntity(entity);
		CloseableHttpResponse response = null;
		try {
			// 响应处理
			response = httpclient.execute(httpPost);
			// 数据处理
		} catch (Exception e) {
			// TODO: handle exception
		} finally {
			response.close();
		}
	}

    2.4 response处理

public void testResponseEntity() {
	CloseableHttpClient httpclient = HttpClients.createDefault();
	// 全部的网络传送须要网络协议
	HttpGet httpget = new HttpGet("http://www.baidu.com");
	CloseableHttpResponse response = null;
	try {
	response = httpclient.execute(httpget);
	HttpEntity entity = response.getEntity();
	if (entity != null) {
	    System.out.println(entity.getContentType());
	    // 利用inputstream-->BufferedReader---->string
	    InputStream instream = entity.getContent();
		try {
		String temp = null;
		BufferedReader r = new BufferedReader(new InputStreamReader(instream));
		while ((temp = r.readLine()) != null) {
			System.out.println(temp);
    		}
    		} catch (Exception e) {
    		} finally {
    			instream.close();
    		}
    		}
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			try {
				response.close();
			} catch (IOException e) {
				e.printStackTrace();
			} finally {
				response = null;
			}
		}
	}

    2.5 其它实现

//1.响应行设置，就是
	public void TestResponse() {
		// 响应行参数：Http/1.1 200 ok
		HttpResponse response = new BasicHttpResponse(HttpVersion.HTTP_1_1, HttpStatus.SC_OK, "OK");
		System.out.println(response.getProtocolVersion());// 协议
		System.out.println(response.getStatusLine().getStatusCode());
		System.out.println(response.getStatusLine().getReasonPhrase());
		System.out.println(response.getStatusLine().toString());
	}
//2.头数据处理：key-value(请求/响应是经过h)
	public void TestHeader() {
		// 响应头
		HttpResponse response = new BasicHttpResponse(HttpVersion.HTTP_1_1, HttpStatus.SC_OK, "OK");
		// 响应头
		response.addHeader("Set-Cookie", "c1=a; path=/; domain=localhost");
		response.addHeader("Set-Cookie", "c2=a; path=\"/\"; domain=\"localhost\"");
		// 迭代
		HeaderIterator it = response.headerIterator("Set-Cookie");
		while (it.hasNext()) {
			System.out.println(it.next());
		}
	}
//3. Entity数据处理：
	public void TestEntity() throws ParseException, IOException {
		// 这里是stirng类型
		// content:important message 传送的数据
		// ContentType:数据类型
		StringEntity myEntity = new StringEntity("important message", ContentType.create("text/plain", "UTF-8"));
		System.out.println(myEntity.getContentType());
		System.out.println(myEntity.getContentLength());
		System.out.println(myEntity.getContent());
		System.out.println(EntityUtils.toString(myEntity));
		System.out.println(EntityUtils.toByteArray(myEntity).length);
	}

    2.6 HttpMessage、Header、HttpEntity

        a）HttpMessage接口：HttpGet、HttpPost:

        b）Header接口：实现请求和响应头数据设置(key-value)

        b）HttpEntity接口：实现响应体和请求体。原理都是同样在模型上都是用了策略模式。