可靠地重新连接到MongoDB

Question

更新： 我在驱动程序上使用2.1版本，而不是3.2

我有一个使用MongoDB的节点应用程序。我的问题是，如果MongoDB服务器由于任何原因而关闭，则应用程序不会重新连接。为了实现这一点，我基于此官方教程中的代码进行了测试。

var MongoClient = require('mongodb').MongoClient
  , f = require('util').format;

MongoClient.connect('mongodb://localhost:27017/test',

// Optional: uncomment if necessary
// { db: { bufferMaxEntries: 3 } },


function(err, db) {
  var col = db.collection('t');

  setInterval(function() {
    col.insert({a:1}, function(err, r) {
      console.log("insert")
      console.log(err)

      col.findOne({}, function(err, doc) {
        console.log("findOne")
        console.log(err)
      });
    })
  }, 1000)
});

想法是运行此脚本，然后停止mongod，然后重新启动它。所以，我们开始：

将MongoDb停止10秒钟可以达到预期效果：它将停止运行查询10秒钟，然后在服务器返回ip后将运行所有查询。

测试2：停止mongod 30秒

恰好30秒后，我开始得到：

{ [MongoError: topology was destroyed] name: 'MongoError', message: 'topology was destroyed' }
insert

{ [MongoError: topology was destroyed] name: 'MongoError', message: 'topology was destroyed' }

麻烦在于，从此以后，当我重新启动mongod时，连接 没有重新建立 。

解决方案？

这个问题有解决办法吗？如果是这样，您知道那是什么吗？一旦我的应用开始呕吐“拓扑已被破坏”，使所有内容重新正常工作的唯一方法是重新启动整个应用…

Answer 1

有2个连接选项可控制连接失败后mongo nodejs驱动程序如何重新连接

• reconnectTries：尝试重新连接＃次（默认30次）
• reconnectInterval：服务器将在两次重试之间等待＃毫秒（默认为1000毫秒）

mongo驱动程序文档上的参考

这意味着mongo默认会继续尝试连接30次，并在每次重试前等待1秒。这就是为什么您在30秒后开始看到错误的原因。

您应该根据自己的需要调整这两个参数，例如本示例。

var MongoClient = require('mongodb').MongoClient,
    f = require('util').format;

MongoClient.connect('mongodb://localhost:27017/test', 
    {
        // retry to connect for 60 times
        reconnectTries: 60,
        // wait 1 second before retrying
        reconnectInterval: 1000
    },

    function(err, db) {
        var col = db.collection('t');

        setInterval(function() {
            col.insert({
                a: 1
            }, function(err, r) {
                console.log("insert")
                console.log(err)

                col.findOne({}, function(err, doc) {
                    console.log("findOne")
                    console.log(err)
                });
            })
        }, 1000)
    });

这将尝试60次，而不是默认的30次，这意味着当它停止尝试重新连接时，您将在60秒后开始看到错误。

旁注：如果要阻止应用程序/请求在重新连接期到期之前等待，则必须传递option bufferMaxEntries: 0。这样做的代价是在短暂的网络中断期间请求也会中止。