原帖：http://www.cnblogs.com/answer1991/archive/2012/04/22/2464524.html

Android操作UI的方法不是線程安全的，也就是說開發(fā)者自己生成的線程對象是不能去操作UI的，比如在新線程里修改某個TextView，生成某個Toast。

?

? 為了能在處理耗時較長的業(yè)務(wù)、而又要兼顧我們的UI，不得不去新生產(chǎn)一個線程，但是這個線程不能兼顧到UI，能做的是向主線程發(fā)送更新UI的Message，由主線程的消息泵抓取到消息后并處理。

?

? Android也為開發(fā)者封裝了上述解決方案，就是用AsynTask。但是個人感覺這個不太好用，畢竟不同的任務(wù)需要去新編寫AsynTask，而這個AsynTask編寫起來也沒那么方便。還不如直接去實現(xiàn)Runnable接口，用自己的線程池和Handler去實現(xiàn)異步處理，（其實AsynTask就是封裝了一個線程池和一個Handler，有興趣的可以參考我的上一篇介紹AsynTask的博文）。

?

? 現(xiàn)在就來介紹如何自己去實現(xiàn)Android異步處理。

?

? 首先，異步處理需要新的一個線程，在這個線程里放上會阻塞的業(yè)務(wù)，比如HTTP請求。那么我們需要一個線程池來管理自己的線程對象。具體使用java.util.concurrent.ThreadPoolExecutor類，concurrent是jdk 1.5新的一個包，為開發(fā)者提供線程以及和線程有關(guān)的一些機制。聽我的一個同學(xué)說，現(xiàn)在起就不要自己去new Thread()了，這樣會降低性能。我們應(yīng)該為整個應(yīng)用提供僅有的一個ThreadPoolExecutor對象，當(dāng)我們需要新的線程的時候，去那里取。

?

package com.chenjun.utils;import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; /** * 線程池輔助類，整個應(yīng)用程序就只有一個線程池去管理線程。 * 可以設(shè)置核心線程數(shù)、最大線程數(shù)、額外線程空狀態(tài)生存時間，阻塞隊列長度來優(yōu)化線程池。 * 下面的數(shù)據(jù)都是參考Android的AsynTask里的數(shù)據(jù)。 * @author zet * */ public class ThreadPoolUtils { private ThreadPoolUtils(){ } //線程池核心線程數(shù) private static int CORE_POOL_SIZE = 5; //線程池最大線程數(shù) private static int MAX_POOL_SIZE = 100; //額外線程空狀態(tài)生存時間 private static int KEEP_ALIVE_TIME = 10000; //阻塞隊列。當(dāng)核心線程都被占用，且阻塞隊列已滿的情況下，才會開啟額外線程。 private static BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<Runnable>( 10); //線程工廠 private static ThreadFactory threadFactory = new ThreadFactory() { private final AtomicInteger integer = new AtomicInteger(); @Override public Thread newThread(Runnable r) { return new Thread(r, "myThreadPool thread:" + integer.getAndIncrement()); } }; //線程池 private static ThreadPoolExecutor threadPool; static { threadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAX_POOL_SIZE, KEEP_ALIVE_TIME, TimeUnit.SECONDS, workQueue, threadFactory); } /** * 從線程池中抽取線程，執(zhí)行指定的Runnable對象 * @param runnable */ public static void execute(Runnable runnable){ threadPool.execute(runnable); } }

?

? ?有了線程池之后，我們就只要編寫自己的Runnable（或者是Callable）去實現(xiàn)業(yè)務(wù)，然后交給線程池讓它分配線程并完成業(yè)務(wù)。

?

? ?這里的業(yè)務(wù)以Android的HTTP下載為例。

?

? ?對于Android的HTTP服務(wù)，我們的整個應(yīng)用程序也只需要一個HttpClient對象，可以生成一個線程安全的HttpClient，這個HttpClient可以為我們多個HttpGet、HttpPost提供服務(wù)。具體代碼如下：

?

package com.chenjun.network.http;import org.apache.http.HttpVersion; import org.apache.http.client.HttpClient; import org.apache.http.conn.ClientConnectionManager; import org.apache.http.conn.params.ConnManagerParams; import org.apache.http.conn.scheme.PlainSocketFactory; import org.apache.http.conn.scheme.Scheme; import org.apache.http.conn.scheme.SchemeRegistry; import org.apache.http.conn.ssl.SSLSocketFactory; import org.apache.http.impl.client.DefaultHttpClient; import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager; import org.apache.http.params.BasicHttpParams; import org.apache.http.params.HttpConnectionParams; import org.apache.http.params.HttpParams; import org.apache.http.params.HttpProtocolParams; import org.apache.http.protocol.HTTP; /** * 輔助類，為整個應(yīng)用程序提供唯一的一個HttpClient對象。 * 這個對象有一些初始化的屬性連接屬性，這些屬性可以被HttpGet、HttpPost的屬性覆蓋 * @author zet * */ public class HttpClientHelper { private static HttpClient httpClient; private HttpClientHelper(){ } public static synchronized HttpClient getHttpClient(){ if(null == httpClient){ //初始化工作 HttpParams params = new BasicHttpParams(); HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1); HttpProtocolParams.setContentCharset(params, HTTP.DEFAULT_CONTENT_CHARSET); HttpProtocolParams.setUseExpectContinue(params, true); //設(shè)置連接管理器的超時 ConnManagerParams.setTimeout(params, 1000); //設(shè)置連接超時 HttpConnectionParams.setConnectionTimeout(params, 5000); //設(shè)置Socket超時 HttpConnectionParams.setSoTimeout(params, 10000); SchemeRegistry schReg = new SchemeRegistry(); schReg.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), 80)); schReg.register(new Scheme("https", SSLSocketFactory.getSocketFactory(), 80)); ClientConnectionManager conManager = new ThreadSafeClientConnManager(params, schReg); httpClient = new DefaultHttpClient(conManager, params); } return httpClient; } }

?

? ?這個HttpClient有一些初始化配置的屬性，如果HttpGet和HttpPost沒有設(shè)定特定的屬性，那么生成的HttpGet和 HttpPost會沿用HttpClient的初始化屬性。但是我們可以根據(jù)不同的情況，為HttpGet和HttpPost設(shè)置屬性，這些屬性將覆蓋掉 HttpClient的初始化屬性，這樣，我們得到的HttpGet和HttpPost就有特定的屬性了。

? ?

? ?具備以上的一些內(nèi)容，我們就可以在自己的Activity里去實現(xiàn)一個Runnable和Handler即可。在Runnable里完成我們的業(yè)務(wù)邏 輯，并適時的發(fā)送Message給Handler來更新UI，在Handler里處理Message并和UI交互。實例代碼：

?

package com.chenjun.httpdemo;import org.apache.http.HttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.params.BasicHttpParams; import org.apache.http.params.HttpConnectionParams; import org.apache.http.params.HttpParams; import org.apache.http.util.EntityUtils; import android.app.Activity; import android.os.Bundle; import android.os.Handler; import android.os.Message; import android.view.View; import android.widget.Toast; import com.chenjun.asynctask.DownloadImageTask; import com.chenjun.network.http.HttpClientHelper; import com.chenjun.utils.ThreadPoolUtils; public class HttpDemoActivity extends Activity { private static final int START_DOWNLOAD_MESSAGE = 0x01; private static final int FINISH_DOWNLOAD_MESSAGE = 0x02; private static final int ERROR_DOWNLOAD_MESSAGE = 0x03; private Handler myHandler; @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.main); myHandler = new MyHandler(); ThreadPoolUtils.execute(new MyRunnable()); } private class MyRunnable implements Runnable{ @Override public void run() { HttpGet httpGet = new HttpGet("http://www.sina.com.cn"); //為這個HttpGet設(shè)置一些特定的屬性，別的屬性沿用HttpClient HttpParams params = new BasicHttpParams(); HttpConnectionParams.setConnectionTimeout(params, 60000); httpGet.setParams(params); myHandler.sendEmptyMessage(START_DOWNLOAD_MESSAGE); try { HttpResponse httpResponse = HttpClientHelper.getHttpClient().execute(httpGet);; byte[] bytes = EntityUtils.toByteArray(httpResponse.getEntity()); //在大多數(shù)情況下，這個下載下來的是XML或者Json。應(yīng)該解析完組裝成對象再放置到Message中。 //這里簡單起見，直接變成字符串打印了 String result = new String(bytes); Message msg = myHandler.obtainMessage(); msg.what = FINISH_DOWNLOAD_MESSAGE; msg.obj = result; myHandler.sendMessage(msg); } catch (Exception ex){ ex.printStackTrace(); myHandler.sendEmptyMessage(ERROR_DOWNLOAD_MESSAGE); } } } private class MyHandler extends Handler{ @Override public void dispatchMessage(Message msg) { switch(msg.what){ case START_DOWNLOAD_MESSAGE: Toast.makeText(HttpDemoActivity.this, "開始下載", Toast.LENGTH_SHORT).show(); break; case FINISH_DOWNLOAD_MESSAGE: Toast.makeText(HttpDemoActivity.this, "下載成功", Toast.LENGTH_SHORT).show(); //簡單起見，直接輸出了。 System.out.println(msg.obj); break; case ERROR_DOWNLOAD_MESSAGE: Toast.makeText(HttpDemoActivity.this, "下載失敗", Toast.LENGTH_SHORT).show(); break; default: System.out.println("nothing to do"); break; } } } }

?

? 總結(jié)：個人有點不習(xí)慣用AsynTask，更傾向于這種寫法。也許Google開發(fā)的AsynTask有更為深遠(yuǎn)的意義，但是我暫時還沒領(lǐng)會到，所以就暫時沿用自己的這種寫法了。

轉(zhuǎn)載于:https://www.cnblogs.com/Free-Thinker/p/4925197.html

總結(jié)

以上是生活随笔為你收集整理的Android实现异步处理 -- HTTP请求的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。