Comment déclencher l'arrière-plan Asynchronous Batch Envoi de SMS au premier plan sans affecter l'expérience utilisateur?

Cet article présente comment permettre au frontal de déclencher l'arrière-plan pour envoyer des messages texte par lots sans affecter l'expérience utilisateur. Une fois que l'utilisateur a cliqué sur le bouton, la réception renvoie immédiatement l'invite de réussite et le bureau arrière effectue une requête de base de données, Redis Cache Write et SMS envoyant de manière asynchrone.

Idée de base: traitement asynchrone

Cette solution utilise un mécanisme de traitement asynchrone pour déplacer des opérations longues à l'arrière-plan pour effectuer, en évitant de bloquer le premier plan. Les étapes spécifiques sont les suivantes:

1. Demande AJAX frontale: l'utilisateur clique sur le bouton Envoyer et le frontal utilise Ajax pour envoyer une demande à l'arrière-plan. Les paramètres de demande incluent l'ID de modèle SMS, la liste des numéros de téléphone mobile et le contenu SMS.

    $ .ajax ({
       URL: «/ send-sms»,
       Type: «Post»,
       Données: {template_id: 123, mobiles: ['13800138000', '13800138001'], contenu: 'Tester SMS'},
       Succès: fonction (réponse) {
           alert («la demande d'envoi de SMS a été soumise»);
       },
       Erreur: fonction (erreur) {
           alert ('Demande a échoué:' error.ResponseText);
       }
   });

2. Le contexte reçoit la demande et renvoie la réponse: Une fois que le contexte a reçu la demande AJAX, il renvoie immédiatement une réponse réussie (format JSON) pour informer le frontal que la demande a été reçue. La clé est que la logique d'envoi SMS est mise dans une tâche asynchrone.

    // Méthode du contrôleur d'arrière-plan fonction publique SendsmsAction () {
       $ templateId = $ _post ['template_id'];
       $ mobiles = $ _post ['mobiles'];
       $ content = $ _post ['contenu'];
   
       // Renvoie la réponse réussie immédiatement écho json_encode (['succès' => true, 'message' => 'requête reçue, sms envoyant la tâche démarrée']);
   
       // ajouter des tâches aux files d'attente (par exemple en utilisant redis ou lapin)
       $ this-> addTaskTqueue ($ templateId, $ mobiles, $ contenu);
   }

3. Traitement des tâches asynchrones: la méthode addTaskToQueue ajoute une tâche d'envoi de SMS à la file d'attente de messages. Un processus d'arrière-plan indépendant (par exemple, à l'aide des travailleurs de la file d'attente) écoute en continu la file d'attente, récupére les tâches et les exécute.

    // ajouter des tâches à la file d'attente (exemple en utilisant redis)
   Fonction privée addtasktqueue ($ templateId, $ mobiles, $ contenu) {
       $ redis = new redis ();
       $ redis-> connect ('127.0.0.1', 6379);
       $ redis-> lpush ('sms_queue', json_encode (['template_id' => $ templateId, 'mobiles' => $ mobiles, 'contenu' => $ contenu]));
   }

4. Travailleur de file d'attente: le travailleur de la file d'attente obtient des tâches de la file d'attente sms_queue , effectue l'envoi de SMS et traite les journaux d'erreur.

    // travailleur de la file d'attente (exemple)
   while (true) {
       $ task = $ redis-> rpop ('sms_queue');
       if ($ task) {
           $ data = json_decode ($ task, true);
           $ result = $ this-> Sendsms ($ data ['template_id'], $ data ['mobiles'], $ data ['contenu']);
           if ($ result! == true) {
               // journal error_log ("SMS Send a échoué:". $ Result);
           }
       }
       sommeil (1); // Évitez l'utilisation excessive du processeur}

5. SMS Envoyer une fonction ( sendSms ) : Cette fonction appelle l'API du fournisseur de services SMS pour envoyer des messages SMS.

Grâce aux étapes ci-dessus, l'expérience utilisateur frontal ne sera pas affectée et le back-end traitera efficacement l'envoi des SMS par lots. Le choix du bon système de file d'attente (redis, lapin, beanstalkd, etc.) est crucial, ce qui garantit que les tâches sont traitées de manière fiable et prend en charge les environnements distribués. De plus, un mécanisme complet de gestion des erreurs et de journalisation est également essentiel.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!