RxJava 在Android中的應(yīng)用

• RxJava 是什么, 能解決什么問題
• 對比其他技術(shù)理解為什么要選擇RxJava
• RxJava的相關(guān)API
• RxJava在Android中的典型使用場景
• RxJava在Android中與其他框架的融合

---

RxJava 是什么, 能解決什么問題

• github官方介紹:

  a library for composing asynchronous and event-based programs by using observable sequences.
  一個在運行在Java VM上的庫, 通過可觀測的序列來組成異步的、基于事件的程序。

• 解決問題:

  讓復(fù)雜的程序邏輯回歸簡單、清晰

• RxJava 的四個基本概念：

  • Observable (可觀察者/被觀察者)
  • Observer (觀察者/訂閱者)
  • subscribe (訂閱)
  • Event (事件)

如何使用

• build.gradle引入依賴

  compile 'io.reactivex:rxandroid:1.2.0' compile 'io.reactivex:rxjava:1.1.4'

• 源碼地址

  https://github.com/ReactiveX/RxJava https://github.com/ReactiveX/RxAndroid

對比其他技術(shù)理解為什么要選擇RxJava

• Observable(被觀察者) 和Subscriber(訂閱者) 可以做任何事情

  • Observable可以是一個網(wǎng)絡(luò)請求，Subscriber來顯示請求結(jié)果;
  • Observable可以是一個數(shù)據(jù)庫查詢，Subscriber來顯示查詢結(jié)果；
  • Observable可以是按鈕點擊事件，Subscriber來響應(yīng)點擊事件；
  • Observable可以是大圖片文件的加載解析, Subscriber來展示解析后的圖片。

RxJava的相關(guān)API

• Observable 可觀察者/被觀察者

• Observer/Subscriber (觀察者/訂閱者)

• 操作符(Operators)(常用的)

  • map 轉(zhuǎn)換對象
  • flatMap 平鋪對象

  - filter 過濾

  • distinct 去重復(fù)(獨特的)
  • take 從開始取出固定個數(shù)
  • doOnNext 輸出元素之前的額外操作
  • toList 打包對象為集合

• Scheduler 調(diào)度器, 用于線程控制

  • Schedulers.immediate() 默認(rèn)線程
  • Schedulers.newThread() 每次都創(chuàng)建新的線程執(zhí)行
  • Schedulers.io() 包含線程池的機(jī)制, 線程個數(shù)無限, 可以復(fù)用空閑線程
  • Schedulers.computation() CPU密集計算線程, 線程池線程數(shù)和CPU數(shù)一致.處理圖形運算
  • AndroidSchedulers.mainThread() Android更新界面的UI主線程

• subscribeOn 可執(zhí)行多次, 切換操作符的線程

• observeOn 只需要執(zhí)行一次, 指定訂閱者執(zhí)行的線程

添加java8的lambda支持

參見: https://github.com/evant/gradle-retrolambda

RxJava 使用流程

創(chuàng)建 Observable 被觀察者

初始化被觀察(訂閱)后的事件序列

創(chuàng)建 Observer/Subscriber 觀察者/訂閱者

訂閱 Subscribe

RxJava在Android中的典型使用場景

• Scheduler線程切換
• 定時任務(wù) timer
• 周期任務(wù) interval
• 合并多個請求 merge
• 防止連續(xù)點擊 throttleFirst
• 解決回調(diào)嵌套Callback hell, flatMap
• 其他…

RxJava在Android中與其他框架的融合 （了解）

• RxBinding: https://github.com/JakeWharton/RxBinding

  //添加依賴 compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'// 相關(guān)代碼 Button button = (Button)findViewById(R.id.bt); RxView.clickEvents(button) // 設(shè)置點擊事件.subscribe(new Action1<ViewClickEvent>() {@Overridepublic void call(ViewClickEvent event) {// Click handling}});

• Retrofit: https://github.com/square/retrofit

  // 添加依賴 compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4' compile 'com.squareup.retrofit2:adapter-rxjava:2.0.0-beta4' compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'// 相關(guān)代碼 new Retrofit.Builder().baseUrl("http://192.168.1.113:8080/").addCallAdapterFactory(RxJavaCallAdapterFactory.create()).addConverterFactory(GsonConverterFactory.create()).build().create(RxDemoApi.class);

總結(jié)

以上是生活随笔為你收集整理的RxJava 在Android中的应用(一)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。