我们的团队正在构建一个受益于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()
返回的liveata,以便在登录用户更改时收到通知:
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
类之后,我们发现它创建了一个观察者并通过调用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);
}
所以我们想知道为什么在这里使用WeakObserver
的房间,这使得房间返回的liveata不可靠?
PS:我们现在正在使用Flowable
在它的onNext()
中发射了liveata来解决这个问题,onNext()
每次都会按预期触发。
将此问题发布到谷歌问题跟踪器(https://issuetracker.google.com/issues/114833188)后,我得到了回复:
如果不再使用LiveData,我们不想泄漏它。当LiveData正在使用/未使用时,我们可以在技术上继续添加和删除观察者;但这可能意味着错过LiveData处于非活动状态时发生的一些事件。我们曾经在最初的原型中做到这一点,但变得更难维护。您应该保留对LiveData的引用以继续使用它。这是我们在所有例子中使用的模式。
所以只要保留对房间返回的liveata的引用,而不仅仅是观察它,现在一切都很好。