将stdout用于node.js / Express时出现ERR_HTTP_HEADERS_SENT错误

发布时间:2020-07-07 16:32

在我的节点应用程序中遇到了有据可查的“错误[ERR_HTTP_HEADERS_SENT]:将标头发送到客户端后无法设置标头”。我已经查看了有关此问题的现有网页,并尝试了补救措施-主要是确保“退还”所有其他回复;但是错误仍然存​​在。下面的代码。

您会注意到我有很多不同的路径通过子进程调用唯一的python函数。有趣的是,http错误仅在某些路径中显示-通常是输出非常大的路径。在所有情况下,响应到达并在客户端呈现都很好,但是使用较大的响应,我会收到http错误,并且我的应用程序将关闭。我可以想到一些潜在的非中间件原因-当响应变大时,潜在的res.send()行为会有所不同?或者,也许是subprocess.stdout导致响应较大的问题?或者,较长的响应时间可能会导致浏览器在传递响应之前重新发送请求?...想在进一步探讨潜在的中间件问题之前排除这些响应。谢谢

router.get('/element/chart', ensureAuthenticated, (req,res) => {
    const path = require('path')
    const {spawn} = require('child_process')
    console.log(current_data_page_id)
    console.log(typeof current_data_page_id)
    let runScript;

    runScript = (current_data_page_id) => {
        switch(current_data_page_id) {
            case "100":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_1.py')]); 
            break;
            case "101":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_2.py')]);
            break;
            case "102":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_3.py')]);
            break;
            case "103":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_4.py')]);
            break;
            case "104":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_5.py')]);
            break;
            case "200":
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_6.py')]);
            break;
            case "201": 
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_7.py')]);
            break;
            case "202": 
                return spawn('python', ["-u", path.join(process.cwd(),'/python/python_func_8.py')]);
            break;
            default:
                console.log("Data page ID does not match current options") 
        };
    };
    
    const subprocess = runScript(current_data_page_id)
    // print output of script
    subprocess.stdout.on('data', (data) => {
        var dataToSend = data.toString();
        console.log(dataToSend);
        res.send(dataToSend);
        res.end('end')
        return;
    });
    subprocess.stderr.on('data', (data) => {
        console.log(`error:${data}`);
        return;
    });
    subprocess.stderr.on('close', () => {
        console.log("Closed");
        return;
    });

});

// ensureAuthenticated middleware
module.exports = {
    ensureAuthenticated: function(req, res, next) {  
        if(req.isAuthenticated()) {
            return next();
        }
        req.flash('error_msg', 'Please log in to view this resource');
        res.sendFile(process.cwd() + '/views/login.html');
        return;
    }
}

下面的控制台输出。堆栈跟踪点指向“ res.send(dataToSend);”线。

_http_outgoing.js:536
    throw new ERR_HTTP_HEADERS_SENT('set');
    ^

Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
回答1

错误的原因是您多次调用“结束”请求,一个http请求只需要完成一次即可。 您致电res.send(dataToSend);res.end('end'),这意味着您两次完成了请求。

当您删除res.end('end');行时,该错误仍然会出现,因为res.send(dataToSend);被多次调用了,因为我认为您的“ python”命令超过了1行数据,然后{{ 1}}被打了很多次。

这种情况的想法是在“命令”完成(完成)时结束请求,您可以使用subprocess.stdout.on('data'进程的close事件(不是{{1} }。

使用数据(命令输出),我们有两种方式:

  • 将输出附加到字符串变量,并在命令完成后将其发送给客户端
spawn
  • 使用express api编写对subprocess.stdout对象的响应(我喜欢这种方式)
var data = ''; // init data store
subprocess.stdout.on('data', (data) => {
  var dataToSend = data.toString();
  console.log(dataToSend);
  data += dataToSend + '\n'; // append data with new line char :)
  // res.send(dataToSend);
  // res.end('end')
  // return;
});

// subscribe to close event
subprocess.on('close', (code) => {
  if (code !== 0) {
    console.log(`grep process exited with code ${code}`);
  }
  res.send(data); // send data to client and finish the request
});