Colas de tareas en JavaScript (Node.js): guía completa para principiantes

Entrenador de Python en Línea para Principiantes

Aprende Python fácilmente sin sobrecargarte de teoría. Resuelve tareas prácticas con verificación automática, recibe pistas y escribe código directamente en el navegador, sin instalar nada.

Start Course

Introducción: ¿por qué se necesitan colas de tareas en JavaScript?

En el desarrollo web moderno, las aplicaciones a menudo se enfrentan a tareas que no pueden ejecutarse instantáneamente dentro de una sola solicitud HTTP. Enviar correos electrónicos, procesar imágenes, generar informes PDF o sincronizar con APIs externas: todo esto requiere tiempo y puede "colgar" el servidor si se ejecuta de forma síncrona.

Las colas de tareas (Task Queues) resuelven este problema. Permiten posponer la ejecución de operaciones que consumen muchos recursos y procesarlas de forma asíncrona en segundo plano. En este artículo, analizaremos cómo crear y gestionar colas de tareas en el entorno Node.js utilizando bibliotecas populares.

\n\n

1. Fundamentos del trabajo con colas en Node.js

Una cola de tareas es una estructura de datos que funciona bajo el principio FIFO (First In, First Out). Las tareas se añaden al final de la cola y se procesan desde el principio. En el contexto de Node.js, esto significa que su servidor puede responder rápidamente al usuario ("Tarea aceptada para procesamiento"), y la tarea en sí se ejecutará más tarde.

Para trabajar con colas en Node.js, se utilizan bibliotecas especializadas que dependen de almacenamientos externos (generalmente Redis). Consideremos las dos más populares:

Bull — una biblioteca moderna, rápida y estable basada en Redis.
Kue — una biblioteca más antigua, pero aún popular, con una interfaz web integrada.

Nos centraremos en Bull, ya que es el estándar de facto para nuevos proyectos.

\n\n

1.1 Instalación y configuración de Bull

Para empezar, instale las dependencias necesarias:

npm install bull ioredis

Ahora creemos una cola simple:

const Queue = require('bull');\nconst myQueue = new Queue('emailQueue', {\n  redis: {\n    host: '127.0.0.1',\n    port: 6379\n  }\n});\n\n// Añadimos una tarea a la cola\nmyQueue.add({\n  to: 'user@example.com',\n  subject: 'Correo de bienvenida',\n  body: '¡Bienvenido a nuestro sitio web!'\n});\n\nconsole.log('Tarea añadida a la cola');

En este ejemplo, creamos una cola llamada emailQueue y añadimos una tarea: enviar un correo. La tarea aún no se ha ejecutado, solo está esperando a su procesador.

\n\n

2. Procesamiento de tareas de la cola

Para que las tareas comiencen a ejecutarse, necesitamos un procesador (consumer). Este "escuchará" la cola y tomará las tareas para ejecutarlas.

Creemos un archivo worker.js:

const Queue = require('bull');\nconst emailQueue = new Queue('emailQueue', {\n  redis: { host: '127.0.0.1', port: 6379 }\n});\n\n// Función procesadora\nemailQueue.process(async (job) => {\n  const { to, subject, body } = job.data;\n  console.log(`Enviando correo a ${to}...`);\n  \n  // Simulación de envío de correo (en un proyecto real aquí iría nodemailer)\n  await new Promise(resolve => setTimeout(resolve, 2000));\n  \n  console.log(`Correo "${subject}" enviado a ${to}`);\n  return { status: 'sent', email: to };\n});\n\nconsole.log('Procesador iniciado y esperando tareas...');

Ejecute este script y luego añada una tarea del primer ejemplo. Verá cómo se procesa la tarea.

\n\n

2.1 Manejo de errores y reintentos

En proyectos reales, las tareas pueden fallar (por ejemplo, el servidor SMTP no está disponible). Bull proporciona un mecanismo de reintentos incorporado:

emailQueue.add(\n  { to: 'user@example.com', subject: 'Correo importante' },\n  { \n    attempts: 5,          // Número de intentos\n    backoff: { type: 'exponential', delay: 2000 } // Retardo exponencial\n  }\n);\n\n// En el procesador se puede manejar el fallo\nemailQueue.on('failed', (job, err) => {\n  console.error(`La tarea ${job.id} falló: ${err.message}`);\n});

\n\n