node.js - 如何从数据事件中取消 HTTP 上传？

Question

鉴于这个简单的网络服务器代码:

console.log('starting');
var server = require('http').createServer();

server.on('connection',function(socket){console.log('*server/connection');});
server.on(
    'request',
    function(request, response){
        console.log('*server/request');
        request.on(
            'data',
            function(chunk){
                console.log('*request/data');
                // <!> How do I abort next data calls from here?
            }
        );
        request.on(
            'readable',
            function(chunk){
                console.log('*request/readable');
                // <!> How do I abort next readable calls from here?
            }
        );
        request.on(
            'end',
            function(){
                console.log('*request/end');
                response.writeHead(200,"OK");
                response.write('Hello');
                response.end();
            }
        );
        request.on('close',function(){ console.log('*request/close'); } );
        request.on('error',function(){ console.log('*request/error'); } );
    }
);
server.on('close',function(){console.log('server/close');});
server.on('checkContinue',function(request, response){console.log('*server/checkContinue');});
server.on('connect',function(request, socket, head){console.log('*server/connect');});
server.on('upgrade',function(request, socket, head){console.log('*server/upgrade');});
server.on('clientError',function(exception, socket){console.log('*server/clientError');});

server.listen(8080);
console.log('started');

当提交 POST 或 FILE 时，我的 on data 功能会被触发一次或多次或多次。有时(比如发送了一个巨大的大文件)我想在数据事件上取消它并触发用户的 on end 功能(稍后我会显示“你的帖子/文件太大”) .我该怎么做？

Answer 1

这里正确的、符合规范的做法是简单地发送一个 HTTP 413尽早响应——也就是说，一旦您检测到客户端发送的字节数超过您想要处理的字节数。发送错误响应后是否终止套接字取决于您。这符合 RFC 2616:(已添加重点)

413 Request Entity Too Large

The server is refusing to process a request because the request entity is larger than the server is willing or able to process. The server MAY close the connection to prevent the client from continuing the request.

接下来发生的事情并不理想。

• 如果您让套接字保持打开状态，所有浏览器(Chrome 30、IE 10、Firefox 21)将继续发送数据，直到上传整个文件。然后，只有这样，浏览器才会显示您的错误消息。这真的很糟糕，因为用户必须等待整个文件完成上传，才发现服务器拒绝了它。它还会浪费您的带宽。

  浏览器当前的行为违反了 RFC 2616 § 8.2.2 :

  An HTTP/1.1 (or later) client sending a message-body SHOULD monitor the network connection for an error status while it is transmitting the request. If the client sees an error status, it SHOULD immediately cease transmitting the body. If the body is being sent using a "chunked" encoding (section 3.6), a zero length chunk and empty trailer MAY be used to prematurely mark the end of the message. If the body was preceded by a Content-Length header, the client MUST close the connection.

  有open Chrome和 Firefox问题，但不要指望很快就能解决问题。

• 如果在发送 HTTP 413 响应后立即关闭套接字，所有浏览器显然会立即停止上传，但 它们 大多数当前显示“连接重置” "错误(或类似错误)，而不是您可能在响应中发送的任何 HTML。

  同样，这可能违反了规范(允许服务器提前发送响应并关闭连接)，但我也不希望浏览器很快修复。

  更新:从 4 月 15 日起，Chrome 可能在您提前关闭连接时显示您的 413 HTML。这仅在浏览器在 Linux 和 Mac OS X 上运行时有效。在 Windows 上，Chrome 仍显示 ERR_CONNECTION_RESET 网络错误，而不是您发送的 HTML。 (IE 11 和 Firefox 37 在所有平台上继续只显示网络错误。)

因此，您对传统纯 HTTP 上传的选择是:

• 显示友好的错误消息，但仅在上传运行完成后。这会浪费时间和带宽。

• 快速失败，但让用户对神秘的浏览器错误屏幕感到困惑。

您最好的选择可能是使用 AJAX uploader ，您可以更好地控制用户体验。您仍然应该提供一个传统的上传表单作为后备，我会使用“快速失败”选项(关闭套接字)来防止浪费时间和带宽。

下面是一些示例代码，如果请求接收到超过 1 kB，则它会终止该请求。我正在使用 Express，但同样适用于 node 的 vanilla HTTP 库。

注意:实际上，您应该使用 formidable multiparty处理您的上传(这是 Connect/Express 使用的)，它有它的 own way监控上传数据。

var express = require("express")
    , app = express();

app.get('/', function(req, res) {
    res.send('Uploads &gt; 1 kB rejected<form action="/upload" method="post" enctype="multipart/form-data"><input type="file" name="file"><input type="submit"></form>');
});

app.post('/upload', function(req, res) {
    var size = 0;

    var gotData = function(d) {
        size += d.length; // add this chunk's size to the total number of bytes received thus far
        console.log('upload chunk', size);
        if (size > 1024) {
            console.log('aborting request');
            req.removeListener('data', gotData); // we need to remove the event listeners so that we don't end up here more than once
            req.removeListener('end', reqEnd);
            res.header('Connection', 'close'); // with the Connection: close header set, node will automatically close the socket...
            res.send(413, 'Upload too large'); // ... after sending a response
        }
    };

    var reqEnd = function() {
       res.send('ok, got ' + size + ' bytes');
    }

    req.on('data', gotData);

    req.on('end', reqEnd);
});

app.listen(3003);