Android网络操作与流行框架(三)——AsyncTask异步任务

一、异步任务简介

1、异步&同步定义

AsyncTask异步任务类，比Handle更轻量级，更适合简单的异步操作。内部类封装了handle，在使用AsyncTask类进行刷新控件的刷新操作时，不用再额外创建声明Handle，可以直接使AsyncTask内部封装好的几个方法实现

2、AsyncTask参数介绍（三个参数）

• Params： 开始异步任务执行时传入的参数类型，对应excute()中传递参数
• Progress：异步任务执行过程中，返回下载进度值的类型
• Result：异步任务执行完成后，返回的结果类型，与dolnBackground()的返回值类型保持一致

3、核心方法

• execute() 执行
• onPreExecute() 在执行之前
• doInBackground() 相当于子线程 耗时操作在这个里边执行， 处理UI问题不行
• onProgressUpdate() 处理进度更新，可以操作UI
• onPostExecute() 接收线程任务的执行结果(doInBackground结果)
• onCancelled() 在执行过程中被取消( onPostExecute和onCancelled只会执行一个)

4、使用步骤

• 创建AsyncTask子类&根据需求实现核心方法
• 创建AsyncTask子类的实例对象（即：任务实例）
• 手动调用execute() 从而执行异步线程任务

案例：

activity_asynctask.xml

AsyncTaskActivity.java

package com.example.timerdemo;

import android.os.AsyncTask;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import androidx.annotation.Nullable;
import androidx.appcompat.app.AppCompatActivity;

import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;

// 请求服务器，将响应显示在界面中
public class AsyncTaskActivity extends AppCompatActivity {

    private String TAG = "AsyncTask";
    private Button button;
    private TextView textView;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_asynctask);

        button = findViewById(R.id.button5);
        textView = findViewById(R.id.textView);

        button.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                // 实例化AsyncTask
                Log.i(TAG, "onClick: 点击按钮~！~");
                MyTask myTask = new MyTask();
                myTask.execute("http://www.imooc.com/api/teacher?type=3&cid=1");

            }
        });

    }

    // execute方法的参数：通常如果是请求服务器的话，那么这个参数我们会传入服务器接口地址
    // MyTask task = new MyTask();
    // task.execute("http://.....................");
    // http://www.imooc.com/api/teacher?type=3&cid=1
    class MyTask extends AsyncTask {

        @Override
        protected void onPreExecute() {
            super.onPreExecute();
            Log.i(TAG, "onPreExecute: 执行了");
        }

        // 请求服务器  可变长度取值按下标取
        @Override
        protected String doInBackground(String... strings) {

            try {
                URL url = new URL(strings[0]);

                HttpURLConnection conn = (HttpURLConnection) url.openConnection();

                conn.setRequestMethod("GET");
                conn.setConnectTimeout(6000);

                if(conn.getResponseCode() == HttpURLConnection.HTTP_OK){

                    InputStream in = conn.getInputStream();
                    byte[] b = new byte[1024];
                    int len = 0;
                    ByteArrayOutputStream baos = new ByteArrayOutputStream();
                    while ((len = in.read(b))>-1){
                        baos.write(b, 0, len);
                    }
                    String msg = new String(baos.toByteArray());
                    Log.i(TAG, "doInBackground: " + msg);
                    return msg;
                }
            } catch (MalformedURLException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }
            return null;
        }

        // 处理显示问题
        @Override
        protected void onPostExecute(String s) {
            super.onPostExecute(s);
            Log.i(TAG, "onPostExecute: 执行了");
            if(s != null){
                textView.setText(s);
            }
        }
    }
}

结果：

案例2：进度条

activity_main.xml

MainActivity.java

package com.example.asynctaskdemo;

import androidx.appcompat.app.AppCompatActivity;

import android.os.AsyncTask;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.ProgressBar;
import android.widget.TextView;

import java.nio.channels.AsynchronousByteChannel;

public class MainActivity extends AppCompatActivity {

    private TextView textView;
    private Button button1, button2;
    private ProgressBar progressBar;
    private AsyncTask pTask;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        textView = findViewById(R.id.textView);
        button1 = findViewById(R.id.button);
        button2 = findViewById(R.id.button2);
        progressBar = findViewById(R.id.pgb);

        pTask = new ProgressTask();

        button1.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                pTask.execute();
            }
        });

        button2.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                pTask.cancel(true);
            }
        });

    }

    class ProgressTask extends AsyncTask {

        @Override
        protected void onPreExecute() {
            super.onPreExecute();
        }

        @Override
        protected String doInBackground(Void... voids) {
            try {
                for(int i = 1; i <= 3; i++){
                    publishProgress(i);
                    Thread.sleep(3000);
                }
                return "sss";
            }catch (InterruptedException e) {
                e.printStackTrace();
            }
            return null;
        }

        @Override
        protected void onProgressUpdate(Integer... values) {
            super.onProgressUpdate(values);
            progressBar.setProgress(100/3*values[0]);
            textView.setText("正在下载第" + values[0] + "个文件");
        }

        @Override
        protected void onPostExecute(String s) {
            super.onPostExecute(s);
            if(s != null){
                textView.setText("下载完成");
            }
        }

        @Override
        protected void onCancelled() {
            super.onCancelled();
            textView.setText("已暂停");
        }
    }
}

坐得住板凳，耐得住寂寞，守得住初心!