SyncAdapter 中的 Singleton Room 数据库触发 LiveData

Question

我正在努力将Room 用作我的SyncAdapter 中的单例。我使用 Kotlin。

我的房间课

@Database(entities = [(Product::class)], version = 1, exportSchema = false)
abstract class AppDatabase : RoomDatabase() {
    abstract fun productDao(): ProductDao

    companion object {
        @Volatile private var INSTANCE: AppDatabase? = null

        fun getInstance(context: Context) : AppDatabase =
            INSTANCE ?: synchronized(this) {
                INSTANCE ?: buildDatabase(context.applicationContext)
                        .also {INSTANCE = it}
            }

        private fun buildDatabase(context: Context) =
                Room
                        .databaseBuilder(context.applicationContext,
                                AppDatabase::class.java, "database.db")
                        .allowMainThreadQueries()
                        .build()
    }

}

我这样检索数据库实例

val db = AppDatabase.getInstance(applicationContext)

而我的问题是，我在活动中总是得到两个不同的 AppDatabase 实例和 SyncAdapter。虽然在活动中AppDatabase 对象确实是单例.AppDatabase_Impl@3c9ff34d，并且对于每个 onPerformSync()，AppDatabase 也是单例.AppDatabase_Impl@7d7718d。 但正如你所看到的，它们是两个不同的对象。 谁能解释一下我在这里想念什么？

另一方面，我想要实现的目标可能在概念上是错误的。那么任何建议将不胜感激。

重点是在通过SynAdapter 从远程服务器插入新数据时使用LiveData 更新UI 组件。在这种情况下，我必须在 ViewModel/Activity 和 SyncAdapter 中使用相同的 productDao 对象，以便在插入新产品时触发 LiveData，否则不会触发。 因此，要获得相同的productDao，我必须获得相同的（即单例）AppDatabase。

我知道这可以使用ContentProvider 来实现，它会在插入新数据时自动触发。但我真的很想尝试新的 android 架构组件。 或者也许使用ContentProvider 是实现这个用例的唯一正确方法？

Answer 1

当您想要在不同的Threads 之间轻松通信时，您需要在同一个进程中。

在AndroidManifest.xml 中，您可以指定一个名为android:process=":processName" 的属性，该属性可用于Activity、Services（与SyncAdapters 相关）、Content Providers 和 Broadcast Receivers，可以帮助您超出单个进程的 Heap（内存）的默认限制。

这些是总结的优点/缺点：

多进程 PRO：您有更多内存来运行您的应用程序，如果 进程崩溃它不会使其他进程崩溃。

多进程缺点： 让流程变得更加困难（但并非不可能） 彼此通信，但显然您不能在它们之间共享状态（在您的情况下，状态是单例）

要深入了解，你应该阅读this article和this good answer

我的建议：如果您的应用程序不是那么复杂并且您没有内存问题，我建议您从单进程方法开始。如果您想将更新数据的 SyncAdapter 与应用程序分离，或者在开发中的某个时刻您发现与单进程相关的瓶颈或崩溃，您可以切换到多进程，删除直接 LiveData 并使用 ContentProvider 来传达数据变化。

Answer 2

使用匕首2：

class MyApplication : Application(){

    val component: AppComponent by lazy {
        DaggerAppComponent.builder().appModule(AppModule(this)).build()
    }

    @Inject
    lateinit var database : AppDatabase

    override fun onCreate() {
        super.onCreate()
        component.inject(this)
    }

}
@Singleton
@Component(modules = arrayOf(
        AppModule::class
))
interface AppComponent {
   fun inject(app: MyApplication)
}

@Module
class AppModule constructor(private val context: Context) {

@Provides
@Singleton
fun providesDatabase() = Room.databaseBuilder(context, AppDatabase::class.java, "mydb.db").build()

}

来自活动：

@Inject lateinit var mRoomDatabase: AppDatabase

override fun onCreate(savedInstanceState: Bundle?) {
     super.onCreate(savedInstanceState)
     (application as MyApplication).component.inject(this)
}