Node.js Express API：如何处理多个回调

Question

我有一个 API 端点，它执行一个函数，该函数又通过 Web 套接字监听一些事件，然后通过回调将它的响应返回给 api 端点，因此端点可以用这个对象响应http 请求。

有时我只收到一个事件，有时我从侦听器收到两个事件。当只出现第一个事件时，我没有问题。因为第二个事件有优先级，所以我使用setTimeout 等待它，以防它仍然出现。

问题在于，当第二个事件出现时，我的 API 端点用它的对象进行响应，但之后它崩溃了。我想它与第二个回调有关，我不知道如何处理它。这就是代码的结构：

app.get('/api/myendpoint', function(req, res) {

    myVar_1 = req.query.myvar1;
    myVar_2 = req.query.myvar2;

    myFunction(myVar_1, myVar_2, function(data, error) {
        if (!error) res.json(data);
        else res.json({"error": String(error)});        
    });

});


function myFunction(myVar_1, myVar_2, callback){

    listenOnSocket.someEvent(myVar_1,
        function(error, event) {
            if (error) callback(null, error);
            else setTimeout(function() {callback(event, null);}, 6000);
        }
    );    

    listenOnSocket.someEvent(myVar_2,
        function(error, event) {
            if (!error) callback(event, null); 
            else callback(null, error);
        }
    );

};

这是我的错误的样子：

错误 [ERR_HTTP_HEADERS_SENT]：发送后无法设置标头 给客户

Answer 1

为什么会这样？

1. 1st 事件发生时，您设置 timeout for 6000 ms 以调用回调函数。
2. 2nd 事件发生在 6000 之前，并且由于事件 2 而执行回调。在此处发送响应。
3. timeout 完成，传递给 setTimeout 的挂起函数执行回调，该回调将再次发送响应，并且在响应发送后无法将标头发送到响应。

解决方案

一个基本的解决方案是检查传递给设置超时的函数中的标志变量是否发生2nd事件。

function myFunction(myVar_1, myVar_2, callback){

    let executed = false;
    listenOnSocket.someEvent(myVar_1,
        function(error, event) {
            if(!executed){
            executed = true
            if (error) callback(null, error);
            else setTimeout(function() {
                       callback(event, null);
                    }, 6000);
        }
       }
    );    

    listenOnSocket.someEvent(myVar_2,
        function(error, event) {
            if(!executed){
            executed = true;
            if (!error) callback(event, null); 
            else callback(null, error);
        }
       }
    );

};