异步任务AsyncTask及JSON解析

你的名字 2022-07-13 10:43 245阅读 0赞

一、AsyncTask：

1、开发Android应用时必须遵守 单线程模型的原则：

Android UI操作并不是线程安全的,并且这些操作必须在UI线程中执行。

2、单线程模型中始终要记住两条法则：

> 1). 不要阻塞UI线程 ；  
> 2). 确保只在UI线程中访问Android UI控件。

当一个程序第一次启动时，Android会同时启动一个对应的 主线程( Main Thread)，主线程主要负责处理与UI相关的事件，如：用户的按键事件，用户接触屏幕的事件以及屏幕绘图事件，并把相关的事件分发到对应的组件进行处理。所以主线程通常又被叫做 UI线程。

3、Android4.0以上版本中， 主线程中不允许访问网络。涉及到网络操作的程序一般都是需要开一个新线程完成网络访问。但是在获得页面数据后，又不能将数据返回到UI界面中 。因为 子线程（ Worker Thread）不能直接访问UI线程中的成员，也就是说 没有办法对UI界面上的内容进行操作，如果操作，将抛出异常： CalledFromWrongThreadException。

其实，android提供了几种在其他线程中访问UI线程的方法：

*  Activity.runOnUiThread( Runnable )
 *  View.post( Runnable )
 *  View.postDelayed( Runnable, long )
 *  Handler消息传递机制（后续课程中讲解）

这些类或方法会使代码很复杂很难理解。为了解决这个问题，Android 1.5提供了一个工具类：AsyncTask，它使创建与用户界面长时间交互运行的任务变得更简单。AsyncTask更轻量级一些，适用于简单的异步处理，不需要借助线程和Handler即可实现。

（二）、AsyncTask的代码实现：

1、AsyncTask是抽象类.AsyncTask定义了三种泛型类型 Params，Progress和Result。

*  Params 启动任务执行的输入参数，比如HTTP请求的URL。 一般用String类型；
 *  Progress 后台任务执行的百分比。 一般用Integer类型；
 *  Result 后台执行任务最终返回的结果，一般用byte\[\]或者String。

2、AsyncTask的执行分为 四个步骤，每一步都对应一个回调方法（由应用程序自动调用的方法），开发者需要做的就是实现这些方法。

> 1) 定义AsyncTask的子类；
> 
> 2) 实现AsyncTask中定义的方法：（可以全部实现，也可以只实现其中一部分）

*  onPreExecute(), 该方法将在执行实际的后台操作前被UI thread调用。可以在该方法中做一些准备工作，如在界面上显示一个进度条。
 *  doInBackground(Params...), 将在onPreExecute 方法执行后马上执行，该方法运行在后台线程中。这里将主要负责执行那些很耗时的后台计算工作。可以调用 publishProgress方法来更新实时的任务进度。该方法是抽象方法，子类必须实现。
 *  onProgressUpdate(Progress...),在publishProgress方法被调用后，UI thread将调用这个方法从而在界面上展示任务的进展情况，例如通过一个进度条进行展示。
 *  onPostExecute(Result), 在doInBackground 执行完成后，onPostExecute 方法将被UI thread调用，后台的计算结果将通过该方法传递到UI thread.

3、核心代码：

publicclass MainActivity extends Activity {
    
    privatefinalstatic String TAG = "MainActivity";
    private String urlString = "http://www.baidu.com/";
    private TextView text_main_info;
    
    
    @Override
    
    protectedvoid onCreate(Bundle savedInstanceState) {
    
    super.onCreate(savedInstanceState);
    
    setContentView(R.layout.activity_main);
    
    text_main_info = (TextView) findViewById(R.id.text_main_info);
    
    // 调用异步任务，执行网络访问
    
    new MyTask(this).execute(urlString);
    
    }
    
    
    
    class MyTask extends AsyncTask<String, Void, byte[]> {
    
    private ProgressDialog pDialog;
    
    private Context context = null;
    
    
    
    // 构造方法，初始化进度对话框
    
    public MyTask(Context context) {
    
    this.context = context;
    
    pDialog = new ProgressDialog(context);
    
    pDialog.setIcon(R.drawable.ic_launcher);
    
    pDialog.setTitle("提示：");
    
    pDialog.setMessage("数据加载中。。。");
    
    }
    
    
    
    // 事先执行方法中显示进度对话框
    
    @Override
    
    protectedvoid onPreExecute() {
    
    pDialog.show();
    
    super.onPreExecute();
    
    }
    
    
    
    // 进度条进度改变方法。一般情况下，可以不写该方法
    
    @Override
    
    protectedvoid onProgressUpdate(Void... values) {
    
    // TODO Auto-generated method stub
    
    super.onProgressUpdate(values);
    
    }
    
    
    
    // 后台执行方法，这个方法执行worker Thread异步访问网络，加载数据。该方法中不可以执行任何UI操作。
    
    @Override
    
    protectedbyte[] doInBackground(String... params) {
    
    BufferedInputStream bis = null;
    
    ByteArrayOutputStream baos = new ByteArrayOutputStream();
    
    try {
    
    URL urlObj = new URL(params[0]);
    
    HttpURLConnection httpConn = (HttpURLConnection) urlObj
    
    .openConnection();
    
    httpConn.setDoInput(true);
    
    // httpConn.setDoOutput(true);
    
    httpConn.setRequestMethod("GET");
    
    httpConn.connect();
    
    if (httpConn.getResponseCode() == 200) {
    
    bis = new BufferedInputStream(httpConn.getInputStream());
    
    byte[] buffer = newbyte[1024 * 8];
    
    int c = 0;
    
    
    
    while ((c = bis.read(buffer)) != -1) {
    
    baos.write(buffer, 0, c);
    
    baos.flush();
    
    }
    
    
    
    // Toast.makeText(context, baos.toByteArray().toString(),
    
    // Toast.LENGTH_LONG).show();
    
    return baos.toByteArray();
    
    }
    
    } catch (Exception e) {
    
    e.printStackTrace();
    
    } finally {
    
    try {
    
    if (bis != null) {
    
    bis.close();
    
    }
    
    if (baos != null) {
    
    baos.close();
    
    }
    
    } catch (IOException e) {
    
    e.printStackTrace();
    
    }
    
    }
    
    returnnull;
    }
    
    
    
    // 事后方法，这个方法主要作用是执行对主线程中UI的操作。可以实现主线程和子线程之间的数据交互
    
    @Override
    
    protectedvoid onPostExecute(byte[] result) {
    
    super.onPostExecute(result);
    
    if (result == null) {
    
    text_main_info.setText("网络异常，加载数据失败！");
    
    } else {
    
    text_main_info.setText(new String(result));
    
    }
    
    pDialog.dismiss();
    
    }
    
    }
    
    
    
    @Override
    
    publicboolean onCreateOptionsMenu(Menu menu) {
    
    // Inflate the menu; this adds items to the action bar if it is present.
    
    getMenuInflater().inflate(R.menu.main, menu);
    
    returntrue;
    }
    
    }

（三）、增加进度条的异步任务：

1、制作思路：

1.  在异步任务内部类的构造方法中new ProgressDialog()；
2.  在onPreExecute()中调用ProgressDialog对象的show()方法，显示进度对话框；
3.  在doInBackground()方法中计算进度，在while循环中通过调用publishProgress()方法将进度数据随时发布出去；
4.  进度数据的计算公式：publishProgress((int) ((count / (double) length) \* 100))，其中count为当前加载的文件长度，length为文件的总长度；
5.  在onPostExecute()方法中调用 ProgressDialog对象的dismiss()方法，让进度条消失。

2、核心代码：

A、如果计算进度？【在doInBackground()方法中增加如下代码】

// 获取内容的长度

int length = httpConn.getContentLength();

while ((c = bis.read(buffer)) != -1) \{

baos.write(buffer, 0, c);

baos.flush();

count += c;

if (length > 0) \{

// 如果知道响应的长度，调用publishProgress()更新进度

publishProgress((int) ((count / (double) length) \* 100));

B、如果更新进度？【在onProgressUpdate()方法中增加如下代码】