如何使用 Express 4 路由中的 socket.io 向连接的套接字发出事件

我最终能够使用以下示例使事情正常工作：https://github.com/expressjs/generator/issues/45#issuecomment-53719435

我创建了一个名为server/io.js的新文件：

var io = require('socket.io')();
io.on('connection', function (socket) {
  socket.emit('news', { hello: 'world' });
  socket.on('my other event', function (data) {
    console.log(data);
  });
});
module.exports = io;

然后我server/bin/www更新为：

#!/usr/bin/env node
var debug = require('debug')('gokibitz');
var app = require('../../server');
var io = require('../io');
app.set('port', process.env.PORT || 3000);
var server = app.listen(app.get('port'), function() {
    debug('Express server listening on port ' + server.address().port);
});
io.attach(server);

然后，在我的路线中，我使用这个：

var io = require('../io');
...
io.emit(...);

至少对我来说，缺少的部分是能够单独创建io对象，返回正确的对象，然后在bin/www中使用io.attach(server)在正确的点启动它。

希望这能帮助其他人追随我的脚步。

我认为你对这些概念感到困惑。socket.io lib 与客户端使用或模拟 websocket（双向套接字），与路由没有关系。

您可以使用 io 对象向所有套接字发送通知：

io.emit('message_to_all', true);

你必须在io.sockets上有一个数组，所有套接字。

您可以使用命名空间或房间来，我建议您学习文档：

http://socket.io/docs/rooms-and-namespaces/#

添加一些内容：

如果要向同一路由中的所有人发送消息，可以加入具有相同路径名称的频道。

例如，在客户端中：

var socket = io(window.location.href); // Or route..

而服务器：

var nsp = io.of('/the/specific/route');
nsp.on('connection', function(socket){
  // ...
});
nsp.emit('message_to_all_in_route', data);

关于最后一个问题的编辑：

您可以使用 Express 中间件 API 将请求或响应对象中的 io 对象发送到路由：

例如：

#!/usr/bin/env node
var debug = require('debug')('gokibitz');
var app = require('../../server');
app.set('port', process.env.PORT || 3000);
var server = app.listen(app.get('port'), function() {
    debug('Express server listening on port ' + server.address().port);
});
var io = require('socket.io').listen(server);
app.use(function (req, res, next) {
  res.io = io;
  next();
});
io.on('connection', require('../routes/socket.js'));

在路线上：

route.post('/post/:id/comments', function (req, res) {
   // Do your logic
  var postio = res.io.of('/post/' + req.params.id);
  postio.emit('new_comment', commentData);
});

正如我在评论中所说，您可以通过以下方式发送给所有连接的客户端：

io.emit(msg, data);

这将需要访问您在第一个模块中创建的io对象。 与路由模式的模块共享它的常用方法是从路由模块导出一个方法，该方法允许您将io对象传递给它，然后在routes模块中需要并创建io对象后，您只需调用该方法将io对象传递给路由模块，它可以将其保存在本地以供将来使用。

io只是一个共享对象，就像app对象一样。 如果希望模块能够使用共享对象，通常的方法是调用该模块中的某个方法，以与其共享一些对象，然后可以使用这些对象。

我在该文件中sockets.js创建了一个新文件：

var socketio = require('socket.io');
var io;
module.exports = {
socketServer: function (app) {
    io = socketio.listen(app);
    io.on('connection', function (socket) {
        console.log(Object.keys(users));
        socket.on('message', function (data) {
            io.emit('updateChat', 'Hello World!')
        });
    });
  }
}

在我的app.js：

var express = require('express');
var app = express();
var http = require('http').createServer(app);
var port = process.env.PORT || 3000;
var io = require('./sockets').socketServer(http);
http.listen(port, function () {
    console.log('SERVER RUNNING.. PORT: ' + port)
});

这对我有用。祝你好运！