本文介绍如何实现前台触发后台异步批量发送短信,且不影响用户体验。 用户点击按钮后,前台立即返回成功提示,后台则异步执行数据库查询、缓存写入和短信发送。
核心思路:异步处理
该方案利用异步处理机制,将耗时操作移至后台执行,避免阻塞前台。 具体步骤如下:
-
前台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); } });
登录后复制 -
后台接收请求并返回响应: 后台接收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); }
登录后复制 -
异步任务处理: 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])); }
登录后复制 -
队列工作者: 队列工作者从 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占用过高 }
登录后复制 -
短信发送函数 (sendSms): 该函数调用短信服务商API发送短信。
通过以上步骤,前台用户体验不受影响,后台则高效地处理批量短信发送。 选择合适的队列系统(Redis、RabbitMQ、Beansd等)至关重要,它能保证任务可靠地被处理,并支持分布式环境。 此外,完善的错误处理和日志记录机制也必不可少。
以上就是如何在前台触发后台异步批量发送短信而不影响用户体验?的详细内容,更多请关注php中文网其它相关文章!