使用RxJava搭配Room时出现循环问题求助

看起来你遇到的问题其实是Room查询的特性导致的——Room的可观察查询（比如返回Flowable/Observable）会持续监听数据库变化，当你插入数据后，数据库的变更会触发查询再次发射结果，进而让你的订阅逻辑重复执行。下面给你拆解问题根源和具体的解决办法：

问题根源 #

默认情况下，Room的@Query如果返回Flowable<T>或Observable<T>，它是一个热流，会一直监听对应表的变化。当你插入新数据后，数据库发生变更，这个查询就会自动发射最新的查询结果，导致你的订阅回调再次被触发。你看到计数器变为1后停止，大概率是第一次回调发现无数据、执行插入；第二次回调拿到了刚插入的数据，不再执行插入，所以没有无限循环，但触发了两次回调，这和你预期的"只执行一次查询+插入"不符。

解决方案 #

根据你的需求，分两种场景给出方案：

场景1：只需要单次查询，不需要持续监听 #

如果你的逻辑只是"检查当天有没有数据，没有就插入"，不需要实时监听数据库变化，那直接把DAO的查询方法改成返回Maybe<T>或Single<T>即可——这两种类型只会发射一次结果，不会持续监听。

第一步：修改DAO层代码

把原来的可观察查询改成单次查询：

// 原来的代码（持续监听）
@Query("SELECT * FROM test_models WHERE date = :date LIMIT 1")
Flowable<TestModel> getTestModelByDate(String date);

// 修改后（单次查询）
@Query("SELECT * FROM test_models WHERE date = :date LIMIT 1")
Maybe<TestModel> getTestModelByDate(String date);

第二步：调整RxJava调用逻辑

用switchIfEmpty来优雅处理"无数据则插入"的逻辑，避免重复触发：

private void getTestModel() {
    String date = new SimpleDateFormat("dd-MM-yyyy", Locale.getDefault()).format(new Date());
    testDao.getTestModelByDate(date)
        .subscribeOn(Schedulers.io()) // 数据库操作放IO线程
        .observeOn(AndroidSchedulers.mainThread())
        .switchIfEmpty(Single.fromCallable(() -> {
            // 无数据时创建实例并插入
            TestModel newModel = new TestModel(date); // 按你的需求初始化字段
            testDao.insertTestType(newModel);
            return newModel;
        }))
        .subscribe(
            model -> {
                // 处理拿到的模型（不管是查询到的还是刚插入的）
                Log.d("TestTag", "成功获取模型: " + model.toString());
            },
            throwable -> {
                // 处理异常
                Log.e("TestTag", "操作失败", throwable);
            }
        );
}

场景2：需要持续监听数据库变化（比如实时更新UI） #

如果你确实需要实时监听数据变化，那就要在订阅回调里做判断，避免重复插入：

private void getTestModel() {
    String date = new SimpleDateFormat("dd-MM-yyyy", Locale.getDefault()).format(new Date());
    testDao.getTestModelsByDate(date)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
            models -> {
                if (models.isEmpty()) {
                    // 只有当无数据时才执行插入
                    TestModel newModel = new TestModel(date);
                    testDao.insertTestType(newModel);
                } else {
                    // 有数据时执行你的业务逻辑
                    Log.d("TestTag", "已存在数据: " + models.get(0).toString());
                }
            },
            throwable -> {
                Log.e("TestTag", "操作失败", throwable);
            }
        );
}

这种情况下，插入数据后会触发第二次回调，但此时models不为空，不会再执行插入，所以只会触发一次插入操作，不会无限循环。

额外注意事项 #

• 确保所有数据库操作（查询、插入）都在IO线程执行，Room不允许在主线程操作数据库，所以一定要用subscribeOn(Schedulers.io())切换线程。
• 区分RxJava中Maybe/Single/Flowable的差异：Maybe发射0或1个数据，Single必发射1个数据或错误，Flowable持续发射数据，根据你的需求选对应类型。

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