如何通过前台按钮触发和后台异步处理实现高效的批量发送短信？

异步批量短信发送：提升效率，优化用户体验

批量发送短信是许多应用的常见需求，例如用户注册、活动通知等。如何既保证效率，又不影响用户体验呢？本文介绍一种基于前台触发、后台异步处理的方案。用户点击发送按钮后，系统立即返回确认信息，后台则异步执行数据库查询、缓存写入以及短信发送等操作。

实现步骤详解

1. 前台AJAX请求: 用户点击发送按钮，前台使用AJAX向后台发送请求，避免页面刷新，提升用户体验。

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

2. 后台快速响应: 后台收到请求后，立即返回成功响应，无需等待耗时操作完成。

    public function sendSms() {
        $templateId = $_POST['template_id'];
        $mobiles = $_POST['mobiles'];
        $content = $_POST['content'];
        // 返回JSON响应
        echo json_encode(['success' => true, 'message' => '请求已提交']);
        // 异步处理短信发送
        $this->asyncSendSms($templateId, $mobiles, $content);
    }

3. 异步任务处理: 后台异步任务首先从数据库获取短信数据，写入Redis缓存。

   

   琅琅配音

   全能AI配音神器

   下载

    private function asyncSendSms($templateId, $mobiles, $content) {
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $redis->auth('redis_password');
        // 将数据存入Redis队列
        $data = ['template_id' => $templateId, 'mobiles' => $mobiles, 'content' => $content];
        $redis->lPush('sms_queue', json_encode($data));
        // 启动异步任务 (使用合适的异步任务处理机制，例如队列管理器)
        // ...
    }

4. 队列发送短信: 异步任务从Redis队列获取数据，调用短信服务商API发送短信。错误信息会被记录到日志中，方便后续排查。

    public function processSmsQueue() {
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $redis->auth('redis_password');
        // 从Redis队列获取数据
        $dataStr = $redis->rPop('sms_queue');
        if ($dataStr) {
            $data = json_decode($dataStr, true);
            // 调用短信服务商API
            $result = $this->sendSmsApi($data['template_id'], $data['mobiles'], $data['content']);
            // 记录日志
            if ($result !== true) {
                error_log("短信发送失败: " . $result);
            }
            // 继续处理队列中的下一条消息
            // ...
        }
    }

此方案通过前台AJAX和后台异步任务，有效地将短信发送与用户交互分离，提高了系统效率和用户体验。 请根据实际情况选择合适的异步任务处理机制，例如使用消息队列服务（如RabbitMQ、Kafka）或进程管理工具（如Supervisor）。