Firestore多where条件查询及数据变更监听实现问询

明确说明：Firestore支持对带过滤条件的Query设置实时监听，逻辑和单次get()查询完全一致，只要你的规则已经允许对应的查询，监听就能正常工作。

对应你现有查询的监听实现示例 #

你可以为每个带where条件的Query分别设置监听，代码如下：

var collection = ref.collection(Constants.Environment)
    .doc("data")
    .collection("groups");

// 保存订阅对象，用于后续取消监听
List<StreamSubscription<QuerySnapshot<Map<String, dynamic>>>> subscriptions = [];

if(phone != null) {
  // 监听第一个查询：user_list.$phone 不为空的文档
  var sub1 = collection.where("user_list.$phone", isNotEqualTo: "")
      .snapshots()
      .listen((querySnapshot) {
    // 处理新增、删除、更新的文档
    for (var change in querySnapshot.docChanges) {
      switch (change.type) {
        case DocumentChangeType.added:
          print("新增文档: ${change.doc.data()}");
          break;
        case DocumentChangeType.removed:
          print("删除文档: ${change.doc.data()}");
          break;
        case DocumentChangeType.modified:
          print("修改文档: ${change.doc.data()}");
          break;
      }
    }
  });

  // 监听第二个查询：org_id 等于phone的文档
  var sub2 = collection.where("org_id", isEqualTo: phone)
      .snapshots()
      .listen((querySnapshot) {
    for (var change in querySnapshot.docChanges) {
      switch (change.type) {
        case DocumentChangeType.added:
          print("新增组织文档: ${change.doc.data()}");
          break;
        case DocumentChangeType.removed:
          print("删除组织文档: ${change.doc.data()}");
          break;
        case DocumentChangeType.modified:
          print("修改组织文档: ${change.doc.data()}");
          break;
      }
    }
  });

  subscriptions.addAll([sub1, sub2]);
}

// 页面销毁或不再需要监听时，取消所有订阅
// subscriptions.forEach((sub) => sub.cancel());

关键注意点 #

• 权限一致性：因为你已经配置了匹配查询逻辑的Firestore规则，只要单次get()能正常返回数据，监听就不会有权限问题。
• 重复文档处理：如果某个文档同时满足两个where条件，会在两个监听回调中都触发，你可能需要在业务逻辑中去重。
• 资源清理：务必在不需要监听时取消订阅，避免内存泄漏，比如在Flutter的dispose()方法中执行取消操作。

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