Ошибка утечки памяти Node.js net tcp

Question

Я пишу сервер игры TCP в Node.js, и у меня возникают проблемы с разделением потока TCP на сообщения. Поскольку я хочу читать числа и поплавки из буфера, я не могу найти подходящий модуль для аутсорсинга, поскольку все те, которые я нашел, имеют дело с простыми строками, заканчивающимися новым разделителем строк. Я решил перейти с префиксом каждого сообщения длиной в байтах сообщения. Я сделал это и написал простую программу для спама сервера со случайными сообщениями (хорошо построенными с префиксом UInt16LE, изображающим длину сообщения). Я заметил, что чем дольше я оставляю программы, работающие на моем реальном сервере, тем больше использует память. Я попытался использовать инструмент отладки, чтобы трассировать выделение памяти без успеха, поэтому я решил, что разместил здесь свой код и надеюсь на ответ. Итак, вот мой код ... любые советы или указатели относительно того, где я иду не так, или что я могу сделать по-другому/более эффективно, было бы потрясающе! Спасибо.

server.on("connection", function(socket) { 
var session = new sessionCS(socket); 
console.log("Connection from " + session.address); 

// data buffering variables 
var currentBuffer = new Buffer(args.bufSize); 
var bufWrite = 0; 
var bufRead = 0; 
var mSize = null; 
var i = 0; 

socket.on("data", function(dataBuffer) { 

    // check if buffer risk of overflow 
    if (bufWrite + dataBuffer.length > args.bufSize-1) { 
     var newBufWrite = 0; 
     var newBuffer = new Buffer(args.bufSize); 

     while(bufRead < bufWrite) { 
      newBuffer[newBufWrite] = currentBuffer[bufRead]; 
      newBufWrite++; 
      bufRead++; 
     } 

     currentBuffer = newBuffer; 
     bufWrite = newBufWrite; 
     bufRead = 0; 
     newBufWrite = null; 
    } 

    // appending buffer 
    for (i=0; i<dataBuffer.length; i++) { 
     currentBuffer[bufWrite] = dataBuffer[i]; 
     bufWrite ++; 
    } 

    // if beginning of message not acknowleged 
    if (mSize === null && (bufWrite - bufRead) >= 2) { 
     mSize = currentBuffer.readUInt16LE(bufRead); 
    } 

    // if difference between read and write is greater or equal to message mSize + 2 
    // +2 for the integer holding the message size 
    // this means that a full message is in the buffer and needs to be extracted 
    while ((bufWrite - bufRead) >= mSize+2) { 
     bufRead += 2; 
     var messageBuffer = new Buffer(mSize); 

     for(i=0; i<messageBuffer.length; i++) { 
      messageBuffer[i] = currentBuffer[bufRead]; 
      bufRead++; 
     } 

     // this is where the message buffer would be passed to the router 
     router(session, messageBuffer); 
     messageBuffer = null; 

     // seeinf if another message length indicator is in the buffer 
     if ((bufWrite - bufRead) >= 2) { 
      mSize = currentBuffer.readUInt16LE(bufRead); 
     } 
     else { 
      mSize = null; 
     } 
    } 
}); 
} 

Answer 1

Буфер кадра Сериализация Protocol (BUFSP) https://github.com/teambition/bufsp Это может быть, что вы хотите: кодировать сообщения в буфер, писать TCP, получать и разделив TCP потока буфера в сообщения.