HttpClient通信

 1 package org.mj.commonsHttpClient;  
 2 
 3 import java.io.IOException;
 4 import java.util.ArrayList;
 5 import java.util.List;
 6 
 7 import org.apache.http.HttpEntity;
 8 import org.apache.http.NameValuePair;
 9 import org.apache.http.client.ClientProtocolException;
10 import org.apache.http.client.entity.UrlEncodedFormEntity;
11 import org.apache.http.client.fluent.Form;
12 import org.apache.http.client.fluent.Request;
13 import org.apache.http.client.methods.CloseableHttpResponse;
14 import org.apache.http.client.methods.HttpGet;
15 import org.apache.http.client.methods.HttpPost;
16 import org.apache.http.impl.client.CloseableHttpClient;
17 import org.apache.http.impl.client.HttpClients;
18 import org.apache.http.message.BasicNameValuePair;
19 import org.apache.http.util.EntityUtils;
20 
21 /** 
22  * @author jing.ming
23  * @version 创建时间：2015年11月26日 上午9:03:06 
24  * 使用最新的httpClient4.5.x
25  */
26 public class HttpClientNewVersion {
27 
28     public static void getMethodTry() throws IOException {
29         CloseableHttpClient httpclient = HttpClients.createDefault();
30         HttpGet httpGet = new HttpGet("http://httpbin.org/get");
31         CloseableHttpResponse response1 = httpclient.execute(httpGet);
32         // The underlying HTTP connection is still held by the response object
33         // to allow the response content to be streamed directly from the
34         // network socket.
35         // In order to ensure correct deallocation of system resources
36         // the user MUST call CloseableHttpResponse#close() from a finally
37         // clause.
38         // Please note that if response content is not fully consumed the
39         // underlying
40         // connection cannot be safely re-used and will be shut down and
41         // discarded
42         // by the connection manager.
43         try {
44             System.out.println(response1.getStatusLine());
45             HttpEntity entity1 = response1.getEntity();
46             // do something useful with the response body
47             // and ensure it is fully consumed
48             EntityUtils.consume(entity1);
49         } finally {
50             response1.close();
51         }
52     }
53 
54     public static void postMethodTry() throws ClientProtocolException, IOException{
55         CloseableHttpClient httpclient = HttpClients.createDefault();
56         HttpPost httpPost = new HttpPost("http://httpbin.org/post");
57         List <NameValuePair> nvps = new ArrayList <NameValuePair>();
58         nvps.add(new BasicNameValuePair("username", "vip"));
59         nvps.add(new BasicNameValuePair("password", "secret"));
60         httpPost.setEntity(new UrlEncodedFormEntity(nvps));
61         CloseableHttpResponse response2 = httpclient.execute(httpPost);
62 
63         try {
64             System.out.println(response2.getStatusLine());
65             HttpEntity entity2 = response2.getEntity();
66             // do something useful with the response body
67             // and ensure it is fully consumed
68             EntityUtils.consume(entity2);
69         } finally {
70             response2.close();
71         }
72     }
73 
74     // fluent API ，更简单的处理方式
75     // The fluent API relieves the user from having to deal with manual
76     // deallocation of system
77     // resources at the cost of having to buffer response content in memory in
78     // some cases.
79     public static void fluentMode() throws ClientProtocolException, IOException {
80         Request.Get("http://targethost/homepage").execute().returnContent();
81         Request.Post("http://targethost/login")
82                 .bodyForm(Form.form().add("username", "vip").add("password", "secret").build())
83                 .execute().returnContent();
84     }
85     
86     public static void main(String[] args) {
87         try {
88             getMethodTry();
89         } catch (ClientProtocolException e) {
90             e.printStackTrace();
91         } catch (IOException e) {
92             e.printStackTrace();
93         }
94     }
95 
96 }
97