Android中如何实时检查Firebase实时数据库内邮箱是否已存在？

我的Firebase实时数据库根节点为users，子节点是用户名，现在想检查邮箱是否已存在，尝试了如下代码，但无法正确判断，需要返回布尔值的验证结果：

private boolean validateEmail(){
    email = inp_email.getEditText().getText().toString();

    ArrayList<String> list_of_emails = new ArrayList<>();
    DatabaseReference ref = FirebaseDatabase.getInstance().getReference();

    ref.addValueEventListener(new ValueEventListener() {
        @Override
        public void onDataChange(@NonNull DataSnapshot snapshot) {

            for (DataSnapshot user: snapshot.getChildren()){
                list_of_emails.add(user.child("email").getValue().toString());
            }
        }
        @Override
        public void onCancelled(@NonNull DatabaseError error) {

        }
    });

    if (list_of_emails.contains(email)){
        inp_email.setError("Email already exists!");
        return false;
    }
 if(email.isEmpty()){
        inp_email.setError("Field cannot be empty");
        return false;
    } else if (!email.contains("@gmail.com")) {
        inp_email.setError("Invalid Email");
        return false;
    }else {
        inp_email.setError(null);
        return true;
    }
}

你的代码核心问题是Firebase数据库操作是异步的，addValueEventListener里的逻辑会在主线程执行完之后才运行，所以你在回调外判断list_of_emails.contains(email)时，列表还是空的，自然得不到正确结果。而且遍历所有用户检查邮箱效率极低，下面给你两种可行方案：

方案一：用回调接口处理异步逻辑 #

既然没法直接在异步回调里返回布尔值，我们可以自定义回调接口来传递验证结果：

首先定义回调接口：

interface EmailValidationCallback {
    void onValidationResult(boolean isValid, String errorMessage);
}

然后修改验证方法，改用回调传递结果：

private void validateEmail(EmailValidationCallback callback) {
    String email = inp_email.getEditText().getText().toString();

    // 先做基础格式校验
    if(email.isEmpty()){
        callback.onValidationResult(false, "Field cannot be empty");
        return;
    } else if (!email.contains("@gmail.com")) {
        callback.onValidationResult(false, "Invalid Email");
        return;
    }

    // 查询数据库检查邮箱是否存在
    DatabaseReference usersRef = FirebaseDatabase.getInstance().getReference("users");
    usersRef.orderByChild("email").equalTo(email).addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(@NonNull DataSnapshot snapshot) {
            if (snapshot.exists()) {
                // 邮箱已存在
                callback.onValidationResult(false, "Email already exists!");
            } else {
                // 邮箱可用
                callback.onValidationResult(true, null);
            }
        }

        @Override
        public void onCancelled(@NonNull DatabaseError error) {
            callback.onValidationResult(false, "Database error: " + error.getMessage());
        }
    });
}

调用时通过回调处理结果：

validateEmail(new EmailValidationCallback() {
    @Override
    public void onValidationResult(boolean isValid, String errorMessage) {
        if (isValid) {
            inp_email.setError(null);
            // 验证通过，执行后续注册等逻辑
        } else {
            inp_email.setError(errorMessage);
        }
    }
});

方案二：优化数据库结构（推荐） #

为了更高效地检查邮箱唯一性，建议在根节点新增emails节点，存储邮箱到用户名的映射，结构如下：

{
  "users": {
    "username1": {
      "email": "user1@gmail.com",
      // 其他用户信息
    },
    "username2": {
      "email": "user2@gmail.com",
      // 其他用户信息
    }
  },
  "emails": {
    "user1@gmail.com": "username1",
    "user2@gmail.com": "username2"
  }
}

这样检查邮箱是否存在时，直接查询emails节点对应的路径，效率更高：

private void validateEmail(EmailValidationCallback callback) {
    String email = inp_email.getEditText().getText().toString();

    // 基础格式校验
    if(email.isEmpty()){
        callback.onValidationResult(false, "Field cannot be empty");
        return;
    } else if (!email.contains("@gmail.com")) {
        callback.onValidationResult(false, "Invalid Email");
        return;
    }

    DatabaseReference emailsRef = FirebaseDatabase.getInstance().getReference("emails").child(email);
    emailsRef.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(@NonNull DataSnapshot snapshot) {
            if (snapshot.exists()) {
                callback.onValidationResult(false, "Email already exists!");
            } else {
                callback.onValidationResult(true, null);
            }
        }

        @Override
        public void onCancelled(@NonNull DatabaseError error) {
            callback.onValidationResult(false, "Database error: " + error.getMessage());
        }
    });
}

注意：注册新用户时，需要同时写入users和emails节点，保证数据一致性。

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