Firebase添加重复Key无报错：Android聊天室用户创建异常求助

问题原因分析 #

问题出在你当前的实现逻辑上——Firebase的setValue()方法在处理已存在的节点时，默认是覆盖原有数据，而不是抛出错误。因为你只是把同一个true值写入已存在的User/[username]节点，这在Firebase看来是合法的写操作，所以CompletionListener会始终进入成功分支，不会返回错误。

要实现「用户已存在时返回错误」的需求，你可以通过以下三种方案解决：

方案1：使用Firebase事务（最安全，解决并发竞争） #

事务是原子操作，能确保在写入前先检查节点是否存在，完美避免多用户同时创建相同用户名的竞争问题。修改你的createUser方法如下：

private void createUser(final String uname) {
    DatabaseReference userRef = firedb.getReference("User").child(uname);
    
    userRef.runTransaction(new Transaction.Handler() {
        @Override
        public Transaction.Result doTransaction(MutableData mutableData) {
            if (mutableData.getValue() != null) {
                // 用户已存在，终止事务
                return Transaction.abort();
            }
            // 用户不存在，写入标记值
            mutableData.setValue(true);
            return Transaction.success(mutableData);
        }

        @Override
        public void onComplete(DatabaseError error, boolean committed, DataSnapshot currentData) {
            if (error != null) {
                Log.d("firebaseTest", "tested_uname: " + uname + " 操作失败: " + error.getMessage());
                requestNewUser();
            } else if (!committed) {
                // 事务被终止，说明用户已存在
                Log.d("firebaseTest", "tested_uname: " + uname + " 已存在，创建失败");
                requestNewUser();
            } else {
                Log.d("firebaseTest", "tested_uname: " + uname + " 创建成功");
            }
        }
    });
}

方案2：先查询再写入（简单但有并发风险） #

先查询目标用户名是否存在，只有不存在时才执行写入操作。注意：这种方式在高并发场景下可能出现「查询时不存在，但写入前被其他用户创建」的情况，适合低并发场景使用：

private void createUser(final String uname) {
    DatabaseReference userRef = firedb.getReference("User").child(uname);
    
    userRef.addListenerForSingleValueEvent(new ValueEventListener() {
        @Override
        public void onDataChange(DataSnapshot dataSnapshot) {
            if (dataSnapshot.exists()) {
                // 用户已存在
                Log.d("firebaseTest", "tested_uname: " + uname + " 已存在");
                requestNewUser();
            } else {
                // 用户不存在，执行写入
                userRef.setValue(true, new DatabaseReference.CompletionListener() {
                    @Override
                    public void onComplete(DatabaseError error, DatabaseReference ref) {
                        if (error != null) {
                            Log.d("firebaseTest", "tested_uname: " + uname + " 创建失败: " + error.getMessage());
                            requestNewUser();
                        } else {
                            Log.d("firebaseTest", "tested_uname: " + uname + " 创建成功");
                        }
                    }
                });
            }
        }

        @Override
        public void onCancelled(DatabaseError error) {
            Log.d("firebaseTest", "查询失败: " + error.getMessage());
            requestNewUser();
        }
    });
}

方案3：设置Firebase安全规则（服务器端强制限制） #

通过Firebase安全规则，从服务器层面禁止客户端覆盖已存在的User节点。这样当客户端尝试写入已存在的用户名时，会被服务器拒绝，CompletionListener会收到权限错误。

在Firebase控制台的规则标签页，修改规则为：

{
  "rules": {
    "User": {
      "$username": {
        ".write": "!data.exists()" // 仅允许写入不存在的节点
      }
    }
  }
}

修改后，重复写入时onComplete会收到PERMISSION_DENIED错误，你可以在错误分支处理重复用户的提示逻辑。

内容的提问来源于stack exchange，提问作者Gürkan Çatak