javascript - 在路由端点之外访问请求属性

Question

var express = require('express');
var router  = module.exports = express.Router();
var server = require("http").Server(express);  
var io = require("socket.io")(server);
server.listen(5000);

//how to get my user.id here?


router.get('/', function(req, res) {

  io.on('connection', function(client) {
    client.on('order_'+req.user.id, function(data) {
        io.emit('order_'+req.user.id,data); 
    });      
  });

});

上面的代码运行良好，但是有一个问题。如果用户刷新页面/或重新进入页面，连接就会成倍增加。我应该放在 router.get('/'.. 之外，但我必须使用 req.user.id。

知道如何获取 user.id 吗？？

Answer 1

正如我已经提到的，您不需要处理这个问题，因为在刷新时客户端会关闭旧连接并且新页面加载应该再次连接，因此没有多个连接。

我的样本

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

app.get('/', function(req, res){
    res.sendfile('index.html');
});

io.on('connection', function(socket){
    console.log('CONNECTED!');

    socket.on('disconnect', function () {
        console.log('DISCONNECTED!');
    });
});

http.listen(3000, function(){
    console.log('listening on *:3000');
});

只需刷新几次选项卡，您将在服务器上获得以下输出:

CONNECTED!
DISCONNECTED!
CONNECTED!
DISCONNECTED!
CONNECTED!
...

传递用户id

无论如何，这应该通过将用户 ID 信息从客户端传递到服务器来完成，您可以通过为其定义新事件来完成，例如 authenticated

socket.on('authenticated', function(userId) {
    socket.on('disconnect', function () {
        console.log(userId + ' DISCONNECTED!');
    });
});

或者将其作为附加数据与每个事件一起传递。

socket.on('someEvent', function(someData, userId) {
    //...
});

替代方案可以使用类似 session.socket.io 的模块

sessionSockets.on('connection', function (err, socket, session) {
    //your regular socket.io code goes here
    //and you can still use your io object
});

从路由发出事件

为了从路由中发出事件，您需要在 express 和 socket.io 之间建立某种连接，这可以通过这样的映射来完成:

var sockets = {};
socket.on('authenticated', function(userId) {
    sockets[userId] = socket; 
    ...
});

内部路由仅使用 sockets[userId].emit 来发出事件。

引用

• > http://socket.io/docs/#sending-volatile-messages
• > http://socket.io/get-started/chat/
• > https://github.com/facundoolano/socketio-auth
• > https://github.com/wcamarao/session.socket.io