第八章 网络的时代—网络开发（3）

一般的，如果应用程序中会大量的创建新的线程，就要考虑使用线程池了。使用线程池可以有效的管理线程。由于本节主要介绍如何在Android网络应用中实现异步处理，所以就不对线程池做展开说明了。

publicclass HandlerTest extends Activity {

publicstatic final int SHOW_PROGRESS = 0;

publicstatic final int REFRESH = 1;

publicstatic final int REMOVE_PROGRESS = 2;

privateProgressBar mProgressBar;

privateImageView img;

privateButton btn;

privateBitmap mBitmap;

privateView.OnClickListener mOnClickListener = new View.OnClickListener(){

@Override

publicvoid onClick(View v) {

intid = v.getId();

switch(id) {

caseR.id.download:

sendMessage(SHOW_PROGRESS);

Thread t =

newThread(newDownload("http://www.google.com/images/google_favicon_128.png"));

// 开启一个线程下载图片

t.start();

break;

}

}

};

privateHandler mHandler = new Handler() {

@Override

publicvoid handleMessage(Message msg) {

switch(msg.what) {

caseSHOW_PROGRESS:

//显示等待界面

mProgressBar.setVisibility(View.VISIBLE);

break;

caseREMOVE_PROGRESS:

//隐藏等待界面

mHandler.removeMessages(SHOW_PROGRESS);

mProgressBar.setVisibility(View.INVISIBLE);

break;

caseREFRESH:

//更新UI

onRefresh();

break;

}

}

};

protectedvoid onRefresh() {

if(mBitmap!= null){

//更新UI

img.setImageBitmap(mBitmap);

}

//隐藏等待界面

sendMessage(REMOVE_PROGRESS);

}

protectedfinal void sendMessage(int what) {

mHandler.sendMessage(mHandler.obtainMessage(what));

}

@Override

publicvoid onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.handlertest_layout);

img= (ImageView)findViewById(R.id.imgic);

btn= (Button)findViewById(R.id.download);

btn.setOnClickListener(mOnClickListener);

mProgressBar= new ProgressBar(this);

FrameLayout.LayoutParamsparams = new FrameLayout.LayoutParams(

LayoutParams.WRAP_CONTENT,LayoutParams.WRAP_CONTENT);

params.gravity= Gravity.CENTER;

//添加一个等待的view

addContentView(mProgressBar,params);

//开始时候设置为隐藏

mProgressBar.setVisibility(View.INVISIBLE);

}

/**

* 下载的线程

*/

publicclass Download implements Runnable {

privateString uri;

publicDownload(String uri) {

this.uri= uri;

}

@Override

publicvoid run() {

try{

URL url = new URL(uri);

HttpURLConnectionconn

=(HttpURLConnection)url.openConnection();

conn.setDoInput(true);

conn.connect();

InputStreaminputStream=conn.getInputStream();

mBitmap= BitmapFactory.decodeStream(inputStream);

//下载完成后，发送消息给主线程刷新UI

sendMessage(REFRESH);

}catch (Exception e) {

//

}

}

}

}

<LinearLayoutxmlns:android="http://schemas.android.com/apk/res/android"

android:orientation="vertical"

android:layout_width="fill_parent"

android:layout_height="fill_parent"

android:background="@android:color/white">

<Button

android:id="@+id/download"

android:layout_width="fill_parent"

android:layout_height="wrap_content"

android:text="开始下载图片"/>

<ImageView

android:id="@+id/imgic"

android:layout_width="fill_parent"

android:layout_height="wrap_content" />

</LinearLayout>

Message是线程之间传递信息的载体，包含了对消息的描述和任意的数据对象。Message中包含了两个额外的intwhat字段（该字段是用来区分每条信息）和一个object字段，这样在大部分情况下，使用者就不需要再做内存分配工作了。虽然Message的构造函数是public的，但是最好是使用Message.obtain()或Handler.obtainMessage()函数来获取Message对象，因为Message的实现中包含了回收再利用的机制，可以提高效率。

android:layout_width=”match_parent”

android:layout_height=”match_parent”

android:orientation=”vertical”>

<Button

android:id=”@+id/readWebpage”

android:layout_width=”match_parent”

android:layout_height=”wrap_content”

android:onClick=”readWebpage”

android:text=”LoadWebpage” >

</Button>

<TextView

android:id=”@+id/TextView01”

android:layout_width=”match_parent”

android:layout_height=”match_parent”

android:text=”ExampleText” >

</TextView>

</LinearLayout>

publicclass AsyncTaskTest extends Activity {

privateTextView textView;

@Override

publicvoid onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(R.layout.asynctask_layout);

textView= (TextView) findViewById(R.id.TextView01);

}

privateclass DownloadWebPageTask extends AsyncTask<String, Void,String> {

@Override

protectedString doInBackground(String... urls) {

Stringresponse = "";

for(String url : urls) {

// 循环的获取Params中的参数

DefaultHttpClientclient = new DefaultHttpClient();

HttpGethttpGet = new HttpGet(url);

try{

HttpResponseexecute = client.execute(httpGet);

InputStreamcontent = execute.getEntity().getContent();

BufferedReaderbuffer = new BufferedReader(

newInputStreamReader(content));

Strings = "";

while((s = buffer.readLine()) != null) {

response+= s;

}

}catch (Exception e) {

e.printStackTrace();

}

}

returnresponse;

}

@Override

protectedvoid onPostExecute(String result) {

//更新UI

//这里的参数是doInBackground返回过来的

textView.setText(result); }

}

publicvoid readWebpage(View view) {

//按钮的动作

DownloadWebPageTasktask = new DownloadWebPageTask();

task.execute(newString[] { "http://www.baidu.com"});

}

}

在使用AsyncTask中需要注意以下几点：

1）AsyncTask的实例必须在UIthread中创建。

2）AsyncTask.execute方法必须在UIthread中调用。

3）不要手动的调用onPreExecute(),onPostExecute(Result)，

doInBackground(Params...),onProgressUpdate(Progress...)这几个方法。

4）该task只能被执行一次，否则多次调用时将会出现异常。