如何處理錯誤，而無需在node.js中設置res頭兩次

Question

我對節點的req, res參數有點困惑，並且在我使用異步調用時處理這些參數的最佳方式。我目前擁有的一個功能應該是將一個Item添加到我的數據庫中，相應地更新一些數據庫模型，然後發送一個響應，說明更新已成功。但是，如果發生錯誤，該函數異步調用的函數可能會發送錯誤的響應。如果發生這種情況，我會收到錯誤Can't set headers after they are sent，因爲我正在嘗試撥打res.send兩次。希望得到某人的幫助，找出更好的處理錯誤的方法。謝謝！

主要功能：

item.author = req.user._id; 
item.description = req.query.description; 
item.rating = req.query.rating; 

item.save() 
    .then(result => { 
     // update user's items 
     UserController.updateItems(req.user._id, result._id); 
     ItemController.updateItemRating(req.query.outingId, req.query.rating, res); 
     res.send(result); 
    }) 
    .catch(error => { 
     res.send(error); 
    }); 

updateItemRating：

export const updateItemRating = (itemId, rating, res) => { 
    Item.findOne({ _id: itemId }).exec((err, item) => { 
     if (item === undefined || item === null) { 
      return res.status(404).send('Item not found; check item ID'); 
     } 

     Item.findOneAndUpdate(
      { _id: itemId }, 
      { $set: { rating: rating }, 
      }, 
      (error, item) => { 
       if (error) { 
        res.status(404).send('Error updating item with new rating'); 
       } 
      }); 
    }); 
}; 

updateItems：

export const updateItems = (userId, itemId) => { 
    User.findOneAndUpdate(
     { _id: userId }, 
     { $push: { items: [itemId] } }, 
     (err, user) => { 
      console.log('user' + user); 
      if (err) { 
       console.log('got an error in updateItems'); 
      } 
     }); 
}; 

Answer 1

函數調用到updateItems和updateItemRating都是異步的。響應發送被稱爲多個時間，也不知道哪個方法發送首先被調用。要解決你的問題，我可以建議你申請以下技術：

1. 回調：您可以將回調作爲參數，它會做res.send和相同的回調，你可以在錯誤或成功的條件調用。

   UserController.updateItems(req.user._id, result._id,function(status,message){res.status(status).send(message);});

您可以更新項目的評價方法，如：

export const updateItemRating = (itemId, rating, callback) => { 
    Item.findOne({ _id: itemId }).exec((err, item) => { 
     if (item === undefined || item === null) { 
      callback(404,'Item not found; check item ID');  
     }  
     Item.findOneAndUpdate(
      { _id: itemId }, 
      { $set: { rating: rating }, 
      }, 
      (error, item) => { 
       if (error) { 
        callback(404,'Error updating item with new rating'); 
       }else{ 
        callback(200); 
       } 
      }); 
    }); 
}; 

Async Module：您可以使用此模塊同步你的方法調用。

Answer 2

而不是讓您的更新功能將結果發送，您應該拋出（）錯誤，那樣你的外部函數就會捕獲錯誤，你可以用它來返回它。

另一種考慮這種情況的方法是你的外部函數用res.send（）處理成功案例，所以它也應該對錯誤情況的res.send負責。

數據庫層知道調用者越少，重用我們的代碼就越容易。

創建自定義錯誤類型封裝404：

function NotFoundError(message) { 
    this.message = (message || ""); 
} 
NotFoundError.prototype = new Error(); 

然後用在你的內部函數：

export const updateItemRating = (itemId, rating, res) => { 
Item.findOne({ _id: itemId }).exec((err, item) => { 
    if (item === undefined || item === null) { 
     throw new NotFoundError('Item not found; check item ID'); 
    } 

    Item.findOneAndUpdate(
     { _id: itemId }, 
     { $set: { rating: rating }, 
     }, 
     (error, item) => { 
      if (error) { 
       throw new NotFoundError('Error updating item with new rating'); 
      } 
     }); 
    }); 
}; 

而主要成爲：

item.save() 
.then(result => { 
    // update user's items 
    UserController.updateItems(req.user._id, result._id); 
    ItemController.updateItemRating(req.query.outingId, req.query.rating, res); 
    res.send(result); 
}) 
.catch(error => { 
    if (error instanceof NotFoundError) { 
     res.status(404).send(error.message); 
    } 
    else { 
     res.send(error); 
    } 
});