在Firebase中,创建聊天室等“房间”非常容易,就像在各种示例中记录的那样。
对于聊天的数据结构,我将使用以下内容:
rooms
room1
member_count
members
user1
user2
messages
message1
但是现在我想创建一个限制,即每个聊天室的参与者人数限制,例如每个聊天室3个用户。
你该怎么做?
在他们的文档中,最有前途的一件事是使用transactions。您可以验证这是一个好方法吗?还是这是错误的方法?
这样的解决方案呢?
Firebase countRef = new Firebase("https://mychat.firebaseIO-demo.com/rooms/room1");
countRef.runTransaction(new Transaction.Handler() {
@Override
public Transaction.Result doTransaction(MutableData currentData) {
int oldMemberCount = currentData.child("member_count").getValue(Integer.class);
currentData.child("member_count").setValue(oldMemberCount + 1); // try to update member count
return Transaction.success(currentData);
}
@Override
public void onComplete(FirebaseError error, boolean committed, DataSnapshot currentData) {
if (error != null || !commited) {
// rollback value (how? just do nothing?)
}
else {
// transaction has been commited (value has already been saved?)
currentData.child("members").child(CURRENT_USER_UUID).setValue(CURRENT_USER_NAME); // add user to the members list
}
}
});
如果您可以对这种方法发表评论,那就太好了。此外,如果交易失败,当然不能满足那种情况。无论是否有另一个用户尝试同时加入,该用户仍然希望加入。那该怎么办呢?将此代码放入函数中,并在错误情况下再次调用该函数?
编辑:
要创建一个具有自动唯一ID的新房间,当然可以在
Firebase
引用上使用push()。但是,如果您想将成员添加到该会议室,则上述问题仍然存在。另一种解决方案是在加入时在成员列表中设置用户的priority。将其优先级设置为当前时间戳时,可以将成员列表回调limit设置为3(成员)。但这似乎并不优雅也不干净。
最佳答案
如果每个房间的参与者人数固定(且相对较少),则最好使用交易。但是,最好为聊天室中的每个人创建命名良好的对象,例如:
/rooms
/<roomid, generated by push()>
/users
one: null
two: null
three: null
加入房间的样子(使用JavaScript代码,请根据需要转换为Java);
var userid = "myuserid";
var ref = new Firebase("<my-firebase>.firebaseio.com/rooms/<roomid>/users");
ref.transaction(function(users) {
if (!users.one) {
// Claim slot 1
users.one = userid;
return users;
} else if (!users.two) {
// Claim slot 2
users.two = userid;
return users;
} else if (!users.three) {
// Claim slot 3
users.three = userid;
return users;
}
// Room is full, abort the transaction.
return;
}, function(err, committed, snapshot) {
if (committed && !err) {
// Joined room successfully.
} else {
// Could not join room because it was full.
}
});
如果Firebase无法将值提交给服务器,它将自动调用事务处理功能。除了上面的代码,您还需要实现一些安全规则,以防止用户声明已占用的插槽:
{
"rules": {
"rooms": {
"$roomid": {
"users": {
"$slot": {
".write": "!data.exists()"
}
}
}
}
}
}
您可以通过Firege的图形调试器Forge上载这些规则,您应该一切顺利!