安卓：等待Firebase值事件监听器

Question

我正在尝试使用Semaphore来等待我的firebase valueEventListener。我有一个用户信息活动，包含6个不同的字段，用户必须填写。当用户保存他/她的信息时，我想要进行“全部或无”的检查。某些用户信息不能重复...例如用户名、电子邮件和电话号码。我正在使用firebase，当前的一般思路是：

void saveUserInfo(){
    if(field1 exist in database){
        return;
    }
    .
    .
    .
    if(field6 exist in database){
        return;
    }

    savefield1();
    .
    .
    .
    savefield6();
}

我遇到的问题是在检查数值是否已经存在于数据库中的方法中。这是目前我的方法:

```html

我遇到的问题是在检查数值是否已经存在于数据库中的方法中。这是目前我的方法:

```

   public boolean alreadyInUse(String key, String value) throws InterruptedException {

    final StringBuilder done = new StringBuilder("");
    final Semaphore semaphore = new Semaphore(0);

    mDatabase.child(key).child(value).addListenerForSingleValueEvent(new ValueEventListener() {

        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            String result = dataSnapshot.getValue(String.class);
            if(result == null){
                Log.d("WorkoutLog", "result: null");
                done.append("false");
                semaphore.release();
                return;
            }
            else if(result.equals(uID)){
                Log.d("WorkoutLog", "result: " + result.toString());
                done.append("false");
                semaphore.release();
                return;
            }
            else{
                Log.d("WorkoutLog", "result: " + result.toString());
                done.append("true");
                semaphore.release();
                return;
            }

        }

        @Override
        public void onCancelled(DatabaseError databaseError) {

        }
    });


    semaphore.acquire();
    if(done.equals("true")){
        return  true;
    }
    else if(done.equals("false")){
        return false;
    }
    else{
        Log.d("WorkoutLog", "Shouldn't be here");
        return true;
    }

}

目前信号量没有被释放...想知道是否有人能在这里帮助我。如果没有使用信号量，在Firebase查询完成之前，返回语句就会触发...

- David Yuan

---

请见 https://dev59.com/wFwX5IYBdhLWcg3w8TMf - Frank van Puffelen

Answer 1

如前所述，您可以使用在Google I/O 2016中介绍的Firebase Task API。

Task<?>[] tasks = new Task[] {
    saveUserName(username),
    saveFriends(friends),
    saveOtherStuff(stuff)
};

Tasks.whenAll(tasks)
    .continueWithTask(new RollbackIfFailure())
    .addOnCompleteListener(this)
    .addOnFailureListener(this);

如果每个修改步骤都可以并行运行，您可以创建一个方法来返回一个任务来执行每个步骤，如下所示：

public Task<String> saveUserName(final String username) {
    final TaskCompletionSource<String> tcs = new TaskCompletionSource<>();

    mDatabase.child("users")
        .child(username)
        .addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            String username = dataSnapshot.getValue(String.class);
            if (null == username) {
                tcs.setResult(null);
            } else {
                tcs.setException(new IllegalStateException(username));
            }
        }

        @Override
        public void onCancelled(FirebaseError firebaseError) {
            tcs.setException(new IOException(TAG, firebaseError.toException()));
        }
    });

    return tcs.getTask();
}

如果它们中的任何一个失败，您需要回滚操作。由于这可以由单个任务处理，因此可以创建一个Continuation任务:

class RollbackIfFailure implements Continuation<Void, Task<Void>> {
    @Override
    public Task<Void> then(@NonNull Task<Void> task) throws Exception {

        final TaskCompletionSource<Void> tcs = new TaskCompletionSource<>();

        if (task.isSuccessful()) {
            tcs.setResult(null);
        } else {
            // Rollback everything
        }

        return tcs.getTask();
    }
}

- JP Ventura

Answer 2

监听器回调方法在主线程上运行。如果您在主线程上调用alreadyInUse()，它将阻止semaphore.acquire()处的线程，从而防止回调运行和释放信号量。

您可能会发现这个答案对相关问题有帮助。

- Bob Snyder