如何处理 MongoClient 中的超时错误？

Question

我正在使用以下命令将 nodejs 应用程序连接到我的 mongodb 数据库：

const url = 'mongodb://localhost:27017/?replicaSet=rs'
let client = new MongoClient(url, { 
  useNewUrlParser: true,
  connectTimeoutMS: 60000,    
  socketTimeoutMS: 60000, 
 })
try {
  let dbclient = await client.connect()
  console.log(dbclient)
  const db = dbclient.db('test')
  const collection = db.collection('accounts')
  const changeStream = collection.watch(pipeline)
  changeStream.on("change", function(change) {
    console.log('changed', change)
  })
} catch (err) {
  console.log('mongo err:', err)
}

这工作得很好，但是它经常在几分钟后失去连接并出现错误：

未捕获的 MongoNetworkError：连接 6 到 localhost:27017 超时

根据the documentation，它应该会在出错时自动重新连接多达 30 次尝试，但它似乎不会再尝试重新连接。

我还需要在重新连接时运行一些额外的逻辑以正确处理本地状态。

如何捕捉和处理这些错误？

编辑：虽然我仍然没有收到其他事件，但在错误发生后我收到了“重新连接”事件。所以看起来我至少可以对错误做出反应，但实际上仍然无法捕捉到它们。

Answer 1

我建议您添加reconnectTries，它充当服务器尝试重新连接#times，并添加其他可以稳定连接的选项，然后您将代码修改回：

const url = 'mongodb://localhost:27017/?replicaSet=rs'
let client = new MongoClient(url, { 
  useNewUrlParser: true,
  connectTimeoutMS: 30000,    
  socketTimeoutMS:  360000, 
  useMongoClient: true,
  keepAlive: true,
  reconnectTries: 30
 })
try {
  let dbclient = await client.connect()
  console.log(dbclient)
  const db = dbclient.db('test')
  const collection = db.collection('accounts')
  const changeStream = collection.watch(pipeline)
  changeStream.on("change", function(change) {
    console.log('changed', change)
  })
} catch (err) {
  console.log('mongo err:', err)
}

Answer 2

试试这个

var MongoClient = require('mongodb').MongoClient;
 var mongo = {};
 mongo.init = function() {
 MongoClient.connect('mongodb://localhost:27017/db',function(err, db) {
    if (err) {
      console.log('Err',err);
    } else {
      mongo.DB = db;
    }
    db.on('reconnect', function() {
      mongo.DB = db;
    });
  }
}

Answer 3

只需添加连接keepAlive: true，或特定时间keepAlive: 300000

在此处查看示例：https://ide.c9.io/ibrahimth/mongo

const MongoClient = require('mongodb').MongoClient;
const assert = require('assert');

// Connection URL
const url = 'mongodb://localhost:27017/?replicaSet=rs'
// Database Name
const dbName = 'test';

// create a client, passing in additional options
const client = new MongoClient(url, {
   keepAlive: true,
  connectTimeoutMS: 60000,    
  socketTimeoutMS: 60000, 
});

// Use connect method to connect to the server
client.connect(function(err) {
  assert.equal(null, err);
  console.log("Connected correctly to server");
const db = client.db(dbName);
createCollated(db, function() {
    client.close();
  });


});


function createCollated(db, callback) {
  db.createCollection('acount',
    {
      'collation' :
        { 'acountnam': 'firstacount' }
    },

    function(err, results) {
      console.log("Collection created.");
      callback();
    }
  );
};

欲了解更多信息：http://mongodb.github.io/node-mongodb-native/3.0/tutorials/collations/