nodejs express错误：发送后无法设置标头

Question

我正在 nodejs 中读取一个不断增长的文件。在我的 app.js 中使用以下代码。

app.post('/readfile',function (req,res) {   
    var fullfilename = req.body.filepath+"\\"+req.body.filename;
    var bite_size = 256;
    var readbytes = 0;
    var file;

    fs.open(fullfilename, 'r', function(err, fd) {
        file = fd;      
        if(err){console.log(err); throw err; return;};
        var mybuff;
        var func = (function readsome() {               
        var stats = fs.fstatSync(fd); // yes sometimes async does not make sense!
                if(stats.size<readbytes+1) {                    
                    setTimeout(readsome, 1000);
                }
                else {
                    fs.read(fd, new Buffer(bite_size), 0, bite_size, readbytes, function (err, bytecount, buff) {
                    //console.log(buff.toString('utf-8', 0, bytecount));
                    res.json(buff.toString('utf-8', 0, bytecount));
                    readbytes+=bytecount;
                    process.nextTick(readsome);
                    });
                };          
        })();           
    }); 
}); 

并像下面这样在 html 中调用它，

var myApp= angular.module("myApp", [])
myApp.controller('Ctrl1', function ($scope, $http,$q) {
        var FileName = "test.txt"
        var obj = {"filepath" : 'D:\\Temp', "filename" : FileName};

        $http({
                url: '/readTfile',
                method: "POST",
                data: JSON.stringify(obj)
                //timeout: canceller.promise,
                //headers: {'Content-Type': 'application/json','charset' : 'utf-8'}
                }).success(function(result) {               
                $scope.myfiledata = result;                     
                }).error(function(data, status) {
                console.log(data);
                }); 
});

当我将此 app.js 代码放在单独的文件 (readfile.js) 中时，这工作正常，但是当我放入 app.js 时，它会出错。

_http_outgoing.js:357
    throw new Error('Can\'t set headers after they are sent.');
    ^
Error: Can't set headers after they are sent.
    at ServerResponse.OutgoingMessage.setHeader (_http_outgoing.js:357:11)
    at ServerResponse.header (D:\myapp\node_modules\express\lib\response.js:725:10)
    at ServerResponse.send (D:\myapp\node_modules\express\lib\response.js:170:12)
    at ServerResponse.json (D:\myapp\node_modules\express\lib\response.js:256:15)
    at D:\myapp\app.js:130:10
    at FSReqWrap.wrapper [as oncomplete] (fs.js:682:17)
[nodemon] app crashed - waiting for file changes before starting...

请帮助找出错误在哪里以及要更改的内容。其次，我想在单击按钮时停止此调用，我该怎么做？

Answer 1

这只是一个猜测，但是，在 app.js 中添加代码之前，您是否删除了旧代码？

也许你的 /readfile 路由是由 app.js 和单独的文件添加的，所以第一个路由发出响应，当第二个路由开始做同样的事情时，它得到响应已经发送的错误.

Answer 2

您只能根据请求致电res.json 一次。它设置相关的标头，JSON 对数据进行编码，将其作为响应发送，然后结束请求。

如果你只是想写一些数据你可以使用write:https://nodejs.org/api/http.html#http_response_write_chunk_encoding_callback

或者也许您可以使用管道来代替您完成这一切？

var readStream = fs.createReadStream(fullfilename);
readStream.pipe(res);