(节点)警告:检测到可能的事件发射器内存泄漏.添加了 11 个错误侦听器.使用 emitter.setMaxListen

Question

我正在使用pg节点模块来连接数据库。我一直在为每个 DML 操作创建多个连接。发生连续查询执行时我收到警告消息为"（节点）警告：检测到可能的事件发射器内存泄漏。添加了 11 个错误侦听器。使用 emitter.setMaxListeners（） 来增加限制。给定的 pg 默认值 poolSize 为 5。

 var pg = require('pg')
 pg.defaults.poolSize = 5;
 var dbHelper = {
 initializeConnection: function (callback) {
    pg.connect(conString, function (err, client, done) {
        if (err) {
            done(client);
            return callback(err, null);
        }
        callback(null, client, done);
    });
    pg.on('error', function (err) {
    });
    pg.end();
},
  query: function (pgQuery, args, callback, options) {
    this.initializeConnection(function (err, client, done) {
           client.query(pgQuery, args, function (err, response) {
            done();
            return callback(err, response);
        });
    });
},
};
 module.exports = dbHelper;

示例查询

 dbHelper.query("SELECT name,age,address FROM EMPLOYEE WHERE id=$1", [1001], function (err, response) {
        callback(err, response);
    });

如何防止事件发射器内存韭菜。

Answer 1

原因是您没有正确释放连接：

pg.connect(conString, function (err, client, done) {
      if (err) {
          done(client);
          return callback(err, null);
      }
      callback(null, client, done);
  });

这应该是：

pg.connect(conString, function (err, client, done) {
    if (err) {
        callback(err, null);
    } else {
        callback(null, client);
        done();
    }
});

即您在没有错误时调用done()。

如果你想完全避免这种错误 - 查看pg-promise;)