ssential rxjava操作員用於有效的異步編程-java教程-PHP中文網

ssential RxJava Operators for Efficient Asynchronous Programming

作為一位多產的作者，我鼓勵您在亞馬遜上探索我的書。請記住，在媒體上關注我的工作以持續支持。謝謝您的讀者！您的訂婚是無價的。

RXJAVA已在Java應用程序中轉換了異步數據流管理。我在這個庫中的經驗強調了它在簡化複雜的異步任務和增強代碼清晰度方面的力量。本文重點介紹了我項目中經常使用的五個基本RXJAVA運營商。

>讓我們從

開始。該操作員是創建自定義可觀察物的基礎，使現有的異步API或新數據源的開發可以集成。當將RXJAVA與遺留系統或缺乏本地反應性支持的第三方庫集成時，這尤其有用。

> Observable.create()這是一個簡明的示例

這種方法顯著改善了我的工作流程，而API固有地反應性。適當的未訂閱處理對於防止記憶洩漏至關重要：

Observable.create()

下一步，

<code class="language-java">Observable<String> wrapCallbackApi(CallbackBasedApi api) {
    return Observable.create(emitter -> {
        api.fetchData(new Callback() {
            @Override
            public void onSuccess(String result) {
                emitter.onNext(result);
                emitter.onComplete();
            }

            @Override
            public void onError(Exception e) {
                emitter.onError(e);
            }
        });
    });
}</code>

登入後複製

是一個變革性操作員。它的多功能性允許可觀察到的項目轉換為新的可觀察物，然後將其變為單個流。這對於嵌套異步操作是無價的。

考慮獲取用戶詳細信息，然後考慮他們的最新訂單：

<code class="language-java">Observable<String> wrapCallbackApi(CallbackBasedApi api) {
    return Observable.create(emitter -> {
        Disposable disposable = api.fetchData(new Callback() {
            @Override
            public void onSuccess(String result) {
                emitter.onNext(result);
                emitter.onComplete();
            }

            @Override
            public void onError(Exception e) {
                emitter.onError(e);
            }
        });

        emitter.setCancellable(disposable::dispose);
    });
}</code>

登入後複製

flatMap()

優雅地管理異步操作之間的過渡，從而產生了乾淨且可讀的操作鏈。通過處理快速用戶輸入，可以防止不必要的API呼叫，操作員在UI開發方面表現出色。它經常用於搜索功能來優化服務器請求：

<code class="language-java">Observable<User> getUser(int userId) {
    return userApi.getUser(userId);
}

Observable<List<Order>> getRecentOrders(User user) {
    return orderApi.getRecentOrders(user.getId());
}

Observable<List<Order>> getUserRecentOrders(int userId) {
    return getUser(userId)
        .flatMap(user -> getRecentOrders(user));
}</code>

登入後複製

此代碼在觸發搜索之前引入了300毫秒延遲，大大減少了客戶端和服務器加載。

> flatMap()強大的錯誤處理至關重要。

>操作員通過自動在錯誤時自動重新訂閱源來促進彈性錯誤處理，從而從瞬態失敗中恢復。

這是一個使用debounce()的示例，並具有指數向後策略：>

<code class="language-java">searchView.textChanges()
    .debounce(300, TimeUnit.MILLISECONDS)
    .flatMap(query -> api.search(query))
    .subscribe(this::updateResults);</code>

登入後複製

這會隨著延遲的增加而嘗試最多三次數據檢索。如果所有嘗試都失敗了，則該錯誤將傳播。

>最後，

>可用於高頻事件或批處理操作以提高效率。它將將項目散佈在捆綁中，將這些捆綁包作為新的可觀察物。一個常見的用例是批處理API請求：retry()

<code class="language-java">Observable<String> wrapCallbackApi(CallbackBasedApi api) {
    return Observable.create(emitter -> {
        api.fetchData(new Callback() {
            @Override
            public void onSuccess(String result) {
                emitter.onNext(result);
                emitter.onComplete();
            }

            @Override
            public void onError(Exception e) {
                emitter.onError(e);
            }
        });
    });
}</code>

登入後複製

這將收集100毫秒或收集50個物品的物品，然後將它們作為批量發送到API。

這五個運算符 -

，Observable.create()>，flatMap()，debounce()和retry()> - 是基礎，但是rxjava提供了更多。像buffer()，map()，filter()，merge()，concat()，zip()，onErrorResumeNext()，onErrorReturn()，switchMap()，distinct()，sample()，throttleFirst()，CompositeDisposable，