Node.js Http 结束后写入

Question

我在 node.js 中写了一个简单的 CRUD Api。我的所有 POST、PUT 和 DELETE 函数在结束后不断收到写入。我已经失去了试图解决这个问题的所有感觉，并希望能有一双新的眼睛或一些关于试图追踪它的建议。 GET 工作得很好，并在 httpmgs.js.

中使用相同的代码 sendJSON()

我散布了各种评论，试图找出错误发生的位置。我不知道 req.on("end".. 是否引起了问题所以我重写了那部分无济于事。

controller.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;

staff.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:\JARVIS\API\peak-2.0\httpMsgs.js:60:14)
    at db.executeSql (E:\JARVIS\API\peak-2.0\controllers\staff.js:53:33)
    at Execute.conn.execute [as onResult] (E:\JARVIS\API\peak-2.0\db.js:35:9)
    at process.nextTick (E:\JARVIS\API\peak-2.0\node_modules\mysql2\lib\commands\query.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之后的所有case都会依次执行，直到结束。

编辑

尝试重新启动您的 SQL 服务器

更新

您有两个选择：在您的 sendJSON 函数中使用：

选项 1（无快递）：

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

或

选项 2（带快递）：这里不需要指定header类型

res.json(data);

Node.js Http 结束后写入

Node.js Http Write after end

api-design

http

node.js

reactjs