Đáng tin cậy kết nối lại với MongoDB

Question

UPDATE: Tôi đang sử dụng phiên bản 2.1 trên người lái xe, chống lại 3,2

Tôi có một ứng dụng nút đó sử dụng MongoDB. Vấn đề tôi gặp phải là nếu máy chủ MongoDB bị hỏng vì bất kỳ lý do gì, ứng dụng sẽ không kết nối lại. Để có được quyền này, tôi dựa trên các thử nghiệm của tôi trên mã số trong this official tutorial.

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) 
}); 

Ý tưởng là chạy tập lệnh này, sau đó dừng lại mong muốn, sau đó khởi động lại. Vì vậy, ở đây chúng tôi đi:

TEST 1: dừng mongod trong 10 giây

Dừng MongoDB trong 10 giây thì kết quả mong muốn: nó sẽ ngừng chạy các truy vấn đối với những 10 giây, và sau đó sẽ chạy tất cả họ một khi máy chủ đã trở lại ip

NGHIỆM 2: dừng mongod trong 30 giây

Sau đúng 30 giây, tôi bắt đầu nhận được:

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

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

Sự cố là từ lúc này, khi tôi khởi động lại mongod, kết nối không được tái xác định.

Giải pháp?

Vấn đề này có giải pháp không? Nếu vậy, bạn có biết nó là gì không? Khi ứng dụng của tôi bắt đầu nôn mửa "topo đã bị phá hủy", cách duy nhất để có được tất cả mọi thứ để làm việc một lần nữa là bằng cách khởi động lại toàn bộ ứng dụng ...

Answer 1

Có 2 tùy chọn kết nối mà kiểm soát cách Mongo nodejs lái xe kết nối lại sau khi kết nối thất bại

• reconnectTries: cố gắng kết nối lại #times (mặc định là 30 lần)
• reconnectInterval: server sẽ đợi # mili giây giữa retries (mặc định 1000 ms)

reference on mongo driver docs

Điều đó có nghĩa là mongo sẽ tiếp tục cố gắng kết nối 30 lần theo mặc định và chờ 1 giây trước mỗi lần thử lại. Đó là lý do tại sao bạn bắt đầu thấy lỗi sau 30 giây.

Bạn nên tinh chỉnh 2 thông số này dựa trên nhu cầu của bạn như mẫu này.

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) 
    }); 

Điều này sẽ thử 60 lần thay vì 30 mặc định, có nghĩa là bạn sẽ bắt đầu thấy lỗi sau 60 giây khi ngừng tìm cách kết nối lại.

Sidenote: nếu bạn muốn ngăn ứng dụng/yêu cầu chờ cho đến khi hết thời hạn kết nối, bạn phải chuyển tùy chọn bufferMaxEntries: 0. Giá cho điều này là yêu cầu cũng bị hủy trong thời gian gián đoạn mạng ngắn.

Answer 2

Hành vi có thể khác với các phiên bản trình điều khiển khác nhau. Bạn nên đề cập đến phiên bản trình điều khiển của bạn.

lái xe phiên bản: 2.2.10 (mới nhất) Mongo db phiên bản: 3.0.7

Dưới mã sẽ kéo dài thời gian mongod có thể làm để trở lại lên.

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

function connectCallback(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) 
} 
var options = { server: { reconnectTries: 2000,reconnectInterval: 1000 }} 
MongoClient.connect('mongodb://localhost:27017/test',options,connectCallback); 

Đối số thứ hai có thể được sử dụng để chuyển tùy chọn máy chủ.

Answer 3

Theo mặc định trình điều khiển Mongo sẽ cố gắng kết nối lại 30 lần, mỗi giây một lần. Sau đó nó sẽ không cố gắng kết nối lại.

Bạn có thể thiết lập số lần thử lại để Number.MAX_VALUE để giữ cho nó kết nối lại "gần như mãi mãi":

var connection = "mongodb://127.0.0.1:27017/db"; 
    MongoClient.connect(connection, { 
     server : { 
     reconnectTries : Number.MAX_VALUE, 
     autoReconnect : true 
     } 
    }, function (err, db) { 

    }); 

Answer 4

Nó đang xảy ra bởi vì nó có thể đã vượt quá giới hạn kết nối thử lại. Sau khi số lần thử lại, nó phá hủy kết nối TCP và không hoạt động. Vì vậy, để tăng số lần thử lại và sẽ tốt hơn nếu bạn tăng khoảng cách giữa kết nối lại.

Sử dụng bên dưới tùy chọn:

retryMiliSeconds {Number, default:5000}, number of milliseconds between retries. 
numberOfRetries {Number, default:5}, number of retries off connection. 

Để biết thêm thông tin chi tiết tham khảo liên kết này https://mongodb.github.io/node-mongodb-native/driver-articles/mongoclient.html

Giải pháp:

MongoClient.connect("mongodb://localhost:27017/integration_test_?", { 
    db: { 
     native_parser: false, 
retryMiliSeconds: 100000, 
numberOfRetries: 100 
    }, 
    server: { 
     socketOptions: { 
     connectTimeoutMS: 500 
     } 
    } 
    }, callback)