Construir una cola de SMS resiliente con Redis (Laravel Horizon, Bull, BullMQ)

Si el pasillo SMS marroquí (IAM, naranja, inwi) tarda 3 segundos en responder debido a una sobrecarga de red, el usuario esperará 3 segundos frente a una pantalla blanca. Peor aún, si la API está temporalmente fuera de línea, su script se desplomará, el usuario verá una página de error 500, y el SMS se perderá definitivamente.

Para una producción robusta, el envío de SMS debe siempre ser asincrónico a través de un Archivo de espera (Queue) gestionado por Redis.

Imaginemos que tengas que dirigir una campaña a 50.000 clientes marroquíes. Un simple loop foreach o for saturará la memoria de tu servidor (Memory Exhaustion) y, sobre todo, desencadenará el mecanismo de Rate Limiting (Throttling) de la API. Obtendrás decenas de miles de errores 429 Too Many Requests.

La arquitectura asíncrona resuelve este problema: 1. Delegación (El Productor): Su aplicación web coloca instantáneamente 50.000 tareas (Jobs) que contienen el número y el mensaje en una base de datos Redis (en memoria, ultra-rápida).La página web responde al cliente en menos de 50ms.2. Ejecución (El Consumidor / Trabajador): Un proceso en el fondo "despila" las consultas Redis a su propio ritmo (ej.: 50 solicitudes por minuto) para mantenerse por debajo del límite de su clave API.

En el ecosistema PHP/Laravel, Horizon (associado con Redis) es la herramienta perfecta. Permite configurar fácilmente filas de espera específicas, throttling y tener un dashboard visual.

1. Configuración del Throttling (App/Jobs/SendSmsJob.php): En lugar de inundar la API, vamos a forzar al trabajador de Laravel a no superar las 50 consultas por minuto, con una gestión automática de retiros.

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\Middleware\RateLimited;

class SendSmsJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $contact;
    public $message;

    // Définir la limite de débit : "sms-api" (défini dans AppServiceProvider)
    public function middleware()
    {
        return [new RateLimited('sms-api')];
    }

    public function handle()
    {
        // Appel API réel vers EnvoiSMS.ma
        $response = EnvoiSms::send($this->contact->phone, $this->message);
        
        if ($response->failed()) {
            throw new \Exception("Erreur API, Horizon relancera le job selon l'exponential backoff.");
        }
    }
}

2. Aislamiento de flujos críticos: En config/horizon.php, configure dos procesos de "workers" distintos. Un worker dedicado a la fila otp_critical (que nunca debe ralentizarse) y otro dedicado a la fila marketing_bulk (que puede girar tranquilamente en tarea de fondo).

Si su backend es Express o NestJS, BullMQ (el sucesor de Bull) es el estándar de la industria de Redis para gestionar millones de puestos de trabajo.

Configuración del límite de tasa nativo en BullMQ:

import { Queue, Worker } from 'bullmq';

// Création de la file d'attente liée à Redis
const smsQueue = new Queue('sms_dispatch', {
  connection: { host: 'localhost', port: 6379 }
});

// Ajout d'un SMS dans la file (Hyper rapide, le client n'attend pas)
await smsQueue.add('send_otp', { phone: '+212600000000', message: 'Code: 1234' });

// Le Worker qui traite l'envoi en respectant les limites de l'opérateur
const smsWorker = new Worker('sms_dispatch', async job => {
  const { phone, message } = job.data;
  
  try {
    await sendSmsViaApi(phone, message); // Votre appel HTTP axios ou fetch
  } catch (error) {
    // Si l'erreur est temporaire (ex: 503), BullMQ relancera le job
    throw new Error('Erreur API, réessayer plus tard.');
  }
}, {
  connection: { host: 'localhost', port: 6379 },
  limiter: {
    max: 50, // Maximum 50 requêtes...
    duration: 60000 // ...par minute, sous la limite de votre clé API (60 à 1 200 req/min selon l'offre).
  }
});

Al usar estas herramientas, no solo se garantiza que la carga de la API sea perfectamente suave, sino que, sobre todo, si su servidor se rompe en medio del envío de la campaña, los SMS no enviados permanecen almacenados en Redis. Al reiniciar el servidor, los trabajadores volverán exactamente donde se detuvieron. Cero doble, cero pérdida.