How to efficiently realize batch sending SMS messages through asynchronous processing in web applications?

Asynchronous batch SMS sending strategy for web applications

This article discusses how to efficiently realize batch SMS sending in web applications, especially when processing complex operations such as database query, Redis writing and SMS sending in the background asynchronously without affecting the response speed of the user interface. The key is to adopt an asynchronous processing mechanism.

Implementation steps:

1. Front-end trigger: The user clicks the send button, triggers the Ajax request, and notifies the background to start the SMS sending process. The request only informs the background to start processing, and there is no need to wait for the SMS to be sent.

    $.ajax({
       url: '/send-sms',
       data: {template_id: 123, mobiles: ['13800138000', '13800138001'], content: 'Test SMS'},
       method: 'POST',
       success: function(result) {
           alert('SMS send request has been submitted');
       }
   });

2. Quick response in the background: After receiving the Ajax request in the background, it will immediately return a successful response, without blocking and waiting for the SMS to be sent to complete.

    public function sendSms() {
       $templateId = $_POST['template_id'];
       $mobiles = $_POST['mobiles'];
       $content = $_POST['content'];
       // Return Ajax response echo json_encode(['success' => true, 'msg' => 'SMS send request received']);
       // Asynchronously process SMS send $this->sendSmsAsync($templateId, $mobiles, $content);
   }

3. Redis cache and asynchronous tasks: The background starts asynchronous tasks and writes SMS sending data (template ID, mobile number list, SMS content) into the Redis cache. Redis's efficiency ensures high-speed reading and writing of data and supports distributed environments.

    private function sendSmsAsync($templateId, $mobiles, $content) {
       $redis = new Redis();
       $redis->connect('127.0.0.1', 6379);
       $redis->auth('redis_password');
       $data = ['template_id' => $templateId, 'mobiles' => $mobiles, 'content' => $content];
       $redis->lPush('sms_queue', json_encode($data));
       // Execute the asynchronous SMS sending task exec('nohup php -f ' . BASEPATH . 'index.php sms/send >/dev/null 2>&1 &');
   }

4. SMS sending task: Independent CLI scripts obtain SMS sending task from the Redis queue and call the SMS service provider API to send SMS messages. Error messages will be recorded in the log for easier subsequent troubleshooting.

    public function send() {
       $redis = new Redis();
       $redis->connect('127.0.0.1', 6379);
       $redis->auth('redis_password');
       $dataStr = $redis->rPop('sms_queue');
       if (!$dataStr) {
           exit;
       }
       $data = json_decode($dataStr, true);
       // Call the SMS service provider API to send a SMS message $result = $this->sendSmsApi($data['template_id'], $data['mobiles'], $data['content']);
       // Log if ($result !== true) {
           $msg = 'SMS send failed:' . $result;
           file_put_contents('/path/to/log.txt', $msg . PHP_EOL, FILE_APPEND);
       }
       // Continue to process the next text message exec('nohup php -f ' . BASEPATH . 'index.php sms/send >/dev/null 2>&1 &');
   }

This solution ensures the smoothness of the user experience and improves the efficiency and stability of SMS sending. In practical applications, more complete error handling and logging mechanisms can be added according to requirements.

The above is the detailed content of How to efficiently realize batch sending SMS messages through asynchronous processing in web applications?. For more information, please follow other related articles on the PHP Chinese website!