提问者:小点点

socket.io私密消息(&I)


这个问题肯定已经问过一千遍了,但是我没有找到任何一个令人满意的答案,所以我会尝试再问一遍,尽可能的清晰。

我从一辆干净的快车开始;通常通过以下终端命令完成的任务:

user$ express
user$ npm install

然后继续安装socket.io,方法如下:

user$ npm install socket.io --save

在我的main.js文件中有以下内容:

//app.js
var express  = require('express'),
  http     = require('http'),
  path     = require('path'),
  io       = require('socket.io'),
  routes   = require('./routes');

var app = express();

我通过将Socket.io服务器连接到express服务器来启动它:

//app.js
var server = http.createServer(app).listen(app.get('port'), function(){
  console.log('express server started!');
});

var sIo = io.listen(server);

我现在所做的是为Express设定通常的工作路线:

//app.js
app.get('/', routes.index);
app.get('/send/:recipient/:text', routes.sendMessage);

现在,既然我喜欢保持事情有条理,我想把我的socket.io代码放在另一个文件中,所以不使用通常的代码:

//app.js
sIo.sockets.on('connection', function(socket){
  console.log('got a connection');
});

我使用以下方法来访问套接字和sIo对象(因为该对象包含所有连接信息(重要)):

//app.js
sIo.sockets.on('connection', function(socket){
  routes.connection(sIo, socket);
});

// index.js (./routes)
exports.connection = function(sIo, socket){
  console.log('got a connection.');
};

这样我就可以在这里做我所有的socket.io工作了。我知道我现在可以从sIo对象访问我的所有客户端信息,但当然,它们不包含关于其会话数据的任何信息。

我现在的问题是:

>

  • 假设用户发出HTTP请求以发送消息,而我的路由中的处理程序如下所示:

    exports.sendmessage=function(req,res){//在这里做事情};

    我怎样才能让它在我的socket.io中“激发”一些东西来发送消息呢?我不想知道所有需要做的底层工作,比如跟踪消息、用户等,我只想了解如何“激发”socket.io来做一些事情。

    1. 如何确保socket.io只将消息发送给特定的人,并100%确保没有其他人收到消息?据我所知,没有办法从sIo对象获取会话信息。

    提前道谢。


  • 共1个答案

    匿名用户

    问题一:将两者分开的最干净的方法可能是使用EventEmitter。您可以创建一个EventEmitter,当http消息传入时发出该EventEmitter。您可以将会话信息与事件一起传递,以便在必要时将其绑定回发送消息的用户。

    // index.js (./routes)
    var EventEmitter = require('events').EventEmitter;
    
    module.exports.messageEmitter = messageEmitter = new EventEmitter();
    
    module.exports.sendMessage = function(req, res) {
      messageEmitter.emit('private_message', req.params.recipient, req.params.text);
    };
    

    问题2:您可以在进行初始连接时访问套接字。一个主要借用这个答案的例子:

    var connect = require('connect'),
        userMap = {};
    
    routes.messageEmitter.on('private_message', function(recipient, text) {
        userMap[recipient].emit('private_message', text);  
    });
    
    io.on('connection', function(socket_client) {
      var cookie_string = socket_client.request.headers.cookie;
      var parsed_cookies = connect.utils.parseCookie(cookie_string);
      var connect_sid = parsed_cookies['connect.sid'];
      if (connect_sid) {
        session_store.get(connect_sid, function (error, session) {
          userMap[session.username] = socket_client;
        });
      }
    
      socket_client.on('private_message', function(username, message) {
          userMap[username].emit(private_message, message)
      });
    });
    

    所以我们只是在会话的用户名和套接字连接之间创建一个映射。现在,无论何时需要发送消息,您都可以轻松地查找与该用户关联的套接字,并使用他们的套接字向他们发送消息。只需确保处理断开,并在多个选项卡中重新连接和连接,等等。