Comment implémenter l'envoi de lots asynchrones des messages SMS sans affecter la vitesse de réponse?

Envoi de lots asynchrones efficaces des messages SMS: améliorer l'expérience utilisateur et l'efficacité de traitement des antécédents

Dans le développement des applications, l'envoi de SMS en lots est une exigence commune. Afin d'améliorer l'expérience utilisateur, évitez les utilisateurs en attendant longtemps et assurez-vous l'exécution fluide des tâches d'arrière-plan, le traitement asynchrone est la meilleure solution. Cet article expliquera en détail comment implémenter l'envoi de lots asynchrones des messages SMS et fournir des exemples de code.

Flux de traitement asynchrone

Cette solution adopte un mécanisme de traitement asynchrone pour s'assurer que la réception réagit rapidement, tandis que le back bureau gère indépendamment les tâches d'envoi SMS. Les étapes spécifiques sont les suivantes:

1. Demande AJAX frontale: l'utilisateur clique sur le bouton Envoyer, déclenche la demande Ajax et soumet une tâche d'envoi SMS à l'arrière-plan. Le contexte renvoie immédiatement une réponse réussie, informant la demande qu'elle a été reçue.
2. Réception et mise en cache des tâches de fond: Une fois que le contexte a reçu la demande, le message de réussite sera renvoyé immédiatement. Ensuite, le numéro de téléphone mobile et le contenu SMS sont obtenus de manière asynchrone à partir de la base de données et les données sont écrites dans le cache Redis. Redis est une base de données de cache efficace qui peut rapidement stocker et lire les données.
3. Exécution de la tâche asynchrone: l'arrière-plan démarre une tâche asynchrone indépendante, lit les données de la file d'attente Redis et appelle l'API SMS Envoyer pour envoyer des SMS. Toute exception sera enregistrée dans le journal pour un dépannage ultérieur plus facile.

Exemple de code (PHP Redis)

L'exemple de code suivant montre comment implémenter le processus ci-dessus à l'aide de PHP et Redis:

 // Requête Ajax Request (JavaScript)
$ .ajax ({
  URL: «/ send-sms»,
  Type: «Post»,
  Données: {template_id: 123, mobiles: ['13800138000', '13800138001'], contenu: 'Tester SMS'},
  Succès: fonction (résultat) {
    console.log («la demande d'envoi de SMS a été soumise»);
  }
});

// Traitement des antécédents (PHP)
Fonction publique Sendsms () {
  $ templateId = $ _post ['template_id'];
  $ mobiles = $ _post ['mobiles'];
  $ content = $ _post ['contenu'];

  // Renvoie la réponse réussie immédiatement écho json_encode (['success' => true, 'message' => 'request reçue']);

  // Traitement des tâches asynchrones $ this-> DispatchSmSesEndingTask ($ templateId, $ mobiles, $ contenu);
}

// Envoi SMS Envoyer une tâche (PHP)
Fonction Private DispatchSMSSendingTask ($ templateId, $ mobiles, $ contenu) {
  $ redis = new redis ();
  $ redis-> connect ('127.0.0.1', 6379);
  $ redis-> auth ('redis_password'); // Veuillez le remplacer par votre mot de passe redis $ data = ['template_id' => $ templateId, 'mobiles' => $ mobiles, 'contenu' => $ contenu];
  $ redis-> lpush ('sms_queue', json_encode ($ data)); // ajouter des tâches à redis file d'attente // Démarrer les tâches avec un mécanisme de planification de tâches asynchrone approprié, par exemple:
  // Utiliser des outils de ligne de commande: exec ('php'. __Dir__. '/Send_sms_worker.php> / dev / null 2> & 1 &');
  // Utilisez des files d'attente de messages: par exemple Rabbitmq, Kafka, etc.}

// SMS Envoyer un processus de travail (PHP - Send_SMS_WORKER.php)
 Php
while (true) {
  $ redis = new redis ();
  $ redis-> connect ('127.0.0.1', 6379);
  $ redis-> auth ('redis_password');

  $ datastr = $ redis-> rpop ('sms_queue');
  if ($ datastr) {
    $ data = json_decode ($ datastr, true);
    // Appelez l'API Envoyer SMS
    $ result = SendsmsViaAPI ($ data ['template_id'], $ data ['mobiles'], $ data ['contenu']);
    // log if ($ result! == true) {
      error_log ("SMS n'a pas réussi à envoyer:". $ Result);
    }
  }
  sommeil (1); // Évitez l'utilisation excessive du processeur}

// Simuler SMS Envoyer l'appel de l'API (PHP)
Fonction SendsmsViaAPI ($ templateId, $ mobiles, $ contenu) {
    // Ceci est remplacé par l'appel API Envoyer SMS réel // ...
    Retour Vrai; // Envoyez avec succès}

Cette solution utilise l'Ajax pour atteindre le découplage frontal et back-end, et Redis file d'attente assure un stockage fiable et un traitement ordonné des tâches, l'amélioration de l'efficacité du système et de l'expérience utilisateur. Veuillez sélectionner le mécanisme de planification des tâches asynchrones approprié en fonction de l'environnement réel, tel que l'utilisation de files d'attente de messages ou d'outils de gestion de processus. N'oubliez pas de remplacer le mot de passe Redis et l'API d'envoi SMS dans le code.

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!