我正在使用 Node.js 创建一个媒体上传微服务。该服务的工作原理是将上传的二进制数据接收到缓冲区，然后使用 S3 npm 包上传到 S3 存储桶。我正在尝试使用该包中的 eventEmitter，它显示上传到 S3 的数据量，并将其发送回正在上传的客户端(以便他们可以看到上传进度)。我正在使用 socket.io 将进度数据发送回客户端。

我遇到的问题是 socket.io 中的 .emit 事件会将上传进度数据发送到所有连接的客户端，而不仅仅是发起上传的客户端。据我了解，一个套接字连接到“连接”上的默认房间，该房间由客户端的“id”镜像。根据官方文档，使用 socket.to(id).emit() 应该只将范围内的数据发送到该客户端，但这对我不起作用。

更新示例代码:

服务器.js:

var http = require('http'),
users = require('./data'),
app = require('./app')(users);

var server = http.createServer(app);

server.listen(app.get('port'), function(){
  console.log('Express server listening on port ' + app.get('port'));
});

var io = require('./socket.js').listen(server);

套接字.js:

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

var socketConnection = exports = module.exports = {};

socketConnection.listen = function listen(app) {
    io = socketio.listen(app);
    exports.sockets = io.sockets;

    io.sockets.on('connection', function (socket) {
        socket.join(socket.id);
        socket.on('disconnect', function(){
            console.log("device "+socket.id+" disconnected");
        });
        socketConnection.upload = function upload (data) {
        socket.to(socket.id).emit('progress', {progress:(data.progressAmount/data.progressTotal)*100});
    };
});
return io;   
};

s3upload.js:

var config = require('../config/aws.json');
var s3 = require('s3');
var path = require('path');
var fs = require('fs');
var Busboy = require('busboy');
var inspect = require('util').inspect;

var io = require('../socket.js');
...
var S3Upload = exports = module.exports = {};
....
S3Upload.upload = function upload(params) {
// start uploading to uploader
var uploader = client.uploadFile(params);

uploader.on('error', function(err) {
    console.error("There was a problem uploading the file to bucket, either the params are incorrect or there is an issue with the connection: ", err.stack);
    res.json({responseHTML: "<span>There was a problem uploading the file to bucket, either the params are incorrect or there is an issue with the connection. Please refresh and try again.</span>"});
    throw new Error(err);
}),

uploader.on('progress', function() {
    io.upload(uploader);
}),

uploader.on('end', function(){
    S3Upload.deleteFile(params.localFile);
});
};

当使用 DEBUG=* node myapp.js 时，我看到 socket.io-parser 接受了这些信息，但它没有将它发送给客户端:

socket.io-parser encoding packet {"type":2,"data":["progress",{"progress":95.79422221709825}],"nsp":"/"} +0ms


socket.io-parser encoded {"type":2,"data":["progress",{"progress":95.79422221709825}],"nsp":"/"} as 2["progress",{"progress":95.79422221709825}] +0ms

但是，如果我删除此代码的 .to 部分，它会将数据发送到客户端(尽管是发送给所有客户端，这根本无济于事):

io.sockets.on('connection', function(socket) {
    socket.join(socket.id);
    socket.emit('progress', {progress: (data.progressAmount/data.progressTotal)*100});
});

DEBUG=* Node myapp.js:

socket.io:client writing packet {"type":2,"data":["progress",{"progress":99.93823786632886}],"nsp":"/"} +1ms
  socket.io-parser encoding packet {"type":2,"data":["progress",{"progress":99.93823786632886}],"nsp":"/"} +1ms
  socket.io-parser encoded {"type":2,"data":["progress",{"progress":99.93823786632886}],"nsp":"/"} as 2["progress",{"progress":99.93823786632886}] +0ms
  engine:socket sending packet "message" (2["progress",{"progress":99.93823786632886}]) +0ms
  engine:socket flushing buffer to transport +0ms
  engine:ws writing "42["progress",{"progress":99.84186540937002}]" +0ms
  engine:ws writing "42["progress",{"progress":99.93823786632886}]" +0ms

我在这里做错了什么？是否有不同的方式从服务器向我缺少的特定客户端发出事件？

最佳答案

您发布的第二个代码示例应该可以工作，如果没有，您应该发布更多代码。

As I understand it, a socket connects to a default room on 'connection', which is mirrored by the 'id' on the client side. According to the official docs, using socket.to(id).emit() should send the data scoped only to that client, but this is not working for me.

Socket.io 比这容易得多。下面的代码将在连接时向每个客户端发送一条“hello”消息:

io.sockets.on('connection', function (socket) {
  socket.emit('hello');
});

每次新客户端连接到 socket.io 服务器时，它将使用该特定套接字作为参数运行指定的回调。 socket.id只是一个识别该套接字的唯一代码，但您实际上不需要该变量来做任何事情，上面的代码向您展示了如何通过特定的 socket 发送消息。 .

Socket.io 还为您提供了一些创建命名空间/房间的功能，因此您可以将连接分组在某个标识符(房间名称)下，并能够向所有这些连接广播消息:

io.sockets.on('connection', function (socket) {
    // This will be triggered after the client does socket.emit('join','myRoom')
    socket.on('join', function (room) {
        socket.join(room); // Now this socket will receive all the messages broadcast to 'myRoom'
    });
...

现在你应该明白了socket.join(socket.id)只是没有意义，因为没有套接字会共享套接字 ID。

编辑以使用新代码回答问题:

这里有两个问题，首先:

    socketConnection.upload = function upload (data) {
        socket.to(socket.id).emit('progress', {progress:(data.progressAmount/data.progressTotal)*100});
    };

请注意上面的代码中 io.sockets.on('connection',function (socket) { 中的所有内容每次客户端连接到服务器时都会运行。您正在覆盖函数以将其指向最新用户的套接字。

另一个问题是您没有链接套接字和 s3 操作。这是合并 socket.js 的解决方案和 s3upload.js在同一个文件中。如果您真的需要将它们分开，您将需要找到一种不同的方式将套接字连接链接到 s3 操作:

var config = require('../config/aws.json');
var s3 = require('s3');
var path = require('path');
var fs = require('fs');
var Busboy = require('busboy');
var inspect = require('util').inspect;
var io = require('socket.io');

var socketConnection = exports = module.exports = {};
var S3Upload = exports = module.exports = {};

io = socketio.listen(app);
exports.sockets = io.sockets;

io.sockets.on('connection', function (socket) {

    socket.on('disconnect', function(){
        console.log("device "+socket.id+" disconnected");
    });

    socket.on('upload', function (data) { //The client will trigger the upload sending the data
        /*
            some code creating the bucket params using data
        */
        S3Upload.upload(params,this);
    });
});

S3Upload.upload = function upload(params,socket) { // Here we pass the socket so we can answer him back
    // start uploading to uploader
    var uploader = client.uploadFile(params);

    uploader.on('error', function(err) {
        console.error("There was a problem uploading the file to bucket, either the params are incorrect or there is an issue with the connection: ", err.stack);
        res.json({responseHTML: "<span>There was a problem uploading the file to bucket, either the params are incorrect or there is an issue with the connection. Please refresh and try again.</span>"});
        throw new Error(err);
    }),

    uploader.on('progress', function() {
        socket.emit('progress', {progress:(uploader.progressAmount/uploader.progressTotal)*100});
    }),

    uploader.on('end', function(){
        S3Upload.deleteFile(params.localFile);
    });
};

关于javascript - Socket.io 无法将数据发送到客户的唯一房间，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33790470/