socket.io 从 express.js 控制器发出到调用 API 端点的特定客户端

Question

你好我的 StackOverflow 朋友们， 我从位于 express.js 控制器函数内的套接字发射，因为我需要在用户的配置文件完成后通知用户。

我需要向调用 API 端点并触发控制器功能的特定客户端发出。

知道如何最好地做到这一点吗？

我正在考虑在 API 调用中将 socket_id 从客户端发送到服务器？

谢谢！

编辑 我意识到问题在于 express.js 和 socket.io 不共享会话数据，它们没有连接到中间件中。这篇文章设计了一个解决方案。 socket.io and express 4 sessions

Answer 1

在您的套接字处理程序中使用 socket.emit，如下所示：

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

io.on('connection', function(socket){
  socket.on('someEndpoint', function(message){
    socket.emit('someClientEndPoint', 'You sent a message to someEndpoint');
  });
});

Answer 2

以下实现解决了发起 API 请求的套接字通信问题。它遵循通过请求发送socketid的想法。当用户在同一浏览器中打开多个选项卡时共享会话变量不起作用，因为浏览器在选项卡之间分配了相同的 cookie/会话。

服务器代码

  socketio.on('connection', function(socket) {
    socket.address = `${socket.request.connection.remoteAddress}:${socket.request.connection.remotePort}`;

    //  USED TO SET THE SOCKET ID FOR THE REQUEST
    socket.emit('initialize', socket.id)


    socket.connectedAt = new Date();
}

客户代码
在 Angular 中，我设置了一个初始化事件来存储选项卡的特定套接字 ID

    this.socket.on('initialize', socketid => {
        console.log(socketid)
        this.socketid = socketid
    })

当请求发送到express时，我将socketid作为header发送

return this.$http({
    method: 'POST',
    withCredentials: true,
    host: '127.0.0.1',
    data: sim_data,
    port: 3000,
    responseType: "arraybuffer",
    headers: {
        "X-socketid": this.socketid
    },
    url: '/api/blah'
})

服务器代码
最后，当 express 处理 POST 或 get i 从 Header 发出到 socketid 时

    // GET SOCKET ID FROM HEADER
    var socket_id = req.headers['x-socketid']

    if (typeof socket_id !== 'undefined' && socket_id) {
        var io = req.app.get('io')
        io.sockets.connected[socket_id].emit('pyr', output)
    }

我的下一步是将其与用户授权集成。