框架學(xué)習(xí)
1.RxJava
RxJavad 使用方面的簡(jiǎn)單總結(jié):
1者蠕、RxJava的基本概念:
Observable
(可觀察者段直,即被觀察者)、Observer
(觀察者)著角、subscribe
(訂閱)吼旧、事件郎嫁。Observable
和Observer
通過subscribe()
方法實(shí)現(xiàn)訂閱關(guān)系,從而Observable
可以在需要的時(shí)候發(fā)出事件來通知Observer
哮内。
2盗棵、觀察者模式:
Observable
(可觀察者,即被觀察者)北发、Observer
(觀察者)的創(chuàng)建纹因,以及兩者之間訂閱關(guān)系的建立。
Observer
的創(chuàng)建:
/** * 觀察者,用于監(jiān)聽被觀察者 */
Observer<String> observer = new Observer<String>() {
@Override
public void onCompleted() {
//事件隊(duì)列完結(jié)時(shí)候調(diào)用;
}
@Override
public void onError(Throwable e) {
// 事件隊(duì)列異常的時(shí)候調(diào)用 }
@Override
public void onNext(String s) {
// 事件發(fā)出時(shí)琳拨,調(diào)用瞭恰。需要觸發(fā) onCompleted() 方法作為標(biāo)志。
}
};
實(shí)際使用中并觀察者用的一般是`Observer`的子類`Subscriber`狱庇。`Subscriber`除了具備`Observer`的幾個(gè)方法外惊畏,還增加一些新的特性。如加入了`onStart()`方法密任。在這個(gè)方法里面可以做一些準(zhǔn)備工作等等颜启。更主要的一點(diǎn)是,Observer在 subscribe()過程中最終會(huì)被轉(zhuǎn)換成 Subscriber對(duì)象
Subscriber
的創(chuàng)建:
- 訂閱者(Subscriber實(shí)現(xiàn)了Observer觀察者,處理能力比Observer更完善浪讳。推薦使用)
*/
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onStart() {
super.onStart();
}
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
};
>`Observable`(可觀察者缰盏,即被觀察者)的創(chuàng)建方式有?三種方式
>
>第一種方式,通過`Observable`的`create()`方法創(chuàng)建:
> ```
> Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("RxJava");
subscriber.onCompleted();
}
});
> ```
>第二種方式淹遵,通過`Observable`的`?just()`方法創(chuàng)建:
> ```
Observable observable = Observable.just("Hello", "RxJava") ;
第三種方式口猜,通過
Observable
的?from()
方法創(chuàng)建:
// 方式三,將傳入的數(shù)組拆分成單個(gè)對(duì)象發(fā)送出去
String[] content = {"Hello","RxJava"};
Observable observable = Observable.from(content);
`Observer`(或者`Subscriber`)與`Observable`之間訂閱關(guān)系的建立:
observable.subscribe(observer);或者observable.subscribe(subscriber);
> 事件的訂閱看上去好像是顛倒了對(duì)象關(guān)系。被觀察者通過訂閱綁定了觀察者透揣。上述這種方式是采用的流式 API 的設(shè)計(jì)方式暮的。如果采用常規(guī)的邏輯實(shí)現(xiàn)訂閱,會(huì)對(duì)流式 API 的設(shè)計(jì)造成影響淌实,比較起來明顯是得不償失的。
>
> 除了 subscribe(Observer)和 subscribe(Subscriber)猖腕,subscribe()還支持不完整定義的回調(diào)拆祈,RxJava 會(huì)自動(dòng)根據(jù)定義創(chuàng)建出Subscriber。形式如下:
>```
Action1<String> onNextAction = new Action1<String>() {
// onNext()
@Override
public void call(String s) {
Log.d(tag, s);
}
};
Action1<Throwable> onErrorAction = new Action1<Throwable>() {
// onError()
@Override
public void call(Throwable throwable) {
// Error handling
}
};
Action0 onCompletedAction = new Action0() {
// onCompleted()
@Override public void call() {
Log.d(tag, "completed");
}
};
// 自動(dòng)創(chuàng)建 Subscriber 倘感,并使用 onNextAction 來定義
onNext()observable.subscribe(onNextAction);
>
// 自動(dòng)創(chuàng)建 Subscriber 放坏,并使用 onNextAction 和 onErrorAction 來定義 onNext() 和 onError()
observable.subscribe(onNextAction, onErrorAction);
>
// 自動(dòng)創(chuàng)建 Subscriber ,并使用 onNextAction老玛、 onErrorAction 和
// onCompletedAction 來定義 onNext()淤年、 onError() 和 onCompleted()
observable.subscribe(onNextAction, onErrorAction, onCompletedAction);
3钧敞、Scheduler(調(diào)度器)設(shè)置
Subscriber
和Observable
運(yùn)行線程在 RxJava 的默認(rèn)規(guī)則中,事件的發(fā)出和消費(fèi)都是在同一個(gè)線程的麸粮。也就是說溉苛,如果只用上面的方法,實(shí)現(xiàn)出來的只是一個(gè)同步的觀察者模式弄诲。觀察者模式本身的目的就是『后臺(tái)處理愚战,前臺(tái)回調(diào)』的異步機(jī)制,因此異步對(duì)于 RxJava 是至關(guān)重要的齐遵。而要實(shí)現(xiàn)異步寂玲,則需要用到 RxJava 的另一個(gè)概念: Scheduler。
在不指定線程的情況下梗摇, RxJava 遵循的是線程不變的原則拓哟,即:在哪個(gè)線程調(diào)用 subscribe(),就在哪個(gè)線程生產(chǎn)事件伶授;在哪個(gè)線程生產(chǎn)事件断序,就在哪個(gè)線程消費(fèi)事件。如果需要切換線程谎砾,就需要用到 Scheduler(調(diào)度器)逢倍。
RxJava 已經(jīng)內(nèi)置了幾個(gè) Scheduler,它們已經(jīng)適合大多數(shù)的使用場(chǎng)景:Schedulers.immediate(): 直接在當(dāng)前線程運(yùn)行景图,相當(dāng)于不指定線程较雕。這是默認(rèn)的 Scheduler。
- **Schedulers.newThread(): **總是啟用新線程挚币,并在新線程執(zhí)行操作亮蒋。
- Schedulers.io(): I/O 操作(讀寫文件、讀寫數(shù)據(jù)庫(kù)妆毕、網(wǎng)絡(luò)信息交互等)所使用的 Scheduler慎玖。行為模式和 newThread()差不多,區(qū)別在于 io()的內(nèi)部實(shí)現(xiàn)是是用一個(gè)無數(shù)量上限的線程池笛粘,可以重用空閑的線程趁怔,因此多數(shù)情況下 io()比 newThread()更有效率。不要把計(jì)算工作放在 io()中薪前,可以避免創(chuàng)建不必要的線程润努。
-
Schedulers.computation(): 計(jì)算所使用的 Scheduler。這個(gè)計(jì)算指的是 CPU 密集型計(jì)算示括,即不會(huì)被 I/O 等操作限制性能的操作铺浇,例如圖形的計(jì)算。這個(gè) Scheduler使用的固定的線程池垛膝,大小為 CPU 核數(shù)鳍侣。不要把 I/O 操作放在 computation()中丁稀,否則 I/O 操作的等待時(shí)間會(huì)浪費(fèi) CPU。
另外倚聚, Android 還有一個(gè)專用的 AndroidSchedulers.mainThread()线衫,它指定的操作將在 Android 主線程運(yùn)行。
有了這幾個(gè) Scheduler秉沼,就可以使用 subscribeOn()和 observeOn()兩個(gè)方法來對(duì)線程進(jìn)行控制了桶雀。
- **subscribeOn(): **指定subscribe()所發(fā)生的線程即 Observable.OnSubscribe被激活時(shí)所處的線程』8矗或者叫做事件產(chǎn)生的線程矗积。
- **observeOn(): **指定Subscriber所運(yùn)行在的線程〕ㄟ郑或者叫做事件消費(fèi)的線程棘捣。
代碼示例:
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("RxJava");
subscriber.onCompleted();
}
}).subscribeOn(Schedulers.io())//observable 被觀察者運(yùn)行在I/O線程
.observeOn(AndroidSchedulers.mainThread());//Subscriber的回調(diào)運(yùn)行在UI線程,即主線程
**4、變換** RxJava 提供了對(duì)事件序列進(jìn)行變換的支持休建,這是它的核心功能之一乍恐,也是大多數(shù)人說『RxJava 真是太好用了』的最大原因。**所謂變換测砂,就是將事件序列中的對(duì)象或整個(gè)序列進(jìn)行加工處理茵烈,轉(zhuǎn)換成不同的事件或事件序列。也就是在事件發(fā)生和事件消費(fèi)之間砌些,將事件序列中的對(duì)象進(jìn)行轉(zhuǎn)換**呜投。 **①**通過`map()`進(jìn)行轉(zhuǎn)換: 代碼示例:
observable.just("images/logo.png") // 輸入類型 String
.map(new Func1<String, Bitmap>() {//String 是傳入的參數(shù)類型,Bitmap返回參數(shù)類型
@Override
public Bitmap call(String filePath) { // 參數(shù)類型 String
return getBitmapFromPath(filePath); // 返回類型 Bitmap
}
}).subscribe(new Action1<Bitmap>() {
@Override
public void call(Bitmap bitmap) { // 參數(shù)類型 Bitmap
showBitmap(bitmap);
}
});
② `flatMap()` flatMap()的原理是這樣的:
- 使用傳入的事件對(duì)象創(chuàng)建一個(gè) Observable對(duì)象存璃;
- 并不發(fā)送這個(gè) Observable, 而是將它激活仑荐,于是它開始發(fā)送事件;
- 每一個(gè)創(chuàng)建出來的 Observable發(fā)送的事件纵东,都被匯入同一個(gè) Observable粘招,而這個(gè) Observable負(fù)責(zé)將這些事件統(tǒng)一交給 Subscriber的回調(diào)方法。這三個(gè)步驟偎球,把事件拆成了兩級(jí)洒扎,通過一組新創(chuàng)建的 Observable將初始的對(duì)象『鋪平』之后通過統(tǒng)一路徑分發(fā)了下去。而這個(gè)『鋪平』就是 flatMap()
所謂的 flat衰絮。
主要作用就是嵌套處理事件對(duì)象
** 關(guān)于線程切換的問題**
可以通過observeOn()
在map()
之前調(diào)用來切換map()
運(yùn)行的線程逊笆。如果調(diào)用subscribeOn()
設(shè)置,則無需關(guān)心放的位置岂傲,subscribeOn()
只會(huì)執(zhí)行一次,并且設(shè)置了subscribeOn()
之后不通過observeOn()
切換的話子檀,事件的發(fā)出和map()
變化都是在subscribeOn()
設(shè)置的線程中運(yùn)行镊掖。
Observable.just(1, 2, 3, 4) // IO 線程乃戈,由 subscribeOn() 指定
.subscribeOn(Schedulers.io())
.observeOn(Schedulers.newThread())
.map(mapOperator) // 新線程,由 observeOn() 指定
.observeOn(Schedulers.io())
.map(mapOperator2) // IO 線程亩进,由 observeOn() 指定
.observeOn(AndroidSchedulers.mainThread)
.subscribe(subscriber); // Android 主線程症虑,由 observeOn() 指定
算了篇幅太大,下面內(nèi)容還是詳看[給 Android 開發(fā)者的 RxJava 詳解](http://toutiao.io/shares/609182/url)吧
RxJava的管理組件的生命周期归薛,防止內(nèi)存泄露
RxLifecycle
RxBus:利用RxJava實(shí)現(xiàn)事件總線
2.Retrofit / OKHttp3
** Retrofit注解**
** 方法注解谍憔,包含@GET、@POST主籍、@PUT习贫、@DELETE、@PATH千元、@HEAD苫昌、@OPTIONS、@HTTP幸海。
** 標(biāo)記注解祟身,包含@FormUrlEncoded、@Multipart物独、@Streaming袜硫。
** 參數(shù)注解**,包含@Query,@QueryMap挡篓、@Body婉陷、@Field,@FieldMap瞻凤、@Part憨攒,@PartMap。
其他注解阀参,@Path肝集、@Header,@Headers、@Url
@Path
作用:用于替換Url路徑中的變量字符
示例:
@GET(“/unableape/url/{name}/get”)
Call getUnableApeName(@Header(“Authorization”) String authorization,@Path(“name”) String name );
@Query
作用:用于拼接在Url路徑后的查詢參數(shù)蛛壳,但相對(duì)于直接在Url后拼接杏瞻,@Query則是添加一個(gè)變量
示例:
@GET(“/unableape/url/get?name=”unableape”)
Call getUnableApeName(@Header(“Authorization”) String authorization);
等同于
@GET(“/unableape/url/get)
Call getUnableApeName(@Header(“Authorization”) String authorization,@Query(“name”) String name);
@QueryMap
作用:效果等同于多個(gè)@Query 參數(shù)為Map類型
示例:
@GET(“/unableape/url/get”)
Call getUnableApeOther(@QueryMap Map String, String> options);
@Body
請(qǐng)求方式:POST
所用:可以指定一個(gè)對(duì)象作為HTTP請(qǐng)求體
示例:
@Body @POST(“/unableape/post”)
Call createUser(@Body Name name);
@FormUrlEncoded/@Field
請(qǐng)求方式:POST
作用:@FormUrlEncoded修飾表單域,每個(gè)表單域子件key-value采用@Field修飾
示例:
@FormUrlEncoded
@POST(“/user/edit”)
Call updateUnableApeName(@Field(“first_name”) String first, @Field(“l(fā)ast_name”) String last);
@Part衙荐,@PartMap
請(qǐng)求方式:POST
作用:文件上傳捞挥。其中@Part MultipartBody.Part代表文件,@Part(“key”) RequestBody代表參數(shù)忧吟。需要添加@Multipart表示支持文件上傳的表單砌函,Content-Type: multipart/form-data
示例:
@Multipart
@POST("upload")
Call<ResponseBody> upload(@Part("description") RequestBody description,
@Part MultipartBody.Part file);
@Header
作用:header處理,不能被互相覆蓋,用于修飾參數(shù)讹俊,
示例:
//動(dòng)態(tài)設(shè)置Header值
@GET("user")
Call<User> getUser(@Header("Authorization") String authorization)
等同于
//靜態(tài)設(shè)置Header值
@Headers("Authorization: authorization")//這里authorization就是上面方法里傳進(jìn)來變量的值
@GET("widget/list")
Call<User> getUser()
@HTTP
可以替代其他方法的任意一種
/**
* method 表示請(qǐng)的方法垦沉,不區(qū)分大小寫
* path表示路徑
* hasBody表示是否有請(qǐng)求體
*/
@HTTP(method = "get", path = "users/{user}", hasBody = false)
Call<ResponseBody> getFirstBlog(@Path("user") String user);
@Url
作用:使用全路徑復(fù)寫baseUrl,適用于非統(tǒng)一baseUrl的場(chǎng)景仍劈。
示例:
@GET
Call<ResponseBody> v3(@Url String url);
@Streaming
作用:用于下載大文件
示例:
@Streaming
@GET
Call<ResponseBody> downloadFileWithDynamicUrlAsync(@Url String fileUrl);
ResponseBody body = response.body();
long fileSize = body.contentLength();
InputStream inputStream = body.byteStream();
//編譯RxJava
compile 'io.reactivex:rxjava:1.1.6'
//編譯RxAndroid
compile 'io.reactivex:rxandroid:1.2.1'
//編譯Retrofit及其相關(guān)庫(kù)厕倍,包括Gson
compile 'com.squareup.okhttp3:okhttp:3.3.1'
compile 'com.squareup.retrofit2:retrofit:2.1.0'
compile 'com.squareup.retrofit2:converter-gson:2.1.0'
compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
compile 'com.squareup.okhttp3:logging-interceptor:3.3.1'
注:有關(guān)Retrofit的gradle依賴參考Square官網(wǎng)的Retrofit
Retrofit 2.0: The biggest update yet on the best HTTP Client Library for Android
Retrofit最佳實(shí)踐
Retrofit 2.0 + OkHttp 3.0 配置
- Android 初識(shí)Retrofit
- Android Retrofit 實(shí)現(xiàn)文字(參數(shù))和多張圖片一起上傳
- Retrofit2.0使用總結(jié)及注意事項(xiàng)
- Retrofit系列文章翻譯
- Retrofit筆記
- 揭開Retrofit的神秘面紗
- Android 你必須了解的網(wǎng)絡(luò)框架Retrofit2.0
3.RxJava + Retrofit
4.事件總線
(1)EventBus
5. SnappyDB
6. FaceBook推出的Stetho
借助Stetho在Chrome上調(diào)試Android網(wǎng)絡(luò)&數(shù)據(jù)庫(kù)