Блог

Главная - Вопросы по программированию - Я не могу отправлять какие-либо сообщения с socket.io

Я не могу отправлять какие-либо сообщения с socket.io

#node.js #sockets #express #socket.io

#node.js #сокеты #выразить #socket.io

Вопрос:

Я пытаюсь создать комнату чата, где я передаю сеанс пользователя из passport express в socket.io . но теперь я не могу отправлять какие-либо сообщения. io.on, похоже, не подключается.

Я не получаю никаких сообщений об ошибках

Вот мой код

 var express = require('express');
var app = express();
var server = require('http').Server(app);

var port = process.env.PORT || 8080;
var mongoose = require('mongoose');
var passport = require('passport');
var flash = require('connect-flash');

var morgan = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var session = require('express-session');

// Add connect-mongo to project - npm install connect-mongo
var MongoStore = require('connect-mongo')(session);

var configDB = require('./config/database.js');
var http = require('http').Server(app);
var io = require('socket.io')(http);
var chatdb = require('./app/models/chat.js');

// configuration ===============================================================
// NOTE: This might need to be put into a callback/promise inside an initialize function
var db = mongoose.connect(configDB.url); // connect to our database

require('./config/passport')(passport); // pass passport for configuration

// set up our express application
app.use(morgan('dev')); // log every request to the console
app.use(cookieParser()); // read cookies (needed for auth)
app.use(bodyParser()); // get information from html forms

app.set('view engine', 'ejs'); // set up ejs for templating


// required for passport
app.use(session({ secret: 'secret' })); // session secret
app.use(passport.initialize());
app.use(passport.session()); // persistent login sessions
app.use(flash()); // use connect-flash for flash messages stored in session
app.use(express.static(__dirname   '/views'));
app.use(express.static(__dirname   '/public'));

// Create a MongoDB storage object
var mongoStore = new MongoStore({
  mongooseConnection: db.connection,
  collection: configDB.sessionCollection,
});

// Intercept Socket.io's handshake request
io.use(function (socket, next) {
  // Use the 'cookie-parser' module to parse the request cookies
  cookieParser('secret')(socket.request, {}, function (err) {
      // Get the session id from the request cookies
      var sessionId = socket.request.signedCookies ? socket.request.signedCookies['session-key'] : undefined;

      if (!sessionId) return next(new Error('sessionId was not found in socket.request'), false);

      // Use the mongoStorage instance to get the Express session information
  mongoStore.get(sessionId, function (err, session) {
      if (err) return next(err, false);
      if (!session) return next(new Error('session was not found for '   sessionId), false);

      // Set the Socket.io session information
      socket.request.session = session;
      console.log(session);
      console.log(socket.request.user);

      // Use Passport to populate the user details
      passport.initialize()(socket.request, {}, function () {
      passport.session()(socket.request, {}, function () {
      // This will prohibit non-authenticated users from connecting to your
      // SocketIO server.
  if (socket.request.user) {
  next(null, true);
  } else {
  next(new Error('User is not authenticated'), false);
  }
    });
    });
    });
    });
});

// socket.io
io.on('connection', function (socket) {
  console.log('a user connected');

  socket.on('chat message', function(msg){
    console.log('a use connected');
    var name = "efe";
    chatdb.saveMsg({name: name, msg: msg}, function(err){
      if(err) throw err;
      io.emit('chat message', msg);
      });
    });

  socket.on('disconnect', function () {
  console.log('user disconnected');
});
});

// routes ======================================================================
require('./app/routes.js')(app, passport); // load our routes and pass in our app and fully configured passport

// launch ======================================================================
http.listen(port);
console.log('The magic happens on port '   port);

Это мой код на стороне клиента.

 <!doctype html>
<html>
  <head>
    <title>chat message</title>

    <link rel="stylesheet" href="/css/chat.css" type="text/css"/>
  </head>
  <body>
    <div class="messages"><br/><br/><br/><br/><br/><br/> </div>
    <form action="">
      <input id="m" autocomplete="off" /><button>Send</button>
    </form>
    <script src="https://cdn.socket.io/socket.io-1.3.7.js"></script>
    <script src="http://code.jquery.com/jquery-1.11.1.js"></script>
    <script>
      var socket = io();
      $('form').submit(function(){
        socket.emit('chat message', $('#m').val());
        $('#m').val('');
        return false;
      });
      socket.on('chat message', function(msg){
        $('.messages').append($('<div class=bubble><br/>').text(msg));
      });
    </script>
  </body>
</html>

Комментарии:

1. Просто чтобы вы знали, if(err) throw err; внутри асинхронного обратного вызова обработка ошибок практически бесполезна, поскольку ошибка никуда не приводит. Полезная.

2. Работает ли это, если вы закомментируете все io.use() , чтобы у вас был гораздо более простой сокет. ответчик чата ввода-вывода? И что вы наблюдаете? Работают ли ваши экспресс-маршруты? Запущен ли сервер? Успешно ли клиент подключается к socket.io ? Где соответствующий клиентский сокет. код ввода-вывода?

3. Спасибо за совет по обработке ошибок, новичок в javascript. это сработает, если я закомментирую io.use(). все экспресс-маршруты работают. сервер работает, и я добавил соответствующий код на стороне клиента.

4. @jfriend00 Я попытался просмотреть каждую строку и пока обнаружил, что проблема в моем mongostore.

Ответ №1:

Это было мое исправление 

 var express = require('express');
var app = express();
var server = require('http').Server(app);

var port = process.env.PORT || 8080;
var mongoose = require('mongoose');
var passport = require('passport');
var flash = require('connect-flash');

var morgan = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');
var session = require('express-session');

// Add connect-mongo to project - npm install connect-mongo
var MongoStore = require('connect-mongo')(session);

var configDB = require('./config/database.js');
var http = require('http').Server(app);
var io = require('socket.io')(http);
var chatdb = require('./app/models/chat.js');

// configuration ===============================================================
// NOTE: This might need to be put into a callback/promise inside an initialize function
var db = mongoose.connect(configDB.url); // connect to our database

require('./config/passport')(passport); // pass passport for configuration

// set up our express application
app.use(morgan('dev')); // log every request to the console
app.use(cookieParser()); // read cookies (needed for auth)
app.use(bodyParser()); // get information from html forms

app.set('view engine', 'ejs'); // set up ejs for templating
var mongoStore = new MongoStore({
  mongooseConnection: db.connection,
});
app.use(session({
  secret: 'secret',
  clear_interval: 900,
  cookie: { maxAge: 2 * 60 * 60 * 1000 },
  store: mongoStore,
}));



// required for passport
app.use(session({ secret: 'secret' })); // session secret
app.use(passport.initialize());
app.use(passport.session()); // persistent login sessions
app.use(flash()); // use connect-flash for flash messages stored in session
app.use(express.static(__dirname   '/views'));
app.use(express.static(__dirname   '/public'));




// Intercept Socket.io's handshake request
io.use(function(socket, next) {

    // Use the 'cookie-parser' module to parse the request cookies
    cookieParser('secret')(socket.request, {}, function(err) {

        // Get the session id from the request cookies
        var sessionId = socket.request.signedCookies ? socket.request.signedCookies['connect.sid'] : undefined;

        if (!sessionId) return next(new Error('sessionId was not found in socket.request'), false);

        // Use the mongoStorage instance to get the Express session information
        mongoStore.get(sessionId, function(err, session) {
            console.log('efe');
            if (err) return next(err, false);
            if (!session) return next(new Error('session was not found for '   sessionId), false);

            // Set the Socket.io session information
            socket.request.session = session;
            console.log(sessionId);
            console.log(socket.request.user);

            // Use Passport to populate the user details
            passport.initialize()(socket.request, {}, function() {
                passport.session()(socket.request, {}, function() {
                    // This will prohibit non-authenticated users from connecting to your
                    // SocketIO server.
                    if (socket.request.user) {
                        next(null, true);
                    } else {
                        next(new Error('User is not authenticated'), false);
                    }
                });
            });
        });
    });
  });

// socket.io
io.on('connection', function(socket) {
    console.log('a user connected');

    socket.on('chat message', function(msg) {
        console.log('a use connected');
        var name = "efe";
        chatdb.saveMsg({
            name: name,
            msg: msg
        }, function(err) {
            if (err) throw err;
            io.emit('chat message', msg);
        });
    });

    socket.on('disconnect', function() {
        console.log('user disconnected');
    });
});

// routes ======================================================================
require('./app/routes.js')(app, passport); // load our routes and pass in our app and fully configured passport

// launch ======================================================================
http.listen(port);
console.log('The magic happens on port '   port);