在express4中的层之间传递socketio引用

Question

我刚刚开始使用 websockets 和 express，但我似乎无法让它与我当前的架构一起工作。

我在另一个问题中看到在我声明我的路线之前要执行以下操作

//this goes prior to your route registration
app.use(function(req, res, next) {
    req.io = io;
});

但我什至不确定如何将 io 传递给我的应用程序 js 以使用上面的代码 sn-p。

我有我的 bin/www：我相信这是在 express4 中引入的？套接字在这里连接良好

#!/usr/bin/env node

/**
 * Module dependencies.
 */

var app = require('../app');
var debug = require('debug')('server:server');
var http = require('http');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
 * Create HTTP server.
 */

var server = http.createServer(app);

/**
 * attach socket to express
 */
var io = require('socket.io').listen(server);

/**
 * Listen on provided port, on all network interfaces.
 */

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);


io.sockets.on('connection', function() {
  console.log('!!!sockets io connected!!!');
})

/**
 * Normalize a port into a number, string, or false.
 */

function normalizePort(val) {
  var port = parseInt(val, 10);

  if (isNaN(port)) {
    // named pipe
    return val;
  }

  if (port >= 0) {
    // port number
    return port;
  }

  return false;
}

我的 app.js。这是我想使用第一个代码sn-p的地方吗？但我不确定如何将“io”传递给这个文件

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

/**
 * Route Imports
 */

var app = express();

app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());

//THIS IS WHERE I WOULD PUT IT???? assuming I can pass IO into this??
app.use(function(req, res, next) {
    req.io = io;
});

/**
 * Routes
 */
var router = require('./router')(app);

module.exports = app;

路由器 index.js

/**
 * The Index of Routes
 */

module.exports = function (app) {

  app.use('/test', require('./routes/test'));
}

最后是路线，我假设一旦我在 app.js 中获得第一个 sn-p，这将起作用，因为它将附加到 req？

var express = require('express');
var router  = express.Router();

router.get('/', function (req, res) {
   //I WANT SOCKET TO JUST RESPOND WITH ANYTHING BUT I CANT GET 
   //AN INSTANCE OF IO IN HERE
   req.io.emit('test', 'hihi');
});

router.post('/', function (req, res) {
  test.save(function (err) {

    if (err) {
      console.log(err);
      res.status(500).json({
        'message': 'error'
      });
    } else {
      // Log success
      console.log('Success');
      req.io.emit('test:added', test);
      res.status(201);
    }

  });
});
module.exports = router;

**注意：为了可读性删除了很多代码**

Answer 1

主模块：

var app = express();
// ...
var server = http.createServer(app);
// ...
var io = require('socket.io').listen(server);

// ...

app.use(function (req, res, next) {
  req.io = io;
})

require('../app')(app); 
require('../routes')(app);    

您的应用模块公开了app 实例，因此如果您有权访问io，则可以在主模块中使用它。很简单。