Nodejs BAE上mongoose长连接问题（新！），求可怜，进来看一眼呗

Nodejs BAE上mongoose长连接问题（新！），求可怜，进来看一眼呗

问题描述

之前解决过 Mongoose 在百度应用引擎（BAE）上的长连接问题，但最近再次遇到这个问题。每次连接关闭后尝试重新连接时，仍然会报 no open connections 的错误。

当前的连接代码

var mongoose = require('mongoose');
var settings = require('./settings.js');

// 创建 Mongoose 连接
var db = mongoose.createConnection();

// 打开 MongoDB 连接
db.open(settings.host, settings.db, settings.port, settings.options, function() {
    console.log('MongoDB connected!');
    console.log('Host: ' + settings.host + ', DB: ' + settings.db + ', Port: ' + settings.port);
});

// 错误处理
db.on('error', function (err) {
    console.error('Connection error:', err);
    console.log("db on error!");
    db.close();
});

// 关闭处理
db.on('close', function() {
    console.log("db on close!");
    db.open(settings.host, settings.db, settings.port, settings.options, function() {
        console.log("db reopened!");
    });
});

module.exports = {
    db: db,
    mongoose: mongoose
};

问题分析

在 BAE 后台查看日志时，发现连接关闭后的重连代码被触发，但是仍然报 no open connections 的错误。这可能是因为之前的连接对象已经失效，需要重新创建一个新的连接对象。

解决方案

根据上述分析，我们需要在连接关闭时重新创建一个新的连接对象，而不是简单地调用 db.open() 方法。

修改后的代码

var mongoose = require('mongoose');
var settings = require('./settings.js');

function createMongooseConnection() {
    var db = mongoose.createConnection();
    
    db.on('error', function (err) {
        console.error('Connection error:', err);
        console.log("db on error!");
        db.close();
    });

    db.on('close', function() {
        console.log("db on close!");
        createMongooseConnection();
    });

    return db;
}

var db = createMongooseConnection();

db.once('open', function() {
    console.log('MongoDB connected!');
    console.log('Host: ' + settings.host + ', DB: ' + settings.db + ', Port: ' + settings.port);
});

module.exports = {
    db: db,
    mongoose: mongoose
};

解释

• createMongooseConnection 函数：该函数负责创建并返回一个新的 Mongoose 连接。
• 事件监听器：在 error 和 close 事件中，我们不再直接调用 db.open()，而是调用 createMongooseConnection() 来重新创建一个新的连接。
• db.once('open')：确保只有在连接成功后才打印连接成功的消息。

通过这种方式，可以确保每次连接失败或关闭时都能正确地重新创建一个新的连接，从而避免 no open connections 的错误。