OkHttp3幾個簡單的例子和在子線程更新UI線程的方法


okHttp用於android的http請求。據說很厲害,我們來一起嘗嘗鮮。但是使用okHttp也會有一些小坑,后面會講到如何掉進坑里並爬出來。

首先需要了解一點,這里說的UI線程和主線程是一回事兒。就是唯一可以更新UI的線程。這個只是點會在給okHttp填坑的時候用到。而且,這個內容本身在日常的開發中也經常用到,值得好好學一學。

okHttp發起同步請求

第一個列子是一個同步請求的例子。

private void performSyncHttpRequest() {
    OkHttpClient client = new OkHttpClient();

    Request request = new Request.Builder()
        .url("http://www.baidu.com")
        .build();
    Call call = client.newCall(request);
    Response response = call.execute();
}

但是這樣的直接在android的主線程里調用一個網絡請求的方法是行不通的,直接拋出UI Thread 請求網絡的異常。所以我們這里為了可以掩飾要做一點小小的改動。把請求寫成同步請求的方式,但是放在一個worker線程里異步的做這個操作。

    private Handler requestHandler = new Handler() {
        @Override
        public void handleMessage(Message msg) {
            switch (msg.what) {
                case REQUEST_SUCCESS:
                    Toast.makeText(MainActivity.this, "SUCCESSFUL", Toast.LENGTH_SHORT).show();
                    break;
                case REQUEST_FAIL:
                    Toast.makeText(MainActivity.this, "request failed", Toast.LENGTH_SHORT).show();
                    break;
                default:
                    super.handleMessage(msg);
            }
        }
    };

    private void performSyncHttpRequest() {
        Runnable requestTask = new Runnable() {
            @Override
            public void run() {
                Message msg = requestHandler.obtainMessage();
                try {
                    OkHttpClient client = new OkHttpClient();

                    Request request = new Request.Builder()
                            .url("http://www.baidu.com")
                            .build();
                    Call call = client.newCall(request);
                    // 1
                    Response response = call.execute();

                    if (!response.isSuccessful()) {
                        msg.what = REQUEST_FAIL;
                    } else {
                        msg.what = REQUEST_SUCCESS;
                    }
                } catch (IOException ex) {
                    msg.what = REQUEST_FAIL;
                } finally {
                    // send the message
                    // 2
                    msg.sendToTarget();
                }
            }
        };

        Thread requestThread = new Thread(requestTask);
        requestThread.start();
    }  

所以同步的請求都是這么做的Response response = call.execute();

  1. 發起同步請求之前先新初始化一個OkHttpClient。然后是具體的請求,用請求builder來創建這個Request。我們這里為了簡單url就是http://www.baidu.com了。接下來用前面初始化好的client發起一個call:Call call = client.newCall(request);。最后執行這個call:Response response = call.execute();並獲得請求的response。
  2. 這一部分的可以暫時不要關注。因為這個例子只是為了能以運行起來的方式展示okHttp如何發起同步請求。

okHttp發起異步請求

既然android本身不支持發起同步請求,當然也沒人要發起同步請求。這么做是能導致嚴重的用戶體驗問題。想象一下,如果你有一個瀑布流,然后瀑布流里全部顯示的都是圖片。現在用戶要不斷地往下翻看瀑布流的圖片。如果這些圖片都用同步請求的話,什么時候可以翻一頁不說,系統的ANR早就跳出來了。

所以我們就探究一下如何發起一個異步的請求。

    private void performAsyncHttpRequest() {
        OkHttpClient client = new OkHttpClient();

        Request request = new Request.Builder()
                .url("http://www.baidu.com")
                .build();
        Call call = client.newCall(request);
        // 1
        call.enqueue(new Callback() {
            // 2
            @Override
            public void onFailure(Call call, IOException e) {
                //Toast.makeText(MainActivity.this, e.getMessage(), Toast.LENGTH_SHORT).show();
                
                if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
                    Log.d(TAG, "Main Thread");
                } else {
                    Log.d(TAG, "Not Main Thread");
                }
            }

            @Override
            public void onResponse(Call call, final Response response) throws IOException {
                // 3
                if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
                    Log.d(TAG, "Main Thread");
                } else {
                    Log.d(TAG, "Not Main Thread");
                }
            }
        });
    }    
  1. 同步請求用execute方法,異步就用call.enqueue(new Callback()方法。
  2. 這個Callback接口提供了兩個方法,一個是onFailure,一個是onResponse。這兩個方法分別在請求失敗和成功的時候調用。
  3. 本來一切都似乎應該很簡單。網絡請求成功或者失敗直接在界面更新了。但是木有想到這樣會拋異常。然后看了看發現原來onFailureonResponse兩個方法不是在主線程執行。打印出來的log是:okhttp.demo.com.okhttpdemo D/###okHttp: Not Main Thread

所以要在主線程中更新view只好想別的辦法了。在worker線程里更新主線程會拋異常。一般來說有這么幾個方法在子線程里更新view。

在子線程更新UI線程

一、Activity的runOnUiThread方法

Activity中有這么一個方法runOnUiThread。這個方法需要一個Runnable實例作為參數。

    MainActivity.this.runOnUiThread(new Runnable() {
        @Override
        public void run() {
            Log.d(TAG, "code: ");
            Toast.makeText(MainActivity.this, String.valueOf(response.code()), Toast.LENGTH_SHORT).show();
        }
    });

二、View的post方法

View的post方法也是一樣,扔一個Runnable的實例進去。然后就在主線程執行了。Toast肯定是沒有這個方法的。

MainActivity.this.mView.post(new Runnable() {
    public void run() {
        Log.d("UI thread", "I am the UI thread");
    }
});

三、其他

  1. 用Handler,這個前面的okHttp同步請求的例子可以用。
  2. AsyncTask, 有兩個方法可以在主線程中執行:onProgressUpdateonPostExecute。這里我們並不是要更新進度,所以考慮的是后一個方法。
    private class BackgroundTask extends AsyncTask<String, Void, Bitmap> {
        protected void onPostExecute(Bitmap result) {
            Log.d("UI thread", "I am the UI thread");
        }
    }

綜合以上,更新UI線程的方法里最后說到的Handler方法和AsyncTask都太重。尤其是AsyncTask。還要繼承實現一堆的方法之后才可以能達到目的,同時還和我們要用的okHttp的使用方法很多不兼容的地方。

所以我們只考慮前面的兩種。但是兩種方法其實是不一樣的。當然,這里並不是說方法的名字不一樣。我們來看看android的源代碼,這兩個方法是如何實現的。

    public final void runOnUiThread(Runnable action) {
        if (Thread.currentThread() != mUiThread) {
            mHandler.post(action);
        } else {
            action.run();
        }
    }
    // mHandler.post(action); 之post方法的實現
    public final boolean post(Runnable r) {
       return  sendMessageDelayed(getPostMessage(r), 0);
    }

方法runOnUiThread最后會調用HandlersendMessageDelayed。但是這里只delay了0。也就是方法傳到這里的時候會立即執行runOnUiThread的參數Runnable實例會立即執行。

下面看看View的post方法:

    public boolean post(Runnable action) {
        final AttachInfo attachInfo = mAttachInfo;
        if (attachInfo != null) {
            return attachInfo.mHandler.post(action);
        }
        // Assume that post will succeed later
        ViewRootImpl.getRunQueue().post(action);
        return true;
    }

一般會執行的是ViewRootImpl.getRunQueue().post(action);。也就是Runnable的實例只是添加到了事件隊列中,按照順序執行。並不一定會立即執行。

我們探討了那么多,最后就使用runOnUiThread來更新界面,也就是方法一了。

call.enqueue(new Callback() {
    @Override
    public void onFailure(Call call, IOException e) {
        final String errorMMessage = e.getMessage();

        if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
            Log.d(TAG, "Main Thread");
        } else {
            Log.d(TAG, "Not Main Thread");
        }

        MainActivity.this.runOnUiThread(new Runnable() {
            @Override
            public void run() {
                Toast.makeText(MainActivity.this, errorMMessage, Toast.LENGTH_SHORT).show();
            }
        });
    }

    @Override
    public void onResponse(Call call, final Response response) throws IOException {
        if (Looper.getMainLooper().getThread() == Thread.currentThread()) {
            Log.d(TAG, "Main Thread");
        } else {
            Log.d(TAG, "Not Main Thread");
        }

        MainActivity.this.runOnUiThread(new Runnable() {
            @Override
            public void run() {
                Log.d(TAG, "code: ");
                Toast.makeText(MainActivity.this, String.valueOf(response.code()), Toast.LENGTH_SHORT).show();
            }
        });
    }
});

無論請求成功還是失敗,都彈出一個Toast。用MainActivity.this.runOnUiThread在UI線程中彈出這個Toast


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM