给出以下简单的网络服务器代码:
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函数 (稍后,我将显示“您的帖子/文件太大”)。我该怎么做?
正确的,符合规范的操作仅是尽早发送HTTP 413响应- 也就是说,一旦您检测到客户端发送的字节数超过了您想要处理的字节数。发送错误响应后是否终止套接字取决于您。这符合RFC 2616 :(添加了重点)
413请求实体太大 服务器拒绝处理请求,因为请求实体大于服务器愿意或能够处理的实体。 服务器可以关闭连接,以防止客户端继续请求。
服务器拒绝处理请求,因为请求实体大于服务器愿意或能够处理的实体。 服务器可以关闭连接,以防止客户端继续请求。
接下来发生的事情并不理想。
该浏览器目前的行为是违反RFC 2616的§ 8.2.2:
发送消息正文的HTTP / 1.1(或更高版本)客户端应该在传输请求时监视网络连接的错误状态。如果客户端看到错误状态,它应该立即停止发送主体。如果使用“块式”编码发送正文(第3.6节),则可以使用零长度的块和空的预告片来过早地标记消息的结尾。如果主体之前是Content- Length标头,则客户端务必关闭连接。
Chrome和Firefox存在开放问题,但是不要指望很快会修复。
同样,这可能违反了规范(允许服务器提前发送响应并关闭连接),但是我也不希望浏览器在此之前很快得到修复。
更新: 从4/15开始,Chrome 可能会 在您提前关闭连接时显示413 HTML。仅当浏览器在Linux和Mac OS X上运行时,此方法才有效。在Windows上,Chrome仍然显示ERR_CONNECTION_RESET网络错误,而不是您发送的HTML。(IE 11和Firefox 37继续在所有平台上显示网络错误。)
ERR_CONNECTION_RESET
因此,您可以使用传统的纯HTTP上传方式进行选择:
仅在上传运行完成后显示友好的错误消息。这浪费时间和带宽。
快速失败,但让用户困惑于浏览器的错误屏幕。
在这里最好的选择是使用AJAX上传器,您可以在其中更好地控制用户体验。您仍然应该提供传统的上传表单作为后备,并且我将使用“快速失败”选项(关闭套接字)来避免浪费时间和带宽。
这是一些示例代码,如果收到的请求超过1 kB,该示例代码将杀死该请求。我使用的是Express,但对节点的普通HTTP库也应如此。
注意: 实际上,您应该使用 强大的 多方来处理您的上载(这是Connect / Express所使用的),并且它有自己的方式来监视上载数据。
var express = require("express") , app = express(); app.get('/', function(req, res) { res.send('Uploads > 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);