android - Room 返回的 Livedata GC 后不会触发
问题描述
我们的团队正在构建一个受益于 Android Jetpack 的项目。
有演示代码显示了我们面临的问题。这些代码可以在https://github.com/viseator/TestRoomLivedata找到
我创建一个UserDao
:
@Dao
interface UserDao {
@Query("SELECT * FROM user WHERE uid = :uid LIMIT 1")
fun findUserById(uid: String?): Single<User>
@Query("SELECT * FROM user WHERE state = 1 LIMIT 1")
fun findLoginUserWithObserve(): LiveData<User>
@Query("SELECT * FROM user WHERE state =1 LIMIT 1")
fun findLoginUser(): Single<User>
@Update
fun update(vararg user: User)
}
我还创建了一个 kotlin 对象来管理用户的状态。
我正在观察返回的实时数据,findLoginUserWithObserve()
以便在登录用户更改时得到通知:
object AccountManager {
private const val DATA_BASE_NAME = "users"
val TAG = "AccountManager"
fun init(context: Application) {
sDb = databaseBuilder(context, UserDataBase::class.java, DATA_BASE_NAME).build()
sDao = sDb.userDao()
sDao.findLoginUserWithObserve().observeForever {
Log.d(TAG, "notified: $it")
}
}
private lateinit var sDb: UserDataBase
private lateinit var sDao: UserDao
fun findLoginUserWithObserve() = sDao.findLoginUserWithObserve()
fun logoutFlowable(): Single<Boolean> = sDao.findLoginUser().subscribeOn(
Schedulers.io()).map { user ->
user.state = User.STATE_NOT_LOGIN
sDao.update(user)
true
}
fun login(user: User) = logoutFlowable().subscribe({ doLogin(user) }, { doLogin(user) })
private fun doLogin(user: User) = sDao.findUserById(user.uid).subscribeOn(
Schedulers.io()).subscribe({ origin ->
origin.userName = user.userName
origin.state = User.STATE_HAVE_LOGIN
sDao.update(origin)
user.state = User.STATE_HAVE_LOGIN
}, {
user.state = User.STATE_HAVE_LOGIN
sDao.insert(user)
})
}
我通过调用它的AccountManager
方法来初始化它并创建一个演示活动:Applicaiton
init
class MainActivity : AppCompatActivity() {
private var i = 0
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_main)
AccountManager.login(User().apply {
userName = "user1"
uid = System.currentTimeMillis().toString()
})
button.setOnClickListener {
AccountManager.login(User().apply {
userName = "user${i++}"
uid = System.currentTimeMillis().toString()
})
}
}
}
我想一旦AccountManager.login()
被调用,我会收到通知,它会打印一条日志消息。但是我们发现GC之后我们就不会再收到通知了。(我们通过 Android Studio Profiler 触发 GC)
在探索了UserDao_Impl
room 生成的类之后,我们发现它通过调用创建了一个观察者并与数据库链接addWeakObserver()
:
@Override
public LiveData<User> findLoginUserWithObserve() {
final String _sql = "SELECT * FROM user WHERE state = 1 LIMIT 1";
final RoomSQLiteQuery _statement = RoomSQLiteQuery.acquire(_sql, 0);
return new ComputableLiveData<User>(__db.getQueryExecutor()) {
private Observer _observer;
@Override
protected User compute() {
if (_observer == null) {
_observer = new Observer("user") {
@Override
public void onInvalidated(@NonNull Set<String> tables) {
invalidate();
}
};
__db.getInvalidationTracker().addWeakObserver(_observer);
}
所以我们想知道为什么roomWeakObserver
在这里使用,这使得room返回的livedata不可靠?
PS:我们现在Flowable
用来发出实时数据onNext()
来解决这个问题,onNext()
每次都会按预期触发。
解决方案
将此问题发布到谷歌问题跟踪器(https://issuetracker.google.com/issues/114833188)后,我得到了回复:
如果不再使用 LiveData,我们不想泄露它。当 LiveData 使用/不使用时,我们可以在技术上继续添加和删除观察者;但这可能意味着错过了一些在 LiveData 处于非活动状态时发生的事件。我们曾经在最初的原型中这样做,但变得更难维护。您应该保留对 LiveData 的引用以继续使用它。这是我们在所有示例中使用的模式。
因此,只需保留对 room 返回的 livedata 的引用,而不是仅仅观察它,现在一切正常。
推荐阅读
- ios - UITableView 和消失的行
- node.js - 在树莓派和mongodb之间建立连接
- driver - uboot中的设备驱动
- javascript - AngularJS 在不同模块之间共享存储在控制器中的数据
- bash - ubuntu 函数,在 source 时有效,但不适用于 bash 命令
- javascript - 将 MediaRecorder blob 发送到服务器并在后端构建文件
- jquery - 输入框中只显示小数点到 2 位?
- reactjs - 超时 - 在 jest.setTimeout 指定的 5000 毫秒超时内未调用异步回调
- javascript - 当并非所有字段都完成时,如何创建将确认提交表单的 JS 函数
- javascript - 获取后返回一个值