如何在前台触发后台异步批量发送短信而不影响用户体验？

本文介绍如何实现前台触发后台异步批量发送短信，且不影响用户体验。 用户点击按钮后，前台立即返回成功提示，后台则异步执行数据库查询、Redis缓存写入和短信发送。

核心思路：异步处理

该方案利用异步处理机制，将耗时操作移至后台执行，避免阻塞前台。 具体步骤如下：

1. 前台Ajax请求: 用户点击发送按钮，前端使用Ajax向后台发送请求，请求参数包含短信模板ID、手机号列表和短信内容。

   $.ajax({
       url: '/send-sms',
       type: 'POST',
       data: { template_id: 123, mobiles: ['13800138000', '13800138001'], content: '测试短信' },
       success: function(response) {
           alert('短信发送请求已提交');
       },
       error: function(error) {
           alert('请求失败:'   error.responseText);
       }
   });

2. 后台接收请求并返回响应: 后台接收Ajax请求后，立即返回成功响应（JSON格式），告知前台请求已接收。 关键在于，短信发送逻辑被放入异步任务中。

   // 后台控制器方法
   public function sendSmsAction() {
       $templateId = $_POST['template_id'];
       $mobiles = $_POST['mobiles'];
       $content = $_POST['content'];
   
       // 立即返回成功响应
       echo json_encode(['success' => true, 'message' => '请求已接收，短信发送任务已启动']);
   
       // 将任务添加到队列（例如使用Redis或RabbitMQ）
       $this->addTaskToQueue($templateId, $mobiles, $content);
   }

3. 异步任务处理: addTaskToQueue 方法将短信发送任务添加到消息队列中。 一个独立的后台进程（例如使用队列工作者）持续监听队列，取出任务并执行。

   // 添加任务到队列 (示例使用Redis)
   private function addTaskToQueue($templateId, $mobiles, $content) {
       $redis = new Redis();
       $redis->connect('127.0.0.1', 6379);
       $redis->lPush('sms_queue', json_encode(['template_id' => $templateId, 'mobiles' => $mobiles, 'content' => $content]));
   }

4. 队列工作者: 队列工作者从 sms_queue 队列中获取任务，执行短信发送，并处理错误日志。

   // 队列工作者 (示例)
   while (true) {
       $task = $redis->rPop('sms_queue');
       if ($task) {
           $data = json_decode($task, true);
           $result = $this->sendSms($data['template_id'], $data['mobiles'], $data['content']);
           if ($result !== true) {
               // 记录错误日志
               error_log("短信发送失败: " . $result);
           }
       }
       sleep(1); // 避免CPU占用过高
   }

5. 短信发送函数 (sendSms): 该函数调用短信服务商API发送短信。

通过以上步骤，前台用户体验不受影响，后台则高效地处理批量短信发送。 选择合适的队列系统（Redis、RabbitMQ、Beanstalkd等）至关重要，它能保证任务可靠地被处理，并支持分布式环境。 此外，完善的错误处理和日志记录机制也必不可少。

以上是如何在前台触发后台异步批量发送短信而不影响用户体验？的详细内容。更多信息请关注PHP中文网其他相关文章！