OKHttp

功能相当于是将URLConnection的功能作了一个封装，方便开发者的使用。其简单的使用步骤如下

1. 构建OkHttpClient， 代码：OkHttpClient client = new OkHttpClient.Builder().build();

2. 构建一个request，代码：Request request = new Request.Builder().url(url).get().build();

3. 构建一个call，来执行这个request，代码：Call call = client.newCall(request);

4. call.enqueue实际的执行，并将结果返还给回调。代码：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发送get请求，因此参数现在了url里面
• 如果是post，OKHttp在构建Request的时候，必须传一个RequestBody进去。传空的话，会报下面的错误。使用Postman尝试，post是可以在header里面加参数的，okhttp可能不赞同这么做。
  java.lang.IllegalArgumentException: method POST must have a request body.
• 一般 post都会把参数数据通过body提交到服务器，因此在构建Post Requst对象的时候需要传递一个RequestBody对象。RequestBody可以对应表单数据、json数据、raw流和multi-part。

Rxjava

功能：实现了一个观察者和被观察者的一个框架。

• 简单的说就是老板和民工的一个模型实现，老板订阅了民工，民工做到哪一步，都会实时的通知到老板那。简单的demo如下, Observer-reader相当于是老板，Novel相当于是民工。不过observer和observable之间只能是一对一的关系，observer不能订阅别的observable。
• 另外，默认情况下，observer的回调函数和observable的回调函数，均处在被调用时的那个线程。即demo的代码实质上是在一个线程里顺序往下执行的。
• 可以通过Observable的observeOn和subscribeOn来分别设定 两者回调函数的线程。
• 观察者模式的意义在于，被观察者做了一些事情，可以实时的将进度通知给观察者。
• 另外 也常用Consumer来替代一个ObservableOnSubscribe的实现，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");
    }

执行的打印如下：

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