问题:我的 MainActivity 中的布局是在我有机会完成调用 firebase 以恢复应用程序数据之前生成的。如果我旋转屏幕，从而导致 onCreate 在 MainActivity 中再次运行，一切都会正常生成。

在我的应用程序中，我有一个 Application 类的自定义实现，它会调用 Firebase 来恢复数据/确保数据始终同步。但是，我有大约 20 个 ValueEventListener，而不是只有几个 ValueEventListeners 和下面的大量子项。这是为了防止每次用户生成少量数据时我的应用程序几乎同步整个数据库，并避免异步操作数据时可能发生的冲突。有趣的是，ValueEventListeners 实际上并没有按照编码的顺序获取它们的数据，所以我无法在最后一个完成时将 bool 设置为 true。

我想知道是否有一种简单的方法来检测 firebase 读取是否全部完成，而不是在每个 Listener 的末尾放置一些代码并执行手动执行此操作的操作。我查看了 Application 类以及 Firebase 中可用的方法，但到目前为止我还没有找到任何有效的方法。

我的应用程序类中的一些代码:

public class CompassApp extends Application {

...然后在应用程序的 onCreate 中:

//        Fetching Data from DB.
    FirebaseDatabase database = FirebaseDatabase.getInstance();
    DatabaseReference dbRef = database.getReference();

//        Current User Data
    dbRef.child("currentAppData").child("workingOut").addValueEventListener(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            activeFirebaseConnections += 1;
//                Stops executing method if there is no data to retrieve
            if (!dataSnapshot.exists()) {
                return;
            }

            workingOut = dataSnapshot.getValue(boolean.class);

            activeFirebaseConnections -= 1;

        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            Log.e(TAG, "Firebase read of sleepDebt failed");
        }
    });
    dbRef.child("currentAppData").child("sleeping").addValueEventListener(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            activeFirebaseConnections += 1;
//                Stops executing method if there is no data to retrieve
            if (!dataSnapshot.exists()) {
                return;
            }

            sleeping = dataSnapshot.getValue(boolean.class);

            activeFirebaseConnections -= 1;

        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            Log.e(TAG, "Firebase read of sleepDebt failed");
        }
    });

(等等...剩下的只是更多的ValueEventListeners)

最佳答案

我目前正在使用我创建的用于启动多个数据加载的实用程序类。当所有监听器完成时，它将触发最终任务。他们的关键是巧妙地使用新的 Task Play 服务提供的异步编程设施。您可能可以使用其他一些异步框架来完成所有这些操作，但 Tasks 随 Play Services 免费提供，并在 Firebase 的其他部分中使用，因此您不妨学习使用它们。 :-)

我在 Google I/O 2016 上发表了关于任务的演讲。这是 a link to a video直接跳转到该 session 的相关部分。

public class FirebaseMultiQuery {

    private final HashSet<DatabaseReference> refs = new HashSet<>();
    private final HashMap<DatabaseReference, DataSnapshot> snaps = new HashMap<>();
    private final HashMap<DatabaseReference, ValueEventListener> listeners = new HashMap<>();

    public FirebaseMultiQuery(final DatabaseReference... refs) {
        for (final DatabaseReference ref : refs) {
            add(ref);
        }
    }

    public void add(final DatabaseReference ref) {
        refs.add(ref);
    }

    public Task<Map<DatabaseReference, DataSnapshot>> start() {
        // Create a Task<DataSnapsot> to trigger in response to each database listener.
        //
        final ArrayList<Task<DataSnapshot>> tasks = new ArrayList<>(refs.size());
        for (final DatabaseReference ref : refs) {
            final TaskCompletionSource<DataSnapshot> source = new TaskCompletionSource<>();
            final ValueEventListener listener = new MyValueEventListener(ref, source);
            ref.addListenerForSingleValueEvent(listener);
            listeners.put(ref, listener);
            tasks.add(source.getTask());
        }

        // Return a single Task that triggers when all queries are complete.  It contains
        // a map of all original DatabaseReferences originally given here to their resulting
        // DataSnapshot.
        //
        return Tasks.whenAll(tasks).continueWith(new Continuation<Void, Map<DatabaseReference, DataSnapshot>>() {
            @Override
            public Map<DatabaseReference, DataSnapshot> then(@NonNull Task<Void> task) throws Exception {
                task.getResult();
                return new HashMap<>(snaps);
            }
        });
    }

    public void stop() {
        for (final Map.Entry<DatabaseReference, ValueEventListener> entry : listeners.entrySet()) {
            entry.getKey().removeEventListener(entry.getValue());
        }
        snaps.clear();
        listeners.clear();
    }

    private class MyValueEventListener implements ValueEventListener {
        private final DatabaseReference ref;
        private final TaskCompletionSource<DataSnapshot> taskSource;

        public MyValueEventListener(DatabaseReference ref, TaskCompletionSource<DataSnapshot> taskSource) {
            this.ref = ref;
            this.taskSource = taskSource;
        }

        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            snaps.put(ref, dataSnapshot);
            taskSource.setResult(dataSnapshot);
        }

        @Override
        public void onCancelled(DatabaseError databaseError) {
            taskSource.setException(databaseError.toException());
        }
    }

}

你的使用方式是这样的。确定您需要从中加载数据并将其存储在 Activity 成员中的所有 DatabaseReference。然后，在您的 onStart() Activity 期间，将它们全部传递到 FirebaseMultiQuery 的实例中并对其调用 start()。它将返回一个 Task，该 Task 生成 DataSnapshot 的 DataSnapshot 映射。有了这个任务，注册一个最终的监听器，它将在加载所有数据时触发:

firebaseMultiQuery = new FirebaseMultiQuery(dbRef1, dbRef2, dbRef3, ...);
final Task<Map<DatabaseReference, DataSnapshot>> allLoad = firebaseMultiQuery.start();
allLoad.addOnCompleteListener(activity, new AllOnCompleteListener());

在您的 onStop() 中，不要忘记对其调用 stop() 以确保一切正常关闭:

firebaseMultiQuery.stop();

接收 map 中所有数据的任务完成后触发的监听器可能如下所示:

private class AllOnCompleteListener implements OnCompleteListener<Map<DatabaseReference, DataSnapshot>> {
    @Override
    public void onComplete(@NonNull Task<Map<DatabaseReference, DataSnapshot>> task) {
        if (task.isSuccessful()) {
            final Map<DatabaseReference, DataSnapshot> result = task.getResult();
            // Look up DataSnapshot objects using the same DatabaseReferences you passed into FirebaseMultiQuery
        }
        else {
            exception = task.getException();
            // log the error or whatever you need to do
        }
        // Do stuff with views
        updateUi();
    }
}

可能值得注意的是，写入数据的 Firebase 数据库调用也会返回您可以监听完成的任务。此外，Firebase 存储使用任务，Firebase 身份验证也是如此。

此处的代码目前可能不适用于 Firebase 数据库查询，它不是对数据库中节点的简单命名引用。这取决于它们是否以与键入 HashMap 一致的方式散列。

上面的代码仍然有些实验性，但到目前为止我还没有遇到任何问题。看起来代码很多，但是如果你做很多并发加载，那真的很方便。

关于android - 仅在 firebase 调用完成时加载布局，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38173569/