Firebase实时数据库写入失败：注册后无法设置用户初始金额

问题概述 #

用户通过Firebase Auth完成注册后，希望自动给用户添加500的初始金额（int类型），将替换.为,的用户邮箱作为实时数据库user节点的子节点ID，金额作为该子节点的值。但调用writeNewUserMoney方法后数据库无变化，需要排查问题并提供无感写入的替代方案。

相关代码 #

writeNewUserMoney方法 #

public void writeNewUserMoney() {
    String email = encodeUserEmail(signupEmail.getText().toString().trim());
    mDatabaseReference = FirebaseDatabase.getInstance().getReference();
    mDatabaseReference.child("user").child(email).setValue(500);
}

encodeUserEmail方法 #

static String encodeUserEmail(String userEmail) {
    return userEmail.replace(".", ",");
}

点击事件代码 #

@Override
public void onClick(View view) {
    String user = signupEmail.getText().toString().trim();
    String pass = signupPassword.getText().toString().trim();
    if (user.isEmpty()){
        signupEmail.setError("Email eingeben");
    }
    if (pass.isEmpty()){
        signupPassword.setError("Passwort eingeben");
    } else{
        auth.createUserWithEmailAndPassword(user, pass).addOnCompleteListener(new OnCompleteListener<AuthResult>() {
                @Override
                public void onComplete(@NonNull Task<AuthResult> task) {
                    if (task.isSuccessful()) {
                        Toast.makeText(SignUpActivity.this, "SignUp Successful", Toast.LENGTH_SHORT).show();
                        startActivity(new Intent(SignUpActivity.this, LoginActivity.class));
                    } else {
                        Toast.makeText(SignUpActivity.this, "SignUp Failed" + task.getException().getMessage(), Toast.LENGTH_LONG).show();
                    }
                }
        });
    }
    FirebaseAuth auth = FirebaseAuth.getInstance();
    FirebaseUser kuser = auth.getCurrentUser();
    kuser.sendEmailVerification().addOnCompleteListener(new OnCompleteListener<Void>() {
            @Override
            public void onComplete(@NonNull Task<Void> task) {
                if (task.isSuccessful()) {
                    System.out.println("Email sent");
                }
            }
    });
    writeNewUserMoney();
}

问题原因分析 #

1. 异步执行顺序错误：writeNewUserMoney和邮件验证代码在createUserWithEmailAndPassword的异步回调外部执行，此时注册流程可能尚未完成，甚至可能出现FirebaseUser为null的情况，导致写入失败或空指针异常。
2. 依赖输入框内容不可靠：直接从输入框获取邮箱，若注册过程中输入框内容被修改，会导致写入的邮箱与实际注册用户不匹配。
3. 缺少写入失败回调：未监听数据库写入的结果，无法获取失败原因（如权限不足、网络问题等）。
4. 数据库规则限制：若实时数据库规则未允许认证用户写入，注册成功后的用户也无法完成数据写入。

解决方案 #

方案1：修正前端代码执行顺序与逻辑 #

将数据库写入和邮件验证操作移至注册成功的回调内，使用注册返回的用户信息而非输入框内容，并添加错误监听：

@Override
public void onClick(View view) {
    String user = signupEmail.getText().toString().trim();
    String pass = signupPassword.getText().toString().trim();
    if (user.isEmpty()){
        signupEmail.setError("Email eingeben");
        return;
    }
    if (pass.isEmpty()){
        signupPassword.setError("Passwort eingeben");
        return;
    }
    
    auth.createUserWithEmailAndPassword(user, pass).addOnCompleteListener(new OnCompleteListener<AuthResult>() {
        @Override
        public void onComplete(@NonNull Task<AuthResult> task) {
            if (task.isSuccessful()) {
                Toast.makeText(SignUpActivity.this, "SignUp Successful", Toast.LENGTH_SHORT).show();
                FirebaseUser currentUser = task.getResult().getUser();
                if (currentUser != null) {
                    // 写入初始金额
                    String encodedEmail = encodeUserEmail(currentUser.getEmail());
                    writeNewUserMoney(encodedEmail);
                    // 发送验证邮件
                    currentUser.sendEmailVerification().addOnCompleteListener(new OnCompleteListener<Void>() {
                        @Override
                        public void onComplete(@NonNull Task<Void> task) {
                            if (task.isSuccessful()) {
                                System.out.println("Email sent");
                            } else {
                                Log.e("EmailError", "验证邮件发送失败: " + task.getException().getMessage());
                            }
                        }
                    });
                }
                startActivity(new Intent(SignUpActivity.this, LoginActivity.class));
            } else {
                Toast.makeText(SignUpActivity.this, "SignUp Failed" + task.getException().getMessage(), Toast.LENGTH_LONG).show();
            }
        }
    });
}

// 修改writeNewUserMoney方法，接收编码后的邮箱并添加结果监听
public void writeNewUserMoney(String encodedEmail) {
    mDatabaseReference = FirebaseDatabase.getInstance().getReference();
    mDatabaseReference.child("user").child(encodedEmail).setValue(500)
        .addOnCompleteListener(new OnCompleteListener<Void>() {
            @Override
            public void onComplete(@NonNull Task<Void> task) {
                if (!task.isSuccessful()) {
                    Log.e("DatabaseError", "初始金额写入失败: " + task.getException().getMessage());
                }
            }
        });
}

同时检查实时数据库规则，确保认证用户可写入：

{
  "rules": {
    ".read": "auth != null",
    ".write": "auth != null"
  }
}

方案2：使用Firebase云函数实现后端无感写入 #

通过云函数的Auth触发器，在用户注册成功后自动写入初始金额，完全无需前端处理，更安全且用户无感知：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();

exports.createUserInitialBalance = functions.auth.user().onCreate((user) => {
    // 编码用户邮箱
    const encodedEmail = user.email.replace(".", ",");
    // 写入初始金额到数据库
    return admin.database().ref(`user/${encodedEmail}`).set(500);
});

部署该云函数后，任何新用户通过Firebase Auth注册时，系统都会自动在实时数据库的user节点下创建对应邮箱编码的子节点，并设置值为500。

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