如何结合Tasks与Firestore onSnapshotListener实现实时更新链式处理

首先，你遇到的books为空的问题，根源在于嵌套快照监听器的触发顺序是不可预测的——可能Admin的快照回调先执行了，但这时候Books的回调还没触发，books变量自然是空的。而且嵌套的写法也没法实现「任一数据源更新就获取三者最新值」的需求，因为只有当最内层的监听器触发时才会处理，外层的更新不会重新触发整个流程。

正确的实现思路 #

我们需要把三个快照监听器解耦，各自维护最新的数据副本，然后在任一监听器触发时，检查三个数据是否都已就绪，若全部就绪就执行统一的处理逻辑。这样不管哪个数据源更新，都能拿到三者的最新值。

具体代码实现 #

首先在你的类中定义三个成员变量来存储最新数据：

private List<User> latestUsers;
private List<Book> latestBooks;
private Admin latestAdmin;

然后分别为三个查询添加独立的快照监听器，每个监听器更新对应变量后，调用统一的处理方法：

// 监听Users的实时更新
mDbase.collection("admins").document(adminID).collection("users")
    .addSnapshotListener(new EventListener<QuerySnapshot>() {
        @Override
        public void onEvent(@Nullable QuerySnapshot usersSnapshot, @Nullable FirebaseFirestoreException e) {
            if (e != null) {
                Log.w("Firestore", "Users监听失败", e);
                return;
            }
            if (usersSnapshot != null && !usersSnapshot.isEmpty()) {
                latestUsers = usersSnapshot.toObjects(User.class);
            } else {
                latestUsers = new ArrayList<>(); // 空列表避免空指针
            }
            // 更新后检查是否可以处理
            processAllData();
        }
    });

// 监听Books的实时更新
mDbase.collection("books").whereEqualTo("groupID", groupID)
    .addSnapshotListener(new EventListener<QuerySnapshot>() {
        @Override
        public void onEvent(@Nullable QuerySnapshot booksSnapshot, @Nullable FirebaseFirestoreException e) {
            if (e != null) {
                Log.w("Firestore", "Books监听失败", e);
                return;
            }
            if (booksSnapshot != null && !booksSnapshot.isEmpty()) {
                latestBooks = booksSnapshot.toObjects(Book.class);
            } else {
                latestBooks = new ArrayList<>();
            }
            processAllData();
        }
    });

// 监听Admin文档的实时更新
mDbase.collection("admins").document(adminID)
    .addSnapshotListener(new EventListener<DocumentSnapshot>() {
        @Override
        public void onEvent(@Nullable DocumentSnapshot adminSnapshot, @Nullable FirebaseFirestoreException e) {
            if (e != null) {
                Log.w("Firestore", "Admin监听失败", e);
                return;
            }
            if (adminSnapshot != null && adminSnapshot.exists()) {
                latestAdmin = adminSnapshot.toObject(Admin.class);
            } else {
                latestAdmin = null; // 或者根据业务逻辑处理
            }
            processAllData();
        }
    });

最后实现统一的处理方法，确保三个数据都就绪后再执行逻辑：

private void processAllData() {
    // 检查三个数据是否都已就绪（根据你的业务需求调整判断条件）
    if (latestUsers != null && latestBooks != null && latestAdmin != null) {
        // 在这里处理所有数据，此时三者都是最新值
        System.out.println("books: " + latestBooks.toString());
        // 你的业务逻辑...
    }
}

额外优化建议 #

• 移除监听器：当页面销毁或不再需要实时更新时，记得调用监听器的remove()方法，避免内存泄漏。比如把每个addSnapshotListener返回的ListenerRegistration存起来，在onDestroy()中移除：

  private ListenerRegistration usersListener;
  // 初始化时
  usersListener = mDbase.collection(...).addSnapshotListener(...);
  // 销毁时
  if (usersListener != null) {
      usersListener.remove();
  }
  

• 处理初始加载：如果需要区分第一次加载和后续更新，可以添加一个标记变量，在第一次processAllData()执行后标记为已加载，后续更新做不同处理。

内容的提问来源于stack exchange，提问作者Brian Begun