如何用RxJava(Android)实现TextView输入后间隔1秒的连续搜索请求？

看起来你需要的是对用户每一次输入的内容都发起搜索，但严格控制两次请求的发起间隔至少1秒，而debounce（防抖）是丢弃高频事件只保留最后一个，完全不符合你的需求；至于delay引发Looper异常，大概率是线程调度没处理好——delay默认在非主线程执行，如果后续直接操作UI就会出问题。

下面给你两种符合需求的实现方案，你可以根据实际场景选择：

方案一：固定间隔发起请求（不管前一次请求是否完成） #

这个方案严格按照「输入a→1秒后请求ab→再过1秒请求abc」的逻辑执行，两次请求的发起时间间隔固定为1秒，适合不在乎请求并发、只要求发起间隔的场景。

代码实现： #

// 1. 获取用户输入的Observable（以EditText为例）
Observable<String> userInputObservable = RxTextView.textChanges(editText)
        .map(CharSequence::toString)
        .distinctUntilChanged() // 过滤重复的文本变化（比如连续输入相同字符）
        .skipInitialValue(); // 可选：跳过EditText的初始默认文本，根据你的需求调整

// 2. 创建一个计时器Observable：第一个事件立即发出，之后每隔1秒发一个事件
Observable<Long> intervalTimer = Observable.timer(0, 1, TimeUnit.SECONDS, Schedulers.io());

// 3. 把输入事件和计时器事件配对，保证每个请求间隔1秒发起
Observable.zip(userInputObservable, intervalTimer, (inputText, timestamp) -> inputText)
        .concatMap(query -> performSearch(query)) // 执行搜索请求
        .observeOn(AndroidSchedulers.mainThread()) // 切换回主线程处理结果
        .subscribe(
                searchResult -> {
                    // 这里处理搜索结果，比如更新RecyclerView或TextView
                },
                throwable -> {
                    // 处理请求错误，比如显示Toast
                }
        );

// 你的搜索请求方法（例子）
private Observable<SearchResult> performSearch(String query) {
    return Observable.fromCallable(() -> {
        // 这里写同步的搜索逻辑：比如调用Retrofit接口、查询数据库
        return yourApiService.search(query);
    }).subscribeOn(Schedulers.io()); // 让请求在IO线程执行，避免阻塞主线程
}

为什么这样写： #

• zip操作符会把输入序列和计时器序列一一配对，第一个输入（a）和计时器的0秒事件配对，立即发起请求；第二个输入（ab）和计时器的1秒事件配对，1秒后发起请求，以此类推，完美匹配你的示例逻辑。
• subscribeOn(Schedulers.io())和observeOn(AndroidSchedulers.mainThread())严格区分了工作线程和UI线程，从根源上避免Looper异常。

方案二：前一次请求完成后再间隔1秒发起下一个 #

如果你的场景要求必须等前一次搜索请求完全结束（拿到结果或报错），再过1秒才发起下一个请求，就用这个方案：

代码实现： #

// 标记是否是第一次请求
AtomicBoolean isFirstRequest = new AtomicBoolean(true);

RxTextView.textChanges(editText)
        .map(CharSequence::toString)
        .distinctUntilChanged()
        .skipInitialValue()
        .concatMap(query -> {
            Observable<String> queryObservable = Observable.just(query);
            // 不是第一次请求的话，延迟1秒再执行
            if (!isFirstRequest.getAndSet(false)) {
                queryObservable = queryObservable.delay(1, TimeUnit.SECONDS, Schedulers.io());
            }
            return queryObservable.flatMap(this::performSearch);
        })
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
                searchResult -> { /* 处理结果 */ },
                throwable -> { /* 处理错误 */ }
        );

核心逻辑： #

• concatMap会严格按顺序处理每个输入事件，必须等前一个请求的Observable完成，才会处理下一个。
• 第一次请求直接执行，后续每个请求都先延迟1秒，再发起搜索，保证两次请求的完成时间间隔至少1秒。

常见问题规避 #

1. Looper异常：永远不要在非主线程更新UI，所有需要操作UI的逻辑都要放在observeOn(AndroidSchedulers.mainThread())之后的回调里。
2. 重复请求：distinctUntilChanged可以过滤掉用户输入的重复内容（比如连续输入同一个字符），避免无效请求。
3. 内存泄漏：记得在Activity/Fragment销毁时，调用Disposable.dispose()取消订阅，防止内存泄漏。

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