OKHttp

功能相當于是將URLConnection的功能作了一個封裝，方便開發(fā)者的使用。其簡單的使用步驟如下

1. 構建OkHttpClient， 代碼：OkHttpClient client = new OkHttpClient.Builder().build();

2. 構建一個request，代碼：Request request = new Request.Builder().url(url).get().build();

3. 構建一個call，來執(zhí)行這個request，代碼：Call call = client.newCall(request);

4. call.enqueue實際的執(zhí)行，并將結果返還給回調(diào)。代碼：call.enqueue(new Callback()）

    String url = "http://evaluation/evaluate?ago=0";
    OkHttpClient client = new OkHttpClient.Builder().build();
    Request request = new Request.Builder().url(url).get().build();
    Call call = client.newCall(request);
    call.enqueue(new Callback() {
        @Override
        public void onFailure(Call call, IOException e) {
            ALog.i("error:" + e.getMessage());
        }
        @Override
        public void onResponse(Call call, Response response) throws IOException {
            //得到的子線程
            String result = response.body().string();
            ALog.i("result:" + result);
        }
    });
   

其他：

• 因為本示例使用OKHttp發(fā)送get請求，因此參數(shù)現(xiàn)在了url里面
• 如果是post，OKHttp在構建Request的時候，必須傳一個RequestBody進去。傳空的話，會報下面的錯誤。使用Postman嘗試，post是可以在header里面加參數(shù)的，okhttp可能不贊同這么做。
  java.lang.IllegalArgumentException: method POST must have a request body.
• 一般 post都會把參數(shù)數(shù)據(jù)通過body提交到服務器，因此在構建Post Requst對象的時候需要傳遞一個RequestBody對象。RequestBody可以對應表單數(shù)據(jù)、json數(shù)據(jù)、raw流和multi-part。

Rxjava

功能：實現(xiàn)了一個觀察者和被觀察者的一個框架。

• 簡單的說就是老板和民工的一個模型實現(xiàn)，老板訂閱了民工，民工做到哪一步，都會實時的通知到老板那。簡單的demo如下, Observer-reader相當于是老板，Novel相當于是民工。不過observer和observable之間只能是一對一的關系，observer不能訂閱別的observable。
• 另外，默認情況下，observer的回調(diào)函數(shù)和observable的回調(diào)函數(shù)，均處在被調(diào)用時的那個線程。即demo的代碼實質(zhì)上是在一個線程里順序往下執(zhí)行的。
• 可以通過Observable的observeOn和subscribeOn來分別設定 兩者回調(diào)函數(shù)的線程。
• 觀察者模式的意義在于，被觀察者做了一些事情，可以實時的將進度通知給觀察者。
• 另外 也常用Consumer來替代一個ObservableOnSubscribe的實現(xiàn)，Consumer是其簡寫的封裝。

class Reader implements Observer<String> {
        String name;
        public Reader(String name) {
            this.name = name;
        }

        private Disposable mDisposable;
        @Override
        public void onSubscribe(Disposable d) {
            mDisposable = d;
            ALog.i(Thread.currentThread().getName() + "-" + name + " onSubscribe");
        }

        @Override
        public void onNext(String value) {
            ALog.i(Thread.currentThread().getName() + "-" + name + " onNext:"+value);
        }

        @Override
        public void onError(Throwable e) {
            ALog.e(Thread.currentThread().getName() + "-" + name + " onError="+e.getMessage());
        }

        @Override
        public void onComplete() {
            ALog.i(Thread.currentThread().getName() + "-" + name + " onComplete()");
        }
    };

    class Novel implements ObservableOnSubscribe<String> {
        ObservableEmitter<String> emitter;

        @Override
        public void subscribe(ObservableEmitter<String> emitter) throws Exception {
            ALog.i("subscribe");
            this.emitter = emitter;
        }

        void next(String str) {
            emitter.onNext(str);
        }
        void complete() {
            emitter.onComplete();
        }
    }

    void rxjava() {
        Novel novel = new Novel();
        Observable novelProxy = Observable.create(novel);
        novelProxy.subscribe(new Reader("JIM"));
        sleep(1);
        novel.next("連載1");
        sleep(1);
        novel.next("連載2");
        sleep(1);
        novel.next("連載3");
        sleep(1);
        novel.complete();
        ALog.i("finished");
    }

執(zhí)行的打印如下：

Demo [INFO]: main-JIM onSubscribe
Demo [INFO]: subscribe
Demo [INFO]: main-JIM onNext:連載1
Demo [INFO]: main-JIM onNext:連載2
Demo [INFO]: main-JIM onNext:連載3
Demo [INFO]: main-JIM onComplete()
Demo [INFO]: finished