如何使用 Firestore 数据库：在 Kotlin 中使用 await() addSnapshotListener？

Question

我有一个 DAO 类，其中我有 fetchHubList 方法，该方法使用 await() 从云 Firestore 异步获取文档集合。这个实现使用了我后来知道的“get()”方法，它不会获取实时更新。在尝试使用 onSnapshotListener 类似地实现代码时会出现错误（这是很诚实的，因为 get() 和此方法返回完全不同的东西）。有谁知道如何实现这个？

代码目前如何：

 suspend fun fetchHubList(): ArrayList<HubModel>? = try {
        val hubList = ArrayList<HubModel>()

        hubsListCollection.get().await().map { document ->

            if (document != null) {

                Log.d(TAG, "Data fetch successful!")
                Log.d(TAG, "the document id is ${document.id}")

                val temp = HubModel(document.get("hubName").toString(),
                                    document.id.toString(),
                        document.get("isAdmin") as Boolean)
                hubList.add(temp)

                     //   hubList.add(document.toObject(HubModel::class.java))

            } else {
                Log.d(TAG, "No such document")
            }

        }

我想在这里实现的（这是完全错误的）：

suspend fun fetchHubList(): ArrayList<HubModel>? = try {
        val hubList = ArrayList<HubModel>()

        hubsListCollection.addSnapshotListener().await().map { document ->

            if (document != null) {

                Log.d(TAG, "Data fetch successful!")
                Log.d(TAG, "the document id is ${document.id}")

                val temp = HubModel(document.get("hubName").toString(),
                                    document.id.toString(),
                        document.get("isAdmin") as Boolean)
                hubList.add(temp)

                     //   hubList.add(document.toObject(HubModel::class.java))

            } else {
                Log.d(TAG, "No such document")
            }

        }

我在我的 ViewModel 类中使用这个函数来创建一个 LiveData 包装的 ArrayList：

val hubList =  MutableLiveData<ArrayList<HubModel>>()
    private val hubListDao = HubListDao()
    init {
        viewModelScope.launch {

            hubList.value = hubListDao.fetchHubList()
        }
    }

提前致谢！

Answer 1

您不需要addSnapshotListener，只需使用get：

hubsListCollection.get().await()

为了观察你的收藏的变化，你可以扩展LiveData：

class CafeLiveData(
    private val documentReference: DocumentReference
) : LiveData<Cafe>(), EventListener<DocumentSnapshot> {

    private var snapshotListener: ListenerRegistration? = null

    override fun onActive() {
        super.onActive()
        snapshotListener = documentReference.addSnapshotListener(this)
    }

    override fun onInactive() {
        super.onInactive()
        snapshotListener?.remove()
    }

    override fun onEvent(result: DocumentSnapshot?, error: FirebaseFirestoreException?) {
        val item = result?.let { document ->
            document.toObject(Cafe::class.java)
        }
        value = item!!
    }
}

并从您的视图模型中公开它：

fun getCafe(id: String): LiveData<Cafe> {
    val query = Firebase.firestore.document("cafe/$id")
    return CafeLiveData(query)
}

Answer 2

正如@FrankvanPuffelen 在他的评论中已经提到的那样，您无法将“.await()”与“addSnapshotListener()”一起使用，因为两者是两个完全不同的概念。一个用于只获取一次数据，而第二个用于收听实时更新。这意味着您可以从您正在收听的参考中接收到连续的数据流。

请注意，“.await()”在 Kotlin 中用于挂起函数。这意味着当您调用“.await()”时，您会启动一个单独的协程，这是一个不同的线程，可以在需要时与其他协程并行工作。这称为异步编程，因为“.await()”启动协程执行并等待其完成。换句话说，如果没有抛出异常，您可以在延迟值上使用“.await()”来获取其最终结果。不幸的是，这种机制不适用于实时更新。

对于 Firestore，您可以在 DocumentReference 对象、Query 对象或 CollectionReference 对象上调用“.await()”，这实际上是一个没有过滤器的查询。这意味着您正在等待结果/结果可用。因此，您可以从此类调用中获取一个文档或多个文档。但是，以下调用：

hubsListCollection.addSnapshotListener().await()

不起作用，因为“addSnapshotListener()”方法返回一个ListenerRegistration 对象。

我想使用快照侦听器来侦听数据库中可能发生的更改以更新我的 RecyclerView

在这种情况下，您应该考虑使用名为 Firebase-UI for Android 的库。在这种情况下，所有繁重的工作都将在幕后完成。所以不需要任何协程或“.await()”调用，一切都是实时同步的。

如果您既不想使用 Kotlin 协程，也不想使用 Firebase-UI 库，则可以使用 LiveData。在我的以下 repo 中可以看到一个具体的例子：

• https://github.com/alexmamo/FirestoreRealtimePagination/blob/master/app/src/main/java/ro/alexmamo/firestorerealtimepagination/ProductListLiveData.java

您可以在其中继承 LiveData 类并实现 EventListener 接口。