我正在使用 Socket.io 创建一个 rochambo 游戏。玩家将他们的赌注添加到等待列表中， Node 在 mondogDB session 中检查玩家是否有足够的钱这样做，然后在将其发送给其他玩家之前创建赌注。

我的代码有效，但如果我要求非常快地创建多个投注， Node 没有时间在下一个投注到达之前更新 mongoDB 中的玩家余额，尽管我有等待名单。因此，玩家即使没有足够的钱也可以下注，我想避免这种情况。

我找不到防止这种情况发生的方法。当然有回调或递归函数，但我没能成功。

对不起我的英语不好，我是法国人:)

这是代码的简化版本:

socket.on('placerunpari', function (screenName, amount, sign) {
newBetWaitingList.push({
    screenName: screenName,
    amount: amount,
    sign: sign
});
for (var k in newBetWaitingList) {

    screenName = newBetWaitingList[k].screenName;
    amount = newBetWaitingList[k].amount;
    sign = newBetWaitingList[k].sign;

    playerModel.findOne({
        screenName: screenName
    }).exec(function (err, player) {
        if (player != null) {
            if (checkAmounts(amount) && (sign == "scissors" || sign == "rock" || sign == "paper")) {
                if (amount <= player.balance) {

                    //DB writing
                    var newBet = new betModel({
                        screenName: screenName,
                        amount: amount,
                        sign: sign
                    });
                    newBet.save(function (err, res) {
                        io.sockets.socket(connected[screenName]).emit('mybet', newBet.id, amount, sign);
                        socket.broadcast.emit('newbet', newBet.id, screenName, amount);
                        creatorUpdateBalance(screenName, -amount);
                    })
                } else {
                    io.sockets.socket(connected[screenName]).emit('showalert', 'You don\'t have enough money for this bet', 'red');
                }
            } else {
                console.log('Unauthorized access');
            }
        }
    });
    newBetWaitingList.shift();
}});

最佳答案

感谢您的回答和帮助，它有效:

   function CreateBet(task, callback) {

    screenName = newBetWaitingList[k].screenName;
    amount = newBetWaitingList[k].amount;
    sign = newBetWaitingList[k].sign;

    playerModel.findOne({
        screenName: screenName
    }).exec(function (err, player) {
        if (player != null) {
            if (checkAmounts(amount) && (sign == "scissors" || sign == "rock" || sign == "paper")) {
                if (amount <= player.balance) {

                    //DB writing
                    var newBet = new betModel({
                        screenName: screenName,
                        amount: amount,
                        sign: sign
                    });
                    newBet.save(function (err, res) {
                        io.sockets.socket(connected[screenName]).emit('mybet', newBet.id, amount, sign);
                        socket.broadcast.emit('newbet', newBet.id, screenName, amount);
                        creatorUpdateBalance(screenName, -amount, function () {
                            callback();
                        });
                    })
                } else {
                    io.sockets.socket(connected[screenName]).emit('showalert', 'You don\'t have enough money for this bet', 'red');
                    callback();
                }
            } else {
                console.log('Unauthorized access');
                callback();
            }
        }
    });
}

var newBetWaitingList = async.queue(CreateBet, 1);

socket.on('placerunpari', function (screenName, amount, sign) {
    newBetWaitingList.push({
        screenName: screenName,
        amount: amount,
        sign: sign
    });
});

关于Javascript - Node.js - 防止函数的多次执行，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22405546/