Mongodb 与 Monk：如果数据库关闭，错误捕获和处理

我是蒙戈的新手。我需要一个简单项目的数据库，最终遵循了使用 Mongo 和 Monk 的教程，但我在理解如何处理错误方面遇到了问题。

背景：我在客户端有一个注册表。当用户单击按钮时，数据通过 AJAX 发送到控制器（经过验证，但现在不相关），该控制器将此类数据插入数据库并发送回成功或错误。当数据库启动时，一切似乎都工作正常。

问题：如果我不启动数据库并尝试发送请求，则不会返回错误。根本什么也没发生。在控制台上运行一段时间后，我得到：POST /members/addmember - - ms - -.

我认为在这种情况下应该向用户返回一些错误，那么我该怎么做呢？

发布请求如下（几乎与教程中的一样）：

// app.js 

var db = monk('localhost:27017/dbname')
[...]
// I realize it might be not optimal here
app.use(function(req,res,next){ 
    req.db = db;
    next();
});

// members.js

router.post('/addmember', function(req, res) {
  var db = req.db;
  var collection = db.get('memberstest');
  collection.insert(req.body, function(err, result){
    res.json(
      (err === null) ? { msg: 'success' } : { msg: err }
    );
  });
});

如果数据库关闭了，我猜问题实际上甚至早于插入，那就是“db.get()“。那么如何检查是否get实际上可以做到吗？我认为考虑到节点的异步性质，像 try/catch 这样的东西在这里是毫无意义的。正确的？

编辑：在尼尔的回答和一些尝试之后，我整理了以下似乎可以完成这项工作的内容。然而，鉴于我对此缺乏信心，如果下面的代码有效，我将不胜感激，因为它有意义或偶然。我添加了 bufferMaxEntries: 0 选项并修改了控制器，如下所示。在 ajax 回调中，我现在只有一个警报，显示抛出的错误消息（如果有）。

router.post('/addmember', async (req,res) => {

    try {
      let db = req.db;
      let collection = db.get('memberstest');

      collection.insert(req.body, function(err, result){
      res.json(
        (err === null) ? { msg: 'success' } : { msg: err }
      );
    });

    await db.then(() => 1);

    } catch(e) {
      res.json({msg: e.message})
    }

});

那么你实际上可以设置bufferMaxEntries选项（记录在Db但不推荐使用该对象，而是在连接上使用“顶层，如演示的那样”），这实际上会在实际不存在连接时停止驱动程序上的“排队”请求。

作为一个最小的例子：

index.js

const express = require('express'),
      morgan = require('morgan'),
      db = require('monk')('localhost/test',{ bufferMaxEntries: 0 }),
      app = express();

const routes = require('./routes');

app.use(morgan('combined'));

app.use((req,res,next) => {
  req.db = db;
  next();
});

app.use('/', routes);

(async function() {

  try {

    await db.then(() => 1);

    let collection = db.get('test');
    await collection.remove({});

    await collection.insert(Array(5).fill(1).map((e,i) => ({ a: i+1 })));
    console.log('inserted test data');

    await app.listen(3000,'0.0.0.0');
    console.log('App waiting');

  } catch(e) {
    console.error(e);
  }

})();

路线.js

var router = require('express').Router();

router.get('/', async (req,res) => {
  try {
    let db = req.db,
        collection = db.get('test');

    let response = await collection.find();
    res.json(response);
  } catch(e) {
    res.status(500).json(e);
  }
});

module.exports = router;

因此，我实际上正在等待数据库连接至少在“启动”时出现，但实际上只是例如，因为我想插入一些数据来实际检索。这不是必需的，但基本概念是等待Promise解决：

await db.then(() => 1);

有点微不足道，并且对于您的实际代码来说并不是真正需要的。但我仍然认为这是一个很好的做法。

真正的测试是通过停止来完成的mongod或者以其他方式使服务器无法访问，然后发出请求。

由于我们将连接选项设置为{ bufferMaxEntries: 0 }这意味着立即地当您尝试向数据库发出命令时，如果不存在实际连接，则会返回失败。

当然，当数据库再次可用时，您不会收到错误，并且指令将正常发生。

如果没有该选项，默认情况下会将操作“入队”，直到解析连接，然后“缓冲区”实质上“播放”。

您可以通过“停止”来模拟这一点（就像我所做的那样）mongod守护进程并发出请求。然后“启动”守护进程并发出请求。它应该简单地返回捕获的错误响应。

NOTE：不是必需的，但实际上是整个目的async/await语法是让事情变得像try..catch再次有效，因为您实际上可以将范围视为块而不是使用Promise.catch() or err用于捕获错误的回调参数。然而，当这些结构中的任何一个实际使用时，同样的原则适用。