0

我制作了订阅redis频道的简单通知应用程序，当它有新消息时，这个应用程序将它发送给用户。

  client.on("auth", function(sessId, userId){
      console.log('AUTH: userId ' + userId)
      var userIdFromRedis;
      redis1.get('PHPREDIS_SESSION:' + sessId, function (err , reply) {

          if (reply){
              reply = reply.toString();
              var result = reply.match(/s:2:\"id\";i:(\d+);/);

              if (result) {
                  userIdFromRedis = result[1]
                  console.log('AUTH: userIdFromRedis ' + userIdFromRedis)
              } else {
                  result = reply.match(/s:7:\"guestId\";i:(\d+);/); 
                  if (result) {
                      var guestIdFromRedis = result[1]
                      console.log('AUTH: guestIdFromRedis ' + guestIdFromRedis)
                  }
              }

              if (userIdFromRedis == userId) {
                  client.userId = userId;
                  subscribe.subscribe(channelPrefix + userId);
                  clients[userId] = client;
                  client.emit("auth", {"success":true});
                  console.log('AUTH: result - ok')
              } else if (guestIdFromRedis) {
                  client.guestId = guestIdFromRedis;
                  subscribe.subscribe(channelPrefix + guestIdFromRedis);
                  clients[guestIdFromRedis] = client;
                  client.emit("auth", {"success":true});
                  console.log('AUTH: result - ok')
              } else {
                client.disconnect();
                console.log('AUTH: result - fail')
              }
            } else {
              client.disconnect();
            }
      });
  })

  subscribe.on("message", function(channel, message) {
      var userId = Math.round(channel.substr(channelPrefix.length));
      if (client.userId == userId || client.guestId == userId) {
          console.log('Subscriber: ' + message)
          client.send(message);
      }
  });

  client.on("message", function(text){
           client.send(text);
  })

有时在日志文件中，我可以找到错误消息

（节点）警告：检测到可能的 EventEmitter 内存泄漏。增加了 11 位听众。使用emitter.setMaxListeners() 增加限制。

而 node.js 应用程序的进程使用了​​ 90% 的 CPU。请建议我该如何解决这个问题？

4

1 回答 1

1

每当您的客户端连接到您的服务器时，您都会将另一个 EventEmitter 添加到堆栈中。不幸的是，您没有关闭它们，因此您达到了 11 的侦听器限制。您应该追踪添加 eventEmitters 的代码段，然后再声明，如果已经连接了客户端，则不应有任何其他产生的发射器。

于 2012-11-19T17:58:23.887 回答