Construire une file d'attente SMS résiliente avec Redis (Laravel Horizon, Bull, BullMQ) في المغرب - دليل وأفضل الممارسات

في المغرب، يتطلب إرسال الرسائل الموثوقة استخدام مسارات مباشرة مع مشغلي الاتصالات (اتصالات المغرب، إنوي، أورنج) والامتثال للأنظمة المحلية. Si la passerelle SMS marocaine (IAM, Orange, inwi) met 3 secondes à répondre à cause d'une surcharge réseau, l'utilisateur attendra 3 secondes face à un écran blanc. Pire, si l'API est temporairement hors ligne, votre script plantera, l'utilisateur verra une page d'erreur 500, et le SMS sera définitivement perdu.

Pour une production robuste, l'envoi de SMS doit toujours être asynchrone via une File d'Attente (Queue) gérée par Redis. Voici comment implémenter cette résilience dans l'écosystème PHP et Node.js.

في المغرب، يتطلب إرسال الرسائل الموثوقة استخدام مسارات مباشرة مع مشغلي الاتصالات (اتصالات المغرب، إنوي، أورنج) والامتثال للأنظمة المحلية. Imaginons que vous devez router une campagne vers 50 000 clients marocains. Une simple boucle foreach ou for va saturer la mémoire de votre serveur (Memory Exhaustion) et, surtout, va déclencher le mécanisme de Rate Limiting (Throttling) de l'API. Vous obtiendrez des dizaines de milliers d'erreurs 429 Too Many Requests.

L'architecture asynchrone règle ce problème : 1. Délégation (Le Producer) : Votre application Web place instantanément 50 000 tâches (Jobs) contenant le numéro et le message dans une base Redis (en mémoire, ultra-rapide). La page Web répond au client en moins de 50ms. 2. Exécution (Le Consumer / Worker) : Un processus en arrière-plan "dépile" les requêtes Redis à son propre rythme (ex: 30 SMS par seconde) pour respecter les limites de l'API SMS.

في المغرب، يتطلب إرسال الرسائل الموثوقة استخدام مسارات مباشرة مع مشغلي الاتصالات (اتصالات المغرب، إنوي، أورنج) والامتثال للأنظمة المحلية. Dans l'écosystème PHP/Laravel, Horizon (associé à Redis) est l'outil parfait. Il permet de configurer facilement des files d'attente spécifiques, du throttling et d'avoir un dashboard visuel.

1. Configuration du Throttling (App/Jobs/SendSmsJob.php) : Plutôt que d'inonder l'API, nous allons forcer le worker Laravel à ne pas dépasser 50 requêtes par seconde, avec une gestion automatique des retries.

```php 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. Isoler les flux critiques : Dans config/horizon.php, configurez deux processus de "workers" distincts. Un worker dédié à la file otp_critical (qui ne doit jamais être ralenti) et un autre dédié à la file marketing_bulk (qui peut tourner tranquillement en tâche de fond).

في المغرب، يتطلب إرسال الرسائل الموثوقة استخدام مسارات مباشرة مع مشغلي الاتصالات (اتصالات المغرب، إنوي، أورنج) والامتثال للأنظمة المحلية. Si votre backend est en Express ou NestJS, BullMQ (le successeur de Bull) est le standard industriel adossé à Redis pour gérer des millions de jobs.

Configuration du Rate Limiting natif dans BullMQ :

```javascript 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: 20, // Maximum 20 requêtes... duration: 1000 // ...par seconde. Respect parfait du Rate Limiting ! } }); ```

En utilisant ces outils, non seulement vous garantissez que la charge de l'API est parfaitement lissée, mais surtout, si votre serveur crashe au milieu de l'envoi de la campagne, les SMS non envoyés restent stockés dans Redis. Au redémarrage du serveur, les workers reprendront exactement là où ils s'étaient arrêtés. Zéro doublon, zéro perte.