我要评论本文介绍如何实现前台触发后台异步批量发送短信，且不影响用户体验。 用户点击按钮后，前台立即返回成功提示，后台则异步执行数据库查询、redis缓存写入和短信发送。
核心思路：异步处理
该方案利用异步处理机制，将耗时操作移至后台执行，避免阻塞前台。 具体步骤如下：
-
前台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、beanstalkd等）至关重要，它能保证任务可靠地被处理，并支持分布式环境。 此外，完善的错误处理和日志记录机制也必不可少。
以上就是如何在前台触发后台异步批量发送短信而不影响用户体验？的详细内容，更多请关注代码网其它相关文章！
发表评论