Node.js:这个长轮询实现是否泄漏:

我正在评估Node.js,以便在Java Web App上replace当前的推送function。 我写了一个简单的长轮询服务器,就像客户端和Java后端之间的中介一样工作。 客户端发出请求订阅,然后Java服务器可以通过调用Node.js来通知订阅的客户端。 目前为止似乎工作正常,但我得到了以下消息指出内存泄漏:

(node) warning: possible EventEmitter memory leak detected. 11 listeners added. Use emitter.setMaxListeners() to increase limit. Trace at EventEmitter.addListener (events.js:168:15) at EventEmitter.once (events.js:189:8) at route (C:\Users\Juan Pablo\pushserver.js:42:12) at Server.onRequest (C:\Users\Juan Pablo\pushserver.js:32:3) at Server.EventEmitter.emit (events.js:91:17) at HTTPParser.parser.onIncoming (http.js:1793:12) at HTTPParser.parserOnHeadersComplete [as onHeadersComplete] (http.js:111:23 ) at Socket.socket.ondata (http.js:1690:22) at TCP.onread (net.js:402:27) 

我有一行代码logging现有的侦听器,每当一个通知事件发射。 我已经运行了一段时间,它显示每个订阅客户端只有一个监听器(应该是这样),但是当我收到警告消息时,这行代码不在代码中。 代码是完全一样的,除了那条线艰难。

这是推送服务器的代码(因为我还在学习Node.js,所以这个代码很简单):

 var http = require('http'); var url = require("url"); var qs = require("querystring"); var events = require('events'); var util = require('util'); var emitter = new events.EventEmitter; function onRequest(request, response) { var pathname = url.parse(request.url).pathname; console.log("Request for " + pathname + " received."); request.setEncoding("utf8"); if (request.method == 'POST') { var postData = ""; request.addListener("data", function(postDataChunk) { postData += postDataChunk; console.log("Received POST data chunk '"+ postDataChunk + "'."); }); request.addListener("end", function() { route(pathname, response, postData); }); } else if (request.method=='GET') { var urlParts = url.parse(request.url, true); route(pathname, response, urlParts.query); } } function route(pathname, response, data) { switch (pathname) { case "/subscription": emitter.once("event:notify", function(ids) { response.writeHead(200, {"Content-Type": "text/html", "Access-Control-Allow-Origin": "*"}); response.write(JSON.stringify(ids)); response.end(); }); break; case "/notification": //show how many listeners exist console.log(util.inspect(emitter.listeners('event:notify')); emitter.emit("event:notify", data.ids); response.writeHead(200, {"Content-Type": "text/html", "Access-Control-Allow-Origin": "*"}); response.write(JSON.stringify(true)); response.end(); break; default: console.log("No request handler found for " + pathname); response.writeHead(404, {"Content-Type": "text/plain", "Access-Control-Allow-Origin": "*"}); response.write("404 - Not found"); response.end(); break; } } http.createServer(onRequest).listen(8888); console.log('Server running at http://127.0.0.1:8888/'); 

我的印象是,使用emitter.once会自动删除事件监听器,所以我不知道如果只有一个客户端连接,如何添加11个监听器。 我在想,也许如果客户端在等待通知时断开连接,那么关联的连接资源就不会被处置。

我想知道是否需要手动处理断开连接,以及是否有泄漏。 任何build议是受欢迎的。 谢谢。

  • 有效的方法redis设置成员更新
  • 节点:运行一个Java文件并返回响应
  • 是否有可能使用WebSockets或类似的本地Android应用程序?
  • 什么是存储大量sockets的最佳做法?
  • 从Java应用程序订阅/发布消息到/从SocketIO / nodejs服务器?
  • 使用Java和Vue创buildWeb应用程序的更好方法
  • Java到节点的JS转换
  • 如何在节点js应用程序中执行jar文件
  • 如果有人感兴趣,上面的代码确实泄漏。 在发送通知之前客户端断开连接时发生泄漏。 为了解决这个问题,有必要在客户端突然中断时删除事件监听器,比如:

     case "/subscription": var notify = function(ids) { response.writeHead(200, {"Content-Type": "text/html", "Access-Control-Allow-Origin": "*"}); response.write(JSON.stringify(ids)); response.end(); } emitter.once("event:notify", notify); //event will be removed when connection is closed request.on("close", function() { emitter.removeListener("event:notify", notify); }); break;