Room Flowable多次触发问题：distinctUntilChanged未生效排查

嘿，我来帮你捋清楚这个问题的根源和解决办法～

首先明确你的核心问题：你用Room定义了一个只查询特定ID（61）Team的Flowable接口，但只要Team表中任意一行发生变更，这个订阅就会触发回调，哪怕变更的不是ID=61的Team。你尝试用distinctUntilChanged()来解决，但没起作用。

为什么会出现这个情况？ #

这里有两个关键原因：

1. Room的Flowable查询机制：Room的Flowable查询是监听整个表的变化——只要表中有任何写入操作（insert/update/delete），不管是不是你查询的那一行，Room都会重新执行你的查询，然后发射新的结果。
2. distinctUntilChanged()的默认行为：这个操作符默认是通过对象引用来判断前后两个值是否相同的。而Room每次重新查询时，都会返回一个新的Team对象实例（哪怕这个实例的所有字段和之前的完全一致）。所以默认的distinctUntilChanged()会认为这是两个不同的对象，就会触发订阅回调。

解决办法 #

方法1：给Team实体类重写equals()和hashCode() #

这是最推荐的方案，因为实体类本来就应该实现这两个方法来判断内容相等。你需要基于Team的所有字段（或者至少是能唯一标识内容的关键字段）来重写这两个方法。

示例代码：

@Entity(tableName = "teams", foreignKeys = { /* 你的外键定义 */ })
public class Team {
    @PrimaryKey
    private int id;
    private String name;
    private int userId;
    // 其他字段...

    // Getter和Setter方法...

    @Override
    public boolean equals(Object o) {
        if (this == o) return true;
        if (o == null || getClass() != o.getClass()) return false;
        Team team = (Team) o;
        return id == team.id &&
               userId == team.userId &&
               Objects.equals(name, team.name);
        // 记得把其他字段也加入比较
    }

    @Override
    public int hashCode() {
        return Objects.hash(id, name, userId);
        // 对应equals里的字段，都加入hash计算
    }
}

重写之后，distinctUntilChanged()就会通过内容来判断是否重复，只要两次查询返回的Team内容一致，就不会触发订阅。

方法2：使用distinctUntilChanged()的自定义比较器 #

如果你不想修改Team类的equals/hashCode，可以用distinctUntilChanged()的重载版本，传入一个自定义的比较逻辑：

teamRepository.getRivals(61)
    .distinctUntilChanged((oldTeam, newTeam) -> {
        // 这里自定义判断逻辑，返回true表示两个对象内容相同，不会发射新值
        return oldTeam.getId() == newTeam.getId() &&
               Objects.equals(oldTeam.getName(), newTeam.getName()) &&
               oldTeam.getUserId() == newTeam.getUserId();
        // 同样要覆盖所有需要比较的字段
    })
    .observeOn(SchedulerProvider.getInstance().ui())
    .subscribeOn(SchedulerProvider.getInstance().computation())
    .subscribe(team -> Log.d("HomeActivity", team.getName()));

额外说明 #

Room的这种设计是合理的——因为表的任何变更都有可能影响你的查询结果（虽然在这个场景下不会，但Room无法提前判断），所以它会重新执行查询。咱们要做的就是通过distinctUntilChanged()过滤掉内容重复的结果，而核心就是让这个操作符能正确判断两个Team对象是否内容一致。

内容的提问来源于stack exchange，提问作者Muhammad Ahmed AbuTalib