Vazamentos de Memória de Listeners

Cada on sem um off correspondente mantém closures vivas em servidores Node de longa execução - use AbortSignal, remoção explícita e preste atenção ao MaxListenersExceededWarning antes que o crescimento da memória se torne um incidente.

Receita

import { EventEmitter } from 'node:events';
 
const controller = new AbortController();
const { signal } = controller;
 
function onAbortable(emitter: EventEmitter, event: string, fn: () => void) {
  emitter.on(event, fn);
  signal.addEventListener('abort', () => emitter.off(event, fn), { once: true });
}
 
// limpeza: controller.abort();

Quando usar isso:

• Assinaturas de escopo de solicitação em emissores globais
• Manipuladores message de WebSocket por conexão
• Observadores de arquivos e ganchos process.on em testes
• Servidores de desenvolvimento de recarregamento a quente anexando listeners duplicados

Exemplo de Trabalho

import { EventEmitter } from 'node:events';
 
const globalBus = new EventEmitter();
 
function handleRequest(requestId: string): void {
  const controller = new AbortController();
 
  const onJob = (id: string) => {
    if (id === requestId) console.log('job done', id);
  };
 
  globalBus.on('job:done', onJob);
  controller.signal.addEventListener('abort', () => {
    globalBus.off('job:done', onJob);
  });
 
  // simula o fim da resposta
  setTimeout(() => controller.abort(), 100);
}
 
for (let i = 0; i < 5; i++) handleRequest(`req-${i}`);

// Detectar vazamentos em desenvolvimento
process.on('warning', (w) => {
  if (w.name === 'MaxListenersExceededWarning') {
    console.error('Listener leak suspected:', w.message);
  }
});

O que isso demonstra:

• O manipulador de escopo de solicitação deve se desanexar quando a solicitação for concluída
• AbortSignal centraliza a limpeza para vários listeners
• MaxListenersExceededWarning em globalBus significa on duplicado sem off
• process.on('warning') expõe violações de limite de listener

Mergulho Profundo

Como Funciona

• EventEmitter armazena arrays de listeners por nome de evento em um mapa interno events.
• Closures capturam req, socket ou grandes grafos - o GC não pode coletar até que o listener seja removido.
• Padrões WeakRef raramente se aplicam - a remoção explícita é a norma.
• Internos do Node - server.on('connection') é bom; on por conexão em um singleton global não é.

Estratégias de Limpeza

Notas de TypeScript

import { on } from 'node:events';
 
// O iterador assíncrono limpa automaticamente quando o loop é interrompido com return
async function drain(emitter: NodeJS.EventEmitter, event: string, signal: AbortSignal) {
  for await (const [payload] of on(emitter, event, { signal })) {
    console.log(payload);
  }
}

Armadilhas

• Funções de seta anônimas em on - não é possível usar off depois. Correção: função nomeada ou wrapper AbortSignal.
• Ônibus global por registro de manipulador - N solicitações → N listeners permanentes. Correção: emissor com escopo por conexão ou off ao fechar.
• Aumentar maxListeners para silenciar avisos - trata o sintoma, não a causa. Correção: corrigir a remoção primeiro.
• Testes sem EventEmitter.removeAllListeners - testes subsequentes instáveis. Correção: limpeza em afterEach.
• Listeners assíncronos lançando exceções - rejeição não tratada separada do vazamento, mas ainda assim fatal. Correção: try/catch interno.

Alternativas

FAQs

Relacionados

• Conceitos Básicos do EventEmitter - on/once/emit
• Typed EventEmitter - wrappers tipados
• Caça a Vazamentos de Memória - profiling de heap
• Desligamento Gracioso - remover listeners em SIGTERM

Versões da Pilha: Esta página foi escrita para Node.js 24.18.0 (Active LTS), npm 10+, TypeScript 5.6+, Express 5, Fastify 5 e NestJS 11.