Fugas de Memoria por Listeners

Cada on sin su off correspondiente mantiene vivos los cierres en servidores Node de larga ejecución. Usa AbortSignal, la eliminación explícita y presta atención a MaxListenersExceededWarning antes de que el crecimiento del heap se convierta en un incidente.

Receta

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 });
}
 
// limpieza: controller.abort();

Cuándo usarlo:

• Suscripciones con ámbito de solicitud en emisores globales
• Manejadores de message de WebSocket por conexión
• Observadores de archivos y hooks process.on en pruebas
• Servidores de desarrollo de recarga en caliente que adjuntan listeners duplicados

Ejemplo Funcional

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 el final de la respuesta
  setTimeout(() => controller.abort(), 100);
}
 
for (let i = 0; i < 5; i++) handleRequest(`req-${i}`);

// Detectar fugas en desarrollo
process.on('warning', (w) => {
  if (w.name === 'MaxListenersExceededWarning') {
    console.error('Posible fuga de listener:', w.message);
  }
});

Lo que esto demuestra:

• El manejador con ámbito de solicitud debe desvincularse cuando la solicitud se completa
• AbortSignal centraliza la limpieza para múltiples listeners
• MaxListenersExceededWarning en globalBus significa on duplicado sin off
• process.on('warning') muestra las infracciones del umbral de listeners

Análisis Detallado

Cómo Funciona

• EventEmitter almacena arrays de listeners por nombre de evento en un mapa interno de events.
• Los cierres capturan req, socket o grandes gráficos - el GC no puede recolectar hasta que se elimina el listener.
• Los patrones de WeakRef rara vez se aplican - la eliminación explícita es la norma.
• Internos de Node - server.on('connection') está bien; on por conexión en un singleton global no lo está.

Estrategias de Limpieza

Notas de TypeScript

import { on } from 'node:events';
 
// El iterador asíncrono se limpia automáticamente cuando el bucle se rompe con un return
async function drain(emitter: NodeJS.EventEmitter, event: string, signal: AbortSignal) {
  for await (const [payload] of on(emitter, event, { signal })) {
    console.log(payload);
  }
}

Errores Comunes

• Funciones flecha anónimas en on - no se pueden off más tarde. Solución: función con nombre o envoltorio de AbortSignal.
• Bus global por registro de manejador - N solicitudes → N listeners permanentes. Solución: emisor con ámbito por conexión o off al cerrar.
• Aumentar maxListeners para silenciar advertencias - trata el síntoma, no la causa. Solución: primero corrige la eliminación.
• Pruebas sin EventEmitter.removeAllListeners - pruebas subsiguientes inestables. Solución: limpieza afterEach.
• Listeners asíncronos que lanzan errores - rechazo no manejado separado de la fuga pero aún fatal. Solución: try/catch interno.

Alternativas

Preguntas Frecuentes

Relacionado

• Conceptos Básicos de EventEmitter - on/once/emit
• EventEmitter Tipado - envoltorios tipados
• Búsqueda de Fugas de Memoria - perfilado de heap
• Apagado Elegante - eliminar listeners en SIGTERM

Versiones de la pila: Esta página fue escrita para Node.js 24.18.0 (LTS Activo), npm 10+, TypeScript 5.6+, Express 5, Fastify 5 y NestJS 11.