Node.js http 在结束之后写入

Question

我在node.js中编写了一个简单的CRUD API。我在所有的 POST、PUT 和 DELETE 函数上都得到了一个写。我已经失去了试图解决这个问题的所有感觉，并希望有一双新鲜的眼睛或一些关于试图追踪它的建议。GET工作得很好，并在httpmgs.js中使用相同的代码sendJSON((。

我已经分散了各种评论，试图找出错误发生的位置。我不知道是否 req.on("结束"....导致了一个问题，所以我重写了那部分无济于事。

控制器.js：

switch (req.method){
case "GET":
if(req.url === "/staff"){
staff.getList(req, resp);
}
break;
case "POST":
if (req.url === "/staff/add"){
var reqBody = '';
req.on("data", function (data){
reqBody += data;
if(reqBody.length > 1e7){
msg.show413(req, resp);              
}
});
req.on("end", function() {
console.log(req.data)
staff.add(req, resp, reqBody)
});            
}
break;
case "PUT":
if (req.url === "/staff/update"){
var reqBody = '';
req.on("data", function (data){
reqBody += data;
if(reqBody.length > 1e7){
msg.show413(req, resp);
}
});
req.on("end", function() {
staff.update(req, resp, reqBody);
});
}
else{
msg.show404(req,resp);
}
break;

员工.js：

exports.add = function (req, resp, reqBody){
try{
if (!reqBody) throw new Error("Input not valid");
var data = JSON.parse(reqBody);
if (data){
db.executeSql("SELECT MAX(ID) AS ID FROM jarvisdb.staff",function (maxID, err){
if(err){
msg.show500(req, resp, err);
}
else{
var newID = maxID[0].ID+1
var sql = "INSERT INTO jarvisdb.staff (`ID`, `First Name`, `Last Name`) VALUES";
sql+= util.format("('%d' ,"%s", "%s")", newID, data.firstName, data.lastName); 
db.executeSql(sql, (data, err)=>{
if(err){
msg.show500(req, resp, err)
}
else{
console.log('Before send')
msg.sendJSON(req,resp,data)
console.log('After send')
}
})
}
});
}
else{
throw new Error("Input not valid");
}
}
catch (ex) {
console.log('500')
msg.show500(req, resp, ex);
}
};

httpMsgs.js：

exports.sendJSON = function(req,resp,data){
if(data){
console.log('Before Write')
resp.writeHead(200, {"Content-type" : "application/json"});
console.log('Write Head')
resp.write(JSON.stringify(data));
console.log('Write body')
resp.end();
console.log('end');
}
}

预期输出： 没有错误并发回 JSON

实际结果：

Listening on port 9000....
undefined
Before send
Before Write
Write Head
Write body
end
After send
events.js:174
throw er; // Unhandled 'error' event
^
Error [ERR_STREAM_WRITE_AFTER_END]: write after end
at write_ (_http_outgoing.js:572:17)
at ServerResponse.write (_http_outgoing.js:567:10)
at Object.exports.sendJSON (E:JARVISAPIpeak-2.0httpMsgs.js:60:14)
at db.executeSql (E:JARVISAPIpeak-2.0controllersstaff.js:53:33)
at Execute.conn.execute [as onResult] (E:JARVISAPIpeak-2.0db.js:35:9)
at process.nextTick (E:JARVISAPIpeak-2.0node_modulesmysql2libcommandsquery.js:76:16)
at process._tickCallback (internal/process/next_tick.js:61:11)
Emitted 'error' event at:
at writeAfterEndNT (_http_outgoing.js:634:7)
at process._tickCallback (internal/process/next_tick.js:63:19)

Answer 1

没有break;case后.因此，超出当前匹配case的所有情况将按顺序执行，直到结束。

编辑

尝试重新启动 SQL 服务器

更新

您有两个选择： 在发送 JSON 函数中使用：

选项 1(不带快递(：

resp.writeHead('Content-Type', 'application/json'); resp.end(JSON.stringify(data));

或

选项 2(带快递(： 在这里，您无需指定标头类型

res.json(data);