文章/答案/技术大牛

发布

社区首页 >问答首页 >(节点)警告:检测到可能的EventEmitter内存泄漏。11名听众补充说。使用emitter.setMaxListeners()来增加限制。跟踪

问(节点)警告:检测到可能的EventEmitter内存泄漏。11名听众补充说。使用emitter.setMaxListeners()来增加限制。跟踪
EN

Stack Overflow用户

提问于 2013-12-16 07:45:25

回答 2查看 3.6K关注 0票数 1

我正在尝试从收件箱中获取所有消息，并将其解析，然后将其发送到另一台服务器。

这是我的密码：

client.listMessages(0, function(err, messages) 
{
    var parser = new MailParser(self.mailParserOptions);
    messages.forEach(function(message)
    {
       parser.on("end", function(mail) 
      {
        console.log(mail);
      });
      self.client.createMessageStream(message.UID).pipe(parser);
    });
});

这是完美的解析，但我得到了这个错误。

(node) warning: possible EventEmitter memory leak detected. 11 listeners added.
 Use emitter.setMaxListeners() to increase limit.
 Trace
at MailParser.EventEmitter.addListener (events.js:160:15)
at Stream.pipe (stream.js:99:8)
at /home/above/Desktop/prabu/inbox.js:75:54
at Array.forEach (native)
at /home/above/Desktop/prabu/inbox.js:70:14
at IMAPClient.<anonymous> (/home/above/Desktop/node_modules/inbox/lib/client.js:1653:13)
at IMAPClient._currentRequest.callback (/home/above/Desktop/node_modules/inbox/lib/client.js:777:25)
at IMAPClient._responseRouter (/home/above/Desktop/node_modules/inbox/lib/client.js:618:30)
at IMAPClient._onServerResponse (/home/above/Desktop/node_modules/inbox/lib/client.js:551:10)
at IMAPLineParser.EventEmitter.emit (events.js:95:17)

我不知道为什么会这样。

parsing

node.js

回答 2

Stack Overflow用户

回答已采纳

发布于 2013-12-16 10:30:20

您的代码存在多个问题：

假设我正确地理解了andris9/mailparser的文档，MailParser对象应该解析一封电子邮件，并且只解析一封电子邮件。然而，您创建一个解析器并向它提供许多信息，这不会产生预期的结果；
在相同的end事件中，您会听很多次，所以Node.js警告您，您正在做的事情可能不是您想要做的。例如，看看这个问题，在那里，海报面临着同样的问题。

相反，我建议以下解决方案：

client.listMessages(0, function(err, messages)  {
    messages.forEach(function(message) {
        var parser = new MailParser(self.mailParserOptions);
        parser.once("end", function(mail) {
            console.log(mail);
        });
        self.client.createMessageStream(message.UID).pipe(parser);
    });
});

注意：

为每个消息创建parser对象
因为我们知道end事件只发出一次，所以我们使用方法而不是on()

票数 2

Stack Overflow用户

发布于 2013-12-16 07:53:44

编辑:正如Paul所指出的，您甚至不允许每次在单个MailParser上启动多个解析，因此您需要为每个解析创建一个新的解析。当您这样做时，限制不再适用，您可以使用现有的循环。我将保留下面的文本，因为它解释了信息，并且仍然适用于其他类似的情况。

该消息的意思是，您将在单个EventEmitter (MailParser)上同时对10多条消息进行解析。您的循环每次迭代都会启动一个解析，并且从不等待任何先前的解析完成。

如果这是您想要做的事情(在本例中并不是因为每个MailParser只能运行一个解析)，则需要提高EventEmitter限制(按照错误消息告诉您的那样做)。因为据我所见，您的循环可以在理论上无限数量的消息上循环，并且您试图并行地解析所有消息，所以这可能不是最好的方法。

如果这不是你想要做的，你有几个选择。或者您需要为每个解析创建一个新的MailParser (限制仅适用于每个EventEmitter)，或者您可能希望查看async库并使用例如eachSeries或eachLimit将同时启动的解析的数量限制在较低的数目。

票数 1

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/20605733

复制

相似问题

问(节点)警告:检测到可能的EventEmitter内存泄漏。11名听众补充说。使用emitter.setMaxListeners()来增加限制。跟踪
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问(节点)警告:检测到可能的EventEmitter内存泄漏。11名听众补充说。使用emitter.setMaxListeners()来增加限制。跟踪EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问(节点)警告:检测到可能的EventEmitter内存泄漏。11名听众补充说。使用emitter.setMaxListeners()来增加限制。跟踪
EN