How to implement asynchronous batch sending of SMS messages without affecting the response speed?

Efficient asynchronous batch sending of SMS messages: Improve user experience and background processing efficiency

In application development, sending SMS in batches is a common requirement. In order to improve the user experience, avoid users waiting for a long time, and ensure the smooth execution of background tasks, asynchronous processing is the best solution. This article will explain in detail how to implement asynchronous batch sending of SMS messages and provide code examples.

Asynchronous processing flow

This solution adopts an asynchronous processing mechanism to ensure that the front desk responds quickly, while the back desk independently handles SMS sending tasks. The specific steps are as follows:

1. Front-end AJAX request: The user clicks the send button, triggers the AJAX request, and submits a SMS sending task to the background. The background immediately returns a successful response, informing the request that it has been received.
2. Background task reception and caching: After the background receives the request, the success message will be returned immediately. Then, the mobile phone number and SMS content are obtained asynchronously from the database and the data is written to the Redis cache. Redis is an efficient cache database that can quickly store and read data.
3. Asynchronous task execution: The background starts an independent asynchronous task, reads data from the Redis queue, and calls the SMS send API to send SMS. Any exception will be recorded in the log for easier subsequent troubleshooting.

Code Sample (PHP Redis)

The following code example shows how to implement the above process using PHP and Redis:

 // Front Desk AJAX Request (JavaScript)
$.ajax({
  url: '/send-sms',
  type: 'POST',
  data: {template_id: 123, mobiles: ['13800138000', '13800138001'], content: 'Test SMS'},
  success: function(result) {
    console.log('SMS send request has been submitted');
  }
});

// Background Processing (PHP)
public function sendSms() {
  $templateId = $_POST['template_id'];
  $mobiles = $_POST['mobiles'];
  $content = $_POST['content'];

  // Return the successful response immediately echo json_encode(['success' => true, 'message' => 'request received']);

  // Asynchronous task processing $this->dispatchSmsSendingTask($templateId, $mobiles, $content);
}

// Send SMS Send Task (PHP)
private function dispatchSmsSendingTask($templateId, $mobiles, $content) {
  $redis = new Redis();
  $redis->connect('127.0.0.1', 6379);
  $redis->auth('redis_password'); // Please replace it with your Redis password $data = ['template_id' => $templateId, 'mobiles' => $mobiles, 'content' => $content];
  $redis->lPush('sms_queue', json_encode($data)); // Add tasks to Redis queue// Start tasks with appropriate asynchronous task scheduling mechanism, for example:
  // Use command line tools: exec('php ' . __DIR__ . '/send_sms_worker.php > /dev/null 2>&1 &');
  //Use message queues: for example RabbitMQ, Kafka, etc.}

// SMS send worker process (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);
    // Call the SMS send API
    $result = sendSmsViaAPI($data['template_id'], $data['mobiles'], $data['content']);
    // Log if ($result !== true) {
      error_log("SMS failed to send: " . $result);
    }
  }
  sleep(1); // Avoid excessive CPU usage}

// Simulate SMS Send API Call (PHP)
function sendSmsViaAPI($templateId, $mobiles, $content) {
    // This is replaced with the actual SMS send API call // ...
    return true; // Send successfully}

This solution uses AJAX to achieve front-end and back-end decoupling, and Redis queue ensures reliable storage and orderly processing of tasks, improving system efficiency and user experience. Please select the appropriate asynchronous task scheduling mechanism based on the actual environment, such as using message queues or process management tools. Remember to replace the Redis password and SMS sending API in the code.

The above is the detailed content of How to implement asynchronous batch sending of SMS messages without affecting the response speed?. For more information, please follow other related articles on the PHP Chinese website!