如何在UI事件中仅订阅一次RxJava2的Observable网络请求？

一、RxBinding的实现方式是否正确？ #

完全正确。RxBinding的核心价值就是将Android原生View事件（如按钮点击）转化为RxJava Observable流，借助RxJava丰富的操作符，能非常优雅地实现防重复请求逻辑。

针对你说的按钮点击触发网络请求场景，常用的处理方式是结合throttleFirst（短时间内仅响应首次点击）或switchMap（新点击触发时自动取消未完成的旧请求），示例代码如下（Kotlin）：

// 需引入RxBinding依赖
import com.jakewharton.rxbinding2.view.clicks

button.clicks()
    .throttleFirst(1, TimeUnit.SECONDS) // 1秒内屏蔽重复点击
    .switchMap { apiService.fetchData() } // 新请求触发时取消旧请求
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        { data -> /* 处理返回数据 */ },
        { error -> /* 处理请求错误 */ }
    )

这种方式无需手动维护请求状态，利用RxJava的流控能力就能统一管理事件与请求的生命周期，代码简洁且可维护性高。

二、不使用RxBinding的替代方案 #

如果项目中未引入RxBinding，核心思路是手动维护请求的活跃状态，确保同一时间只有一个网络请求在执行。以下是两种常用实现：

方案1：通过布尔变量标记请求状态 #

private var isRequestInProgress = false

button.setOnClickListener {
    if (!isRequestInProgress) {
        isRequestInProgress = true
        apiService.fetchData()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(
                { data ->
                    // 处理数据
                    isRequestInProgress = false
                },
                { error ->
                    // 处理错误
                    isRequestInProgress = false
                }
            )
    }
}

⚠️ 注意：必须在请求成功、失败、被取消的所有场景下重置isRequestInProgress，否则会导致按钮永久无法触发新请求。

方案2：利用Disposable管理请求生命周期 #

private var activeRequest: Disposable? = null

button.setOnClickListener {
    // 检查是否有未完成的请求
    activeRequest?.takeIf { !it.isDisposed }?.let {
        return@setOnClickListener
    }
    // 发起新请求并持有Disposable
    activeRequest = apiService.fetchData()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
            { data ->
                // 处理数据
                activeRequest = null
            },
            { error ->
                // 处理错误
                activeRequest = null
            }
        )
}

// 在页面销毁时取消未完成的请求，避免内存泄漏
override fun onDestroy() {
    super.onDestroy()
    activeRequest?.dispose()
}

这种方式更贴合RxJava的使用习惯，通过Disposable的状态判断请求是否活跃，同时能在页面销毁时及时清理资源，降低内存泄漏风险。

内容的提问来源于stack exchange，提问作者SmallGrammer