什么是響應(yīng)式編程?

????????響應(yīng)式編程是一種基于異步數(shù)據(jù) 流概念的編程模式。數(shù)據(jù)流就像一條河：它可以被觀測(cè)，被過(guò)濾，被操作，或者為新的消費(fèi)者與另外一 條流合并為一條新的流。

什么是RxJava?

• ?RxJava 是一種響應(yīng)式編程，來(lái)創(chuàng)建基于事件的異步操作庫(kù)。基于事件流的鏈?zhǔn)秸{(diào)用、邏輯清晰簡(jiǎn)潔。?
• RxJava 我的理解是將事件從起點(diǎn)（上游）流向終點(diǎn)（下游），中間有很多卡片對(duì)數(shù)據(jù)進(jìn)操作并傳 遞，每個(gè)卡片獲取上一個(gè)卡片傳遞下來(lái)的結(jié)果然后對(duì)事件進(jìn)行處理然后將結(jié)果傳遞給下一個(gè)卡片， 這樣事件就從起點(diǎn)通過(guò)卡片一次次傳遞直到流向終點(diǎn)。

RxJava本質(zhì)上是一個(gè)異步操作庫(kù)，是一個(gè)能讓你用極其簡(jiǎn)潔的邏輯去處理繁瑣復(fù)雜任務(wù)的異步事件庫(kù)。?

觀察者模式

????????Android中View的點(diǎn)擊監(jiān)聽(tīng)器的實(shí)現(xiàn)，View是被觀察者，OnClickListener對(duì)象是觀察者， Activity要如何知道View被點(diǎn)擊了？那就是派一個(gè)OnClickListener對(duì)象，入駐View，與View達(dá)成一個(gè)訂 閱關(guān)系，一旦View被點(diǎn)擊了，就通過(guò)OnClickListener對(duì)象的OnClick方法傳達(dá)給Activity。采用觀察者模 式可以避免去輪詢(xún)檢查，節(jié)約有限的cpu資源。

Retrofit+OkHTTP+RxJava+RecycleView的實(shí)現(xiàn)步驟?

要引入項(xiàng)目依賴(lài)

//添加RxJava依賴(lài) implementation "io.reactivex.rxjava3:rxjava:3.0.0" //添加RxAndroid依賴(lài)，專(zhuān)門(mén)用于Android的Rx庫(kù) implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'//銜接 Retrofit & RxJava，此處一定要注意使用RxJava2的版本 implementation 'com.squareup.retrofit2:adapter-rxjava2:2.5.0' //添加Retrofit依賴(lài) implementation 'com.squareup.retrofit2:retrofit:2.5.0' //添加Gson解析 implementation 'com.squareup.retrofit2:converter-gson:2.5.0' //添加圖片加載庫(kù)依賴(lài) implementation 'com.github.bumptech.glide:glide:4.12.0'

?首先要定義接口

public interface GETInterface {@GET("api/hotlist?type=36Ke")Observable<News> getObservable();}

然后是在Activity中的實(shí)現(xiàn)方法?

?創(chuàng)建請(qǐng)求接口

開(kāi)始網(wǎng)絡(luò)請(qǐng)求

處理返回結(jié)果

private void getObservable() {Retrofit retrofit=new Retrofit.Builder().baseUrl("https://api.vvhan.com/").addConverterFactory(GsonConverterFactory.create()).addCallAdapterFactory(RxJava2CallAdapterFactory.create()).build();GETInterface request = retrofit.create(GETInterface.class);Observable<News> observable = request.getObservable();observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Observer<News>() {@Overridepublic void onSubscribe(Disposable d) {}@Overridepublic void onNext(News news) {adapter.setNews(news.getData());}@Overridepublic void onError(Throwable e) {Log.i("onError", "連接失敗");}@Overridepublic void onComplete() {Log.i("onComplete", "連接完成");}});}

總結(jié)

以上是生活随笔為你收集整理的Retrofit+OKHttp+RxJava的使用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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