利用com.loopj.android.http jar包 发送http请求过程分析
声明:本博客只是为了说明com.loopj.android.http jar包对http请求的实现方式,这个jar包是第三方封装的一个用于android开发的jar包,它是对apach的提供的一些功能的进一步的封装,所以,本博客只可以帮助你理解com.loopj.android.http jar包对http请求的实现,却不能在android基于http协议的应用开发上面给你帮助。所以,本博客的阅读对象是想了解com.loopj.android.http jar包的人,而不是需要实现android http请求的人。
在做项目过程中用到了需要通过android客户端发送http请求的问题,利用com.loopj.android.http jar包可以轻松实现。但是项目完成之后,回过头来,却对其实现的方式不甚了解。于是花了一些时间反编译了他的jar包,得到了请求的具体过程。<以发送GET请求为例>。
一、在工程中建一个控制发送请求的UpdateTask类,继承AsyncTask(为了实现请求的同步或异步发送,且防止在主线程中发送请求<android4.0以上不被允许>),重写doInBackground方法,并将请求的内容写在该方法里面。重写onPostExecute方法。
1
2
3
4
5
6 |
//请求的内容为:<br>/** * url 请求的url * params 需要上传的参数 * responseHandler 可以传WebPage对象 * isAsync 是否异步发送请求 get(String url, RequestParams params, HttpResponseHandler responseHandler, boolean
isAsync) |
二、每次需要发送请求时,只需要new 一个UpdateTask对象,则可以出发其回调方法,执行doInBackground方法,实现请求的发送。
三、新建一个WebPage类继承AsyncHttpResponseHandler,在WebPage里面写上请求的url,请求类型,需要上传的参数(GET请求中为Query String)。
四、目前为止,已经完成了代码的请求的发送,余下的就是get(String url, RequestParams params, HttpResponseHandler responseHandler, boolean isAsync)方法的执行,这个方法在com.loopj.android.http.AndroidHttpClient类中:
1
2
3
4
5
6
7
8
9
10 |
public void get(String url, HttpResponseHandler responseHandler, boolean
isAsync) { get( null , url, null , responseHandler, isAsync); } <span style= "color: rgb(255, 0, 0);" > /**get(null, url, null, responseHandler, isAsync)继续执行,调用下边的get方法*/ </span> public
void get(Context context, String url, RequestParams params, HttpResponseHandler responseHandler, boolean
isAsync) { sendRequest( this .httpClient, this .httpContext, <span style= "color: rgb(255, 0, 0);" > new
HttpGet(getUrlWithQueryString(url, params))</span>, null , responseHandler, context, isAsync); } |
在上面的方法中又调用了3个其他的方法:
1、getUrlWithQueryString(url, params),这个方法的源码不在展示,他是用来组合url的,就是把上传的参数和原来的url组合,得到一个新的目标url,这个url请求服务器响应的内容才是我们想要的。
2、new HttpGet(getUrlWithQueryString(url, params)),这个方法的原型是 public HttpGet(String uri),在org.apache.http.client.methods.HttpGet类中,目的是生成一个请求对象。
3、sendRequest方法,这个方法仍在com.loopj.android.http.AndroidHttpClient类中:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26 |
protected
void sendRequest(DefaultHttpClient client, HttpContext httpContext, HttpUriRequest uriRequest, String contentType, HttpResponseHandler responseHandler, Context context, boolean
isAsync) { if
(contentType != null ) { uriRequest.addHeader( "Content-Type" , contentType); } if
(!isAsync) { <span style= "color: rgb(255, 0, 0);" > new
AsyncHttpRequest(client, httpContext, uriRequest, responseHandler).run(); //同步时,直接发送请求。</span> return ; } Future request = this .threadPool.submit( new
AsyncHttpRequest(client, httpContext, uriRequest, responseHandler)); if
(context != null ) { List requestList = (List) this .requestMap.get(context); if
(requestList == null ) { requestList = new
LinkedList(); this .requestMap.put(context, requestList); } requestList.add( new
WeakReference(request)); } } |
这个方法比较长,但是核心就在红色标注的地方,当然,如果是异步的话,则把这个请求放入线程池中等待发送,当要发送的时候,还是要执行和同步一样的过程,在此只言同步,异步的不在赘述。
五、new AsyncHttpRequest(client, httpContext, uriRequest, responseHandler).run()方法的执行在com.loopj.android.http.AsyncHttpRequest类中。代码如下:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86 |
public <span style= "color: rgb(255, 0, 0);" >AsyncHttpRequest</span>(AbstractHttpClient client, HttpContext context, HttpUriRequest request, HttpResponseHandler responseHandler) { this .client = client; this .context = context; this .request = request; this .responseHandler = responseHandler; if
((responseHandler instanceof
BinaryHttpResponseHandler)) this .isBinaryRequest = true ; } <span style= "color: rgb(255, 0, 0);" > public
void run()</span> { try
{ if
( this .responseHandler != null ) { this .responseHandler.sendStartMessage(); } <span style= "color: rgb(255, 0, 0);" > makeRequestWithRetries();</span> if
( this .responseHandler != null ) this .responseHandler.sendFinishMessage(); } catch
(IOException e) { if
( this .responseHandler != null ) { this .responseHandler.sendFinishMessage(); if
( this .isBinaryRequest) this .responseHandler.sendFailureMessage(e, null ); else this .responseHandler.sendFailureMessage(e, null ); } } } private
void <span style= "color: rgb(255, 0, 0);" > makeRequest()</span> throws
IOException { if
(!Thread.currentThread().isInterrupted()) { <span style= "color: rgb(255, 153, 0);" >HttpResponse response = this .client.execute( this .request, this .context); //发送具体的网络请求,该方法是apach提供的<apach是在android sdk里面提供的方法<br> ,android api文档有具体的介绍在,org.apach.*中>,返回的页面信息在<span style="color: rgb(255, 153, 0);">response 里面</span>。</span> if
((!Thread.currentThread().isInterrupted()) && ( this .responseHandler != null )) this .responseHandler.sendResponseMessage(response); //responseHandler 是 HttpResponseHandler对象,HttpResponseHandler全是抽象方法,需要重载。 } } private
void makeRequestWithRetries() throws
ConnectException { boolean
retry = true ; IOException cause = null ; HttpRequestRetryHandler retryHandler = this .client.getHttpRequestRetryHandler(); while
(retry) { try
{ <span style= "color: rgb(255, 0, 0);" > makeRequest();</span> return ; } catch
(UnknownHostException e) { if
( this .responseHandler != null ) { this .responseHandler.sendFailureMessage(e, "can‘t resolve host" ); } return ; } catch
(SocketException e) { if
( this .responseHandler != null ) { this .responseHandler.sendFailureMessage(e, "can‘t resolve host" ); } return ; } catch
(SocketTimeoutException e) { if
( this .responseHandler != null ) { this .responseHandler.sendFailureMessage(e, "socket time out" ); } return ; } catch
(IOException e) { cause = e; retry = retryHandler.retryRequest(cause, ++ this .executionCount, this .context); } catch
(NullPointerException e) { cause = new
IOException( "NPE in HttpClient"
+ e.getMessage()); retry = retryHandler.retryRequest(cause, ++ this .executionCount, this .context); } } ConnectException ex = new
ConnectException(); ex.initCause(cause); throw
ex; } } |
六、在上面方法的执行中,如果请求发送成功,则会把返回的结果放在response中,然后通过this.responseHandler.sendResponseMessage(response)方法把信息传递出去,上面已经说了,这个方法本身是抽象的,所以必须新建一个类,实现这些方法。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23 |
protected
void sendResponseMessage(HttpResponse response) { StatusLine status = response.getStatusLine(); InputStream responseBody = null ; try
{ responseBody = response.getEntity().getContent(); //得到response里面的主要信息,其实就是我们发送的请求对应的网页的html源码 } catch
(IOException e) { sendFailureMessage(e, (String) null ); } if
(status.getStatusCode() >= 300 ) { onFailure( new
HttpResponseException(status.getStatusCode(), status.getReasonPhrase()), responseBody); } else
{ //对responseBody的信息,即:得到的页面源码进行你想要的处理。 } try
{ responseBody.close(); } catch
(IOException e) { e.printStackTrace(); } } |
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。