OKHttp
功能相当于是将URLConnection的功能作了一个封装，方便开发者的使用。其简单的使用步骤如下
构建OkHttpClient， 代码：OkHttpClient client = new OkHttpClient.Builder().build();
构建一个request，代码：Request request = new Request.Builder().url(url).get().build();
构建一个call，来执行这个request，代码：Call call = client.newCall(request);
-
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
