RxJava如何取消订阅

在 RxJava 中，“取消订阅”本质上就是 切断 Observable 和 Observer 之间的订阅关系，不再接收事件。常见方式如下（以 RxJava2 / RxJava3 为主）：

一、使用 Disposable（最常用 ✅）

1️⃣ 订阅时拿到 Disposable

Disposable disposable = Observable.just(1, 2, 3)
        .subscribe(
                value -> Log.d("Rx", "onNext: " + value),
                error -> Log.e("Rx", "onError", error),
                () -> Log.d("Rx", "onComplete")
        );

2️⃣ 取消订阅

disposable.dispose();

3️⃣ 判断是否已取消

if (!disposable.isDisposed()) {
    disposable.dispose();
}

二、使用 CompositeDisposable（推荐在 Activity / Fragment 中使用 ✅）

适合 统一管理多个订阅。

CompositeDisposable compositeDisposable = new CompositeDisposable();

Disposable d1 = Observable.interval(1, TimeUnit.SECONDS)
        .subscribe(t -> Log.d("Rx", "tick"));

Disposable d2 = Observable.just(1, 2, 3).subscribe();

compositeDisposable.add(d1);
compositeDisposable.add(d2);

// 退出页面时统一取消
@Override
protected void onDestroy() {
    super.onDestroy();
    compositeDisposable.clear(); // 或 dispose()
}

clear() vs dispose()

三、使用 takeUntil / takeWhile（自动取消）

条件自动停止

Observable.interval(1, TimeUnit.SECONDS)
        .takeUntil(v -> v == 5)
        .subscribe(v -> Log.d("Rx", "v=" + v));

根据另一个 Observable 取消

Observable.interval(1, TimeUnit.SECONDS)
        .takeUntil(Observable.timer(5, TimeUnit.SECONDS))
        .subscribe();

四、使用 switchMap / flatMap 自动取消旧任务

searchSubject
    .debounce(300, TimeUnit.MILLISECONDS)
    .switchMap(key -> api.search(key))
    .subscribe();

switchMap 会在新事件到来时 自动取消上一个订阅。

五、在 RxBinding / UI 场景中（Android）

通常结合 AutoDispose 或 Lifecycle：

Observable.timer(3, TimeUnit.SECONDS)
    .as(AutoDispose.autoDisposable(AndroidLifecycleScopeProvider.from(this)))
    .subscribe();

六、总结 ✅

如果你愿意，可以告诉我你是 RxJava2 还是 3、Android 还是后端，我可以给你更具体的示例。