flutter - 如何在不重复读取量的情况下同时订阅整个集合和其中的文档？

Question

我正在为学习目的编写一个使用 Flutter 和 Firestore 的跨平台待办事项应用程序。目前，我有以下设计，我想知道是否有更好的选择。

应用程序的主屏幕之一显示所有任务的列表。它通过订阅相应的 Firestore 集合来实现这一点，为简单起见，我们将其称为 /tasks。

FirebaseFirestore.instance.collection("tasks").snapshots()

任务 ListView 中的每个图 block 都可以单击。单击磁贴会打开一个新屏幕(带有 Navigator.push)，显示有关该特定任务的详细信息。

重要的是，这个屏幕也需要实时更新，所以仅仅从主屏幕传递(本地，不可变的)任务对象是不够的。相反，此屏幕会订阅与该任务对应的单个 Firestore 文档。

FirebaseFirestore.instance.collection("tasks").doc(taskId).snapshots()

这在逻辑上对我来说是有意义的:详细信息页面只需要知道那个特定的文档，所以它只订阅它以避免接收不必要的更新。

问题是因为在详细信息屏幕打开时主屏幕的集合范围订阅仍然有效，如果文档 /tasks/{taskId} 更新，两个监听器都会触发。根据this中的答案, this和 this问题，这意味着我要为该文档的任何一次更新支付两次(重复)读取费用。

此外，每个任务都可以有子任务。这在 Firestore 中反射(reflect)为每个任务的 tasks 子集合。例如，嵌套任务的路径可能是:/tasks/abc123/tasks/efg875/tasks/aay789。通过在 "tasks" 上使用集合组查询，主页可以显示所有任务而不管嵌套。上述详情页面还通过监听子集合来显示任务的子任务。这允许对子任务进行复杂查询(过滤、排序等)，但同样的缺点是每次更新子任务都会重复读取。

我想到的替代设计是:

• 仅保留对整个任务集(无论是平面集合还是集合组查询)的单一应用范围订阅，并在客户端上进行任何和所有选择、过滤等。例如，任务的详细信息页面将使用相同的集合范围订阅，并且每次都从集合中选择适当的任务。任务/子任务的任何过滤和排序都将在客户端完成。

  • 优点:无重复读取，最大限度地降低 Firestore 成本。
  • 缺点:对于客户端来说可能会消耗更多电量，并且代码会变得更加复杂，因为我必须在每种情况下都从整个任务集中选择适当的数据。

• 打开详情页时取消全集订阅，返回主界面时重新开启。这意味着当详细信息页面打开时，只会收到对该特定任务的更新，而不会被复制为两次读取。

  • 优点:没有重复读取。
  • 缺点:返回主屏幕时重新开始订阅意味着读取第一个快照中的所有文档，即每个任务读取一次，这实际上可能会使问题变得更糟。此外，编码可能会非常复杂。

这些设计中有哪一个看起来是最好的？我还缺少其他更好的选择吗？

Answer 1

在您的应用程序中创建一个 TaskService 或类似的东西来处理监听 FirebaseFirestore.instance.collection("tasks").snapshots() 调用，然后在您的应用程序，订阅该服务的更新而不是 Firebase 本身(您可以创建两个 Stream 对象，一个用于全局更新，一个用于特定更新)。

然后，您的 Firebase 集合中只有一个正在阅读。一切都在应用端处理。

伪代码:

class TaskService {  
    final List<Task> _tasks = [];
    final StreamController<List<Task>> _signalOnTasks = StreamController.broadcast();
    final StreamController<Task> _signalOnTask = StreamController.broadcast();
    
    get List<Task> allTasks => _tasks;
    Stream<List<Task>> get onTasks => _signalOnTasks.stream;
    Stream<List<Task>> get onTask => _signalOnTask.stream;
    
    void init() {
        FirebaseFirestore.instance.collection("tasks").snapshots().listen(_onData);
    }
    
    void _onData(snapshot) {
        /// get/update our tasks (maybe check for duplicates or whatever)
        _tasks.addAll(snapshot.documents);
        
        /// dispatch our signal streams
        _signalOnTasks.add(snapshot.documents);
        for(final task in snapshot.documents) {
            _signalOnTask.add(task);
        }
    }
}

您可以让 TaskService 和 InheritedWidget 随时随地访问它(或使用提供程序包)，并将您的监听器添加到您感兴趣的任何流中。您只需要在 onTask 上检查您的监听器，在对其执行任何操作之前，它是正确的任务。