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，