由 RxJava 掌握流动数据处理的艺术，探索 RxJava 2.x 操作符中的retry、doOnNext和doAfterTerminate

Android

2023-10-24 15:05:40

序曲：揭开 RxJava 的神秘面纱

作为 Java 开发者，我们常常会遇到需要处理海量数据流的情况，例如网络请求、传感器数据采集、用户事件跟踪等。面对这些实时不断涌现的数据，传统的面向对象编程往往捉襟见肘，难以从容应对。

幸运的是，RxJava 闪耀登场了！它是一款强大的响应式编程框架，专门为处理异步和基于事件的编程而设计。凭借其简洁易懂的 API 和强大的功能，RxJava 迅速成为众多开发者的不二之选。

第一乐章：重试的艺术 - retry操作符

在现实世界中，网络中断、服务器故障等问题时有发生。当我们的程序遇到这些问题时，直接抛出异常显然不是最佳方案。retry 操作符的魅力就在于它允许我们在遇到错误时自动重试，为我们带来重拾希望的机会。

retry 的用法非常简单，只需在需要重试的 Observable 末尾添加它即可。你可以指定重试次数或指定重试延迟时间，甚至两者兼而有之。

例如，以下代码演示了如何使用 retry 操作符重试3次：

Observable.create(emitter -> {
    // 产生一个随机数
    int randomNumber = new Random().nextInt(10);

    // 如果随机数小于5，则抛出异常
    if (randomNumber < 5) {
        emitter.onError(new RuntimeException("随机数小于5"));
    } else {
        // 否则，发送随机数
        emitter.onNext(randomNumber);
        emitter.onComplete();
    }
})
.retry(3)
.subscribe(System.out::println, Throwable::printStackTrace);

第二乐章：数据处理的交响曲 - doOnNext操作符

在数据流处理中，我们经常需要对数据进行一些处理，例如过滤、映射、变换等。doOnNext 操作符就是我们的得力助手，它允许我们在接收到数据时对数据进行处理。

doOnNext 的用法也很简单，只需要在需要处理数据的 Observable 中间添加它即可。你可以通过 lambda 表达式来指定数据处理逻辑。

例如，以下代码演示了如何使用 doOnNext 操作符过滤掉小于5的数据：

Observable.create(emitter -> {
    // 产生一个随机数
    int randomNumber = new Random().nextInt(10);

    // 发送随机数
    emitter.onNext(randomNumber);
    emitter.onComplete();
})
.doOnNext(value -> {
    // 如果数据小于5，则过滤掉
    if (value < 5) {
        emitter.onNext(value);
    }
})
.subscribe(System.out::println);

第三乐章：完成通知的圆舞曲 - doAfterTerminate操作符

当 Observable 完成或遇到错误时，doAfterTerminate 操作符会收到通知。这使得我们可以对 Observable 的完成或错误情况进行一些处理，例如记录日志、发送通知、释放资源等。

doAfterTerminate 的用法也比较简单，只需要在 Observable 的末尾添加它即可。你可以通过 lambda 表达式来指定完成或错误处理逻辑。

例如，以下代码演示了如何使用 doAfterTerminate 操作符记录日志：

Observable.create(emitter -> {
    // 产生一个随机数
    int randomNumber = new Random().nextInt(10);

    // 发送随机数
    emitter.onNext(randomNumber);
    emitter.onComplete();
})
.doAfterTerminate(() -> {
    // 记录日志
    System.out.println("Observable 已完成");
})
.subscribe(System.out::println);