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

wufei123 2025-04-06 阅读:40 评论:0

本文介绍如何实现前台触发后台异步批量发送短信，且不影响用户体验。用户点击按钮后，前台立即返回成功提示，后台则异步执行数据库查询、redis缓存写入和短信发送。核心思路：异步处理该方案利用异步处理机制，将耗时操作移至后台执行，避免阻...

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

核心思路：异步处理

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

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

PHP

$.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格式），告知前台请求已接收。关键在于，短信发送逻辑被放入异步任务中。

PHP

// 后台控制器方法
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 方法将短信发送任务添加到消息队列中。一个独立的后台进程（例如使用队列工作者）持续监听队列，取出任务并执行。

PHP

// 添加任务到队列 (示例使用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 队列中获取任务，执行短信发送，并处理错误日志。

PHP

// 队列工作者 (示例)
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占用过高
}