Socket.io 在 Express Route 上发出

Question

我想在调用某些 API 路由时向客户端发送一些数据。 我必须遵循 server.js 上的代码

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

var io   = require('socket.io')(http);

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

  socket.emit('tx', 'msg');

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

现在我有这条路线 /test:

var bsg   = require('./routes/test');

还有那个文件：

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

router.get('/test',  function(req, res) {
  //work here
});

module.exports = router;

在客户端：

<script type="text/javascript">
   var socket = io();

   socket.on('tx', function(data) {
     console.log(data);
   });
</script>

什么是最好的解决方案？

谢谢！

Express 4 / socket.io 1.4.5

Answer 1

将io 实例附加到您的应用。

app.io = io;

然后就可以通过请求访问了。

router.get('/test',  function(req, res) {
  req.app.io.emit('tx', {key:"value"});
});

我应该注意，将数据附加到 express 更“正确”的方法是使用 app.set('io', io) 和 app.get('io') 来检索它，以防 express 开始使用 io 属性。

如果您希望向单个客户端发送数据，则需要保留某种会话映射以将独立的 http 请求链接到套接字。会话 ID 可能不是一对一的映射，因为您可以为一个会话打开多个套接字。你最好直接使用 socket.io 回调处理请求/响应模式。

Answer 2

您也可以将实例附加到 req 对象：

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

并发射到单个客户端

req.io.to(<socketId of cient>).emit(data);