Room Database中LiveData观察者回调次数多于表内实际行数问题

我在Room数据库的friend_table表内仅存入了1行数据，但调用DAO查询_id字段时，绑定的LiveData观察者触发了两次回调，两次返回的列表均仅包含同一个_id值，不清楚这是Room的固有工作机制，还是我在实现过程中遗漏了某些配置，相关代码如下：

实体类代码 #

@Entity(tableName = "friend_table")
class FriendModel
    : Serializable {
    @PrimaryKey
    @NonNull
    var _id: String = ""
    ...
}

DAO接口代码 #

@Dao
interface FriendDAO {
    ...
    @Query("select _id from friend_table")
    fun readRoomIdFriendsDAO() : LiveData<List<String>>
}

Repository层代码 #

class UserRepository(private val userAPI: UserAPI, context : Context) {
    private val userDAO : UserDAO
    private val friendDAO : FriendDAO
    init {
        val userDatabase: UserRoomDatabase = UserRoomDatabase.getInstance(context)
        val friendDatabase: FriendRoomDatabase = FriendRoomDatabase.getInstance(context)

        userDAO = userDatabase.getUserDao()
        friendDAO = friendDatabase.getFriendDao()
    }
    ...
    fun readRoomIdFriendsDAO() : LiveData<List<String>> = friendDAO.readRoomIdFriendsDAO()
    
}

ViewModel层代码 #

class UserViewModel(private val userRepository: UserRepository) : ViewModel() {
      ...
      fun readRoomIdFriendsDAO() : LiveData<List<String>> = userRepository.readRoomIdFriendsDAO()
}

观察调用代码（MainActivity） #

viewModel.readRoomIdFriendsDAO().observe(this,{ listRoomId ->
            if(listRoomId!=null && listRoomId.isNotEmpty()){
                for(item in listRoomId){
                    Log.e(TAG, "RoomId: $listRoomId")
                }
            }
        })

日志输出 #

E/Log: RoomId: [IZnIP4srwDZiB1foauiZF6R60RF3]
...
E/Log: RoomId: [IZnIP4srwDZiB1foauiZF6R60RF3]

常见触发原因 #

• LiveData固有派发逻辑：首次注册观察者时，LiveData会先返回当前缓存的默认值作为第一次回调，等Room完成磁盘IO查询到真实数据后，会再次触发回调返回实际查询结果，此时如果数据无变更，两次返回内容完全一致。
• 关联表写操作触发：只要friend_table表发生任意写入操作（包括插入、更新、删除，哪怕修改的是和当前查询无关的字段），Room都会自动触发所有查询该表的LiveData重新拉取数据，触发回调。
• 重复注册观察者：如果在onResume、onStart这类会被多次调用的生命周期方法中执行observe注册，会生成多个观察者，每个观察者都会独立收到数据回调。

修复方案 #

方案1：使用单次查询替代LiveData（适合仅需拉取一次数据的场景） #

将DAO方法改为suspend函数直接返回查询结果，不需要包LiveData，用协程调用即可避免多次回调：

// DAO层修改
@Query("select _id from friend_table")
suspend fun readRoomIdFriendsDAO() : List<String>

方案2：添加去重操作符（适合需要监听表变动的场景） #

使用distinctUntilChanged()操作符，仅当查询结果和上一次返回内容不同时才触发观察者回调，修改方式如下：

// ViewModel层修改
fun readRoomIdFriendsDAO() : LiveData<List<String>> = 
    userRepository.readRoomIdFriendsDAO().distinctUntilChanged()

方案3：检查观察者注册逻辑 #

确保observe方法仅在onCreate这类生命周期只会调用一次的方法中执行，避免重复注册观察者。

内容的提问来源于stack exchange，提问作者Lộc Trần Phước