使用 Nodejs 和 Socket.io 的聊天服务器：记录对话的最佳方式 [关闭]

Question

我正在使用带有多个房间的聊天服务器，使用 nodejs 和 socket.io。我想知道保存所有对话的最佳方法是什么？

我也在使用 Mysql 和 Redis（会话）。我不确定 MySQL 是不是一个不错的选择，因为它会超载，我需要它来显示其他页面内容。 平面文件呢？这可能很棒，但是在尝试保存新消息时文件已经打开是否存在风险？

谢谢

Answer 1

我使用 Socket.IO、Node.js 和 MongoDB 开发了一个名为 montreus-chat 的聊天工具。 完整的源代码可以在this GitHub repo找到。

以下是可能有用的部分来源：

db.js：

var MessageSchema = new Schema({
    message: String,
    room: String,
    sent: Date
});
var Message = mongoose.model('Message', MessageSchema);

var findMessages = function(room) {
    return new Promise(function (resolve, decline){
        Message.find({room: room}).sort({sent: 'ascending'}).exec(function(error, messages) {
            if(!error){
                resolve(messages);
            }else{
                console.error(error.message);
                decline(error);
            }
        });
    });
}

var addNewMessage = function(message, room){
    return new Promise(function (resolve, decline){
        var newMessage = new Message({
            message: message,
            room: room,
            sent: new Date()
        });
        newMessage.save(function(error){
            if(!error){
                resolve();
            }else{
                console.error(error);
                decline(error);
            }
        });
    });
}

//Exporting methods
exports.find = findMessages;
exports.add = addNewMessage;

app.js：

roomRouter.get('/room/:id/', function(req, res){
    var id = req.params.id;
    var roomName;
    var roomId;
    for(var i = 0; i < rooms.length; i++){
      var room = rooms[i];
        if(room.number == id){
            roomName = room.name;
            roomId = room.roomId;
        }
    }
    if(roomName == null){
        res.status(404).sendFile(__dirname + '/error.html');
    }else{
        db.find(roomId).then(function(messages){
            res.set('Content-Type', 'text/html');
        res.status(200).send(ejs.render(indexEJS, {title: roomName, id: roomId, messages: messages}));
        }, function(error){
            res.status(500).send("Uh oh! An error ocurred: " + error.message);
        });
    }
});
//Inside io.on("connection", ...
socket.on('chat message', function(msg){
            if(!verifyEmptyness(msg.message)){
                var result = processMessage(msg);
                if(result.sendToAll === true){
                    io.in(socket.handshake.query.room).emit('chat message', result.message);
                    db.add(result.message, socket.handshake.query.room);
                }else{
                    socket.emit('chat message', result.message);
                }
            }else{
                var time = moment(msg.date).format("LT, D/M");
                socket.emit('chat message', generateMessage("You may not send empty messages", time, false));
            }
        });