* 一個多線程異步Http連接框架。它可用於Android項目或者一般JAVA項目。

 

## 特點

 

**簡單** Async Http Connection為簡單的Http連接請求而設計,提供POST和GET兩個介面。通過參數和回調介面完成整個Http連接的交互。
**輕量** 純JDK實現,不依賴協力廠商Jar包。
**快速** 採用Executor多線程並發框架,秉承它的並發處理優勢。
**可擴展** 框架提供Invoker擴展,通過實現RequestInvoker可方便的把HttpClient等優秀框架整合到項目中。



## 使用

 

更多例子見源目錄的**[test]**目錄

 

### 簡單的例子

 

//使用Get方法,取得服務端響應流:
AsyncHttpConnection HTTP = AsyncHttpConnection.getInstance();
ParamsWrapper params = ...;
String url = ...
int requestId = HTTP.get(url, null, new ResponseCallback() {

 

@Override
public void onResponse(InputStream response,URL url) {
System.out.println("[test GET] --> response back, url = "+url);
Assert.assertNotNull(response);
requestBack();
}

 

@Override
public void onError(Throwable exp) {
System.err.println("[test GET] --> response error, url = "+url);
requestBack();
}

 

@Override
public void onSubmit(URL url) {
}
});





//使用POST方法,取得服務端響應流:
AsyncHttpConnection HTTP = AsyncHttpConnection.getInstance();
ParamsWrapper params = ...;
String url = ...
int requestId = HTTP.post(url, null, new ResponseCallback() {

 

@Override
public void onResponse(InputStream response,URL url) {
System.out.println("[test POST] --> response back, url = "+url);
Assert.assertNotNull(response);
requestBack();
}

 

@Override
public void onError(Throwable exp) {
System.err.println("[test POST] --> response error, url = "+url);
requestBack();
}

 

@Override
public void onSubmit(URL url) {
}
});




### 更詳細的例子

 

//使用POST方法,取得服務端響應流:
AsyncHttpConnection HTTP = AsyncHttpConnection.getInstance();
final int KEY_VAL = 24;
ParamsWrapper params = new ParamsWrapper();
params.put("firstname", "chen");
params.put("lastname", "yoca");
params.put("foo", KEY_VAL);
params.put("cookiename", KEY_VAL);
params.put("cookievalue", KEY_VAL);
int requestId = HTTP.post(url, params, new StringResponseHandler() {

 

@Override
public void onSubmit(URL url) {
System.out.println(">> target: "+url.getHost()+" --> "+url.getPath());
}

 

@Override
public void onError(Throwable exp) {
requestBack();
exp.printStackTrace();
}

 

@Override
public void onResponse(String content, URL url) {
Assert.assertNotNull(content);
boolean containsKey = content.contains(String.valueOf(KEY_VAL));
Assert.assertEquals(true, containsKey);
requestBack();
}
});





//在大量並發的異步請求情況下,每個請求的回調可能需要一個標識碼來標記這個回調結果。
//有兩種方式來解決這個問題:
// 1、使用get和post返回的RequestID來標識,但這需要對RequestID進行管理
// 2、使用get和post的token參數

 

AsyncHttpConnection HTTP = AsyncHttpConnection.getInstance();
final int KEY_VAL = 24;
ParamsWrapper params = new ParamsWrapper();
params.put("firstname", "chen");
params.put("lastname", "yoca");
params.put("foo", KEY_VAL);
params.put("cookiename", KEY_VAL);
params.put("cookievalue", KEY_VAL);

 

// ******** 利用token 介面 ************
Object token = "1234566";

 

// 如果調用了帶token的方法,回調的方法將是onResponse(String content, URL url, Object token)
int requestId = HTTP.post(url, params, token, new StringResponseHandler() {

 

@Override
public void onSubmit(URL url) {
System.out.println(">> target: "+url.getHost()+" --> "+url.getPath());
}

 

@Override
public void onError(Throwable exp) {
requestBack();
exp.printStackTrace();
}

 

@Override
public void onResponse(String content, URL url, Object token) {
// token == "1234566" Token被傳到這裏作為標識
Assert.assertNotNull(content);
boolean containsKey = content.contains(String.valueOf(KEY_VAL));
Assert.assertEquals(true, containsKey);
requestBack();
}
});
arrow
arrow
    全站熱搜

    戮克 發表在 痞客邦 留言(0) 人氣()