OKHttp
功能相當(dāng)于是將URLConnection的功能作了一個(gè)封裝辅愿，方便開發(fā)者的使用溯街。其簡單的使用步驟如下
構(gòu)建OkHttpClient， 代碼：OkHttpClient client = new OkHttpClient.Builder().build();
構(gòu)建一個(gè)request，代碼：Request request = new Request.Builder().url(url).get().build();
構(gòu)建一個(gè)call统捶，來執(zhí)行這個(gè)request，代碼：Call call = client.newCall(request);
-
call.enqueue實(shí)際的執(zhí)行柄粹，并將結(jié)果返還給回調(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); } });
其他：
- 因?yàn)楸臼纠褂肙KHttp發(fā)送get請(qǐng)求，因此參數(shù)現(xiàn)在了url里面
- 如果是post驻右，OKHttp在構(gòu)建Request的時(shí)候什黑，必須傳一個(gè)RequestBody進(jìn)去。傳空的話堪夭，會(huì)報(bào)下面的錯(cuò)誤愕把。使用Postman嘗試拣凹，post是可以在header里面加參數(shù)的，okhttp可能不贊同這么做恨豁。
java.lang.IllegalArgumentException: method POST must have a request body. - 一般 post都會(huì)把參數(shù)數(shù)據(jù)通過body提交到服務(wù)器嚣镜，因此在構(gòu)建Post Requst對(duì)象的時(shí)候需要傳遞一個(gè)RequestBody對(duì)象。RequestBody可以對(duì)應(yīng)表單數(shù)據(jù)橘蜜、json數(shù)據(jù)菊匿、raw流和multi-part。
Rxjava
功能：實(shí)現(xiàn)了一個(gè)觀察者和被觀察者的一個(gè)框架计福。
- 簡單的說就是老板和民工的一個(gè)模型實(shí)現(xiàn)跌捆，老板訂閱了民工，民工做到哪一步象颖，都會(huì)實(shí)時(shí)的通知到老板那佩厚。簡單的demo如下, Observer-reader相當(dāng)于是老板，Novel相當(dāng)于是民工说订。不過observer和observable之間只能是一對(duì)一的關(guān)系可款，observer不能訂閱別的observable。
- 另外克蚂，默認(rèn)情況下闺鲸，observer的回調(diào)函數(shù)和observable的回調(diào)函數(shù)，均處在被調(diào)用時(shí)的那個(gè)線程埃叭。即demo的代碼實(shí)質(zhì)上是在一個(gè)線程里順序往下執(zhí)行的摸恍。
- 可以通過Observable的observeOn和subscribeOn來分別設(shè)定 兩者回調(diào)函數(shù)的線程。
- 觀察者模式的意義在于赤屋，被觀察者做了一些事情立镶，可以實(shí)時(shí)的將進(jìn)度通知給觀察者。
- 另外 也常用Consumer來替代一個(gè)ObservableOnSubscribe的實(shí)現(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
