javascript - 如何将 socket.io 消息发送到 mongodb

Question

我有一个类似于 socket.io 主页上的聊天应用程序。我想用 monogdb/mongoose 保存消息，以便它们在刷新/服务器重新启动后始终存在(只是为了了解它是如何工作的)。

所以例如在我的 Mongoose 文件中我有这个:

var mongoose = require( 'mongoose' );
var Schema   = mongoose.Schema;

var Mes = new Schema({
    content    : String
});

mongoose.model( 'Mes', Mes );
mongoose.connect( 'mongodb://localhost/socketio' );

我想用它保存我所有的消息。

var db = require('./db.js');
...
io.on('connection', function(socket){
  socket.emit('uconnected')
  socket.broadcast.emit('connected')
  socket.on('disconnect', function(){
    io.emit('disconnect')
  });
  socket.on('chat message', function(msg){
    io.emit('chat message', msg);
  });});

所以我不知道该怎么做，我有一些想法，但没有一个奏效。我知道你必须在某处添加它。

new Mes({
  content : $('#m').val(),
}).save( function ( err, todo, count ){
      if( err ) return next( err );
    });

Answer 1

试试这个:

var db = require('./db.js');
var Mes=require('Mes');
io.on('connection', function(socket){
    socket.emit('uconnected')
    socket.broadcast.emit('connected')
    socket.on('disconnect', function(){
        io.emit('disconnect')
    });
    socket.on('chat message', function(msg){
        io.emit('chat message', msg);
        Mes.create({content:msg}, function (err,success) {
            if(err)
            {
                //handle error
            }
            else{
                //handle success
            }
        })
    });});