如何在Web应用中通过异步处理高效实现批量发送短信?(高效.发送短信.批量.如何在.Web...)

wufei123 发布于 2025-03-24 阅读(5)

如何在web应用中通过异步处理高效实现批量发送短信?

Web应用异步批量短信发送策略

本文探讨如何在Web应用中高效实现批量短信发送,尤其是在不影响用户界面响应速度的前提下,异步处理后台的数据库查询、Redis写入和短信发送等复杂操作。 关键在于采用异步处理机制。

实现步骤:

  1. 前端触发: 用户点击发送按钮,触发Ajax请求,通知后台开始短信发送流程。 请求仅告知后台开始处理,无需等待短信发送完成。

    $.ajax({
        url: '/send-sms',
        data: {template_id: 123, mobiles: ['13800138000', '13800138001'], content: '测试短信'},
        method: 'POST',
        success: function(result) {
            alert('短信发送请求已提交');
        }
    });
  2. 后台快速响应: 后台接收Ajax请求后,立即返回成功响应,不阻塞等待短信发送完成。

    public function sendSms() {
        $templateId = $_POST['template_id'];
        $mobiles = $_POST['mobiles'];
        $content = $_POST['content'];
        // 返回Ajax响应
        echo json_encode(['success' => true, 'msg' => '短信发送请求已接收']);
        // 异步处理短信发送
        $this->sendSmsAsync($templateId, $mobiles, $content);
    }
  3. Redis缓存与异步任务: 后台启动异步任务,将短信发送数据(模板ID、手机号列表、短信内容)写入Redis缓存。Redis的高效性保证了数据的高速读写,并支持分布式环境。

    private function sendSmsAsync($templateId, $mobiles, $content) {
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $redis->auth('redis_password');
        $data = ['template_id' => $templateId, 'mobiles' => $mobiles, 'content' => $content];
        $redis->lPush('sms_queue', json_encode($data));
        // 执行异步短信发送任务
        exec('nohup php -f ' . BASEPATH . 'index.php sms/send >/dev/null 2>&1 &');
    }
  4. 短信发送任务: 独立的CLI脚本从Redis队列中获取短信发送任务,调用短信服务商API发送短信。 错误信息会被记录到日志中,方便后续排查。

    public function send() {
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $redis->auth('redis_password');
        $dataStr = $redis->rPop('sms_queue');
        if (!$dataStr) {
            exit;
        }
        $data = json_decode($dataStr, true);
        // 调用短信服务商API发送短信
        $result = $this->sendSmsApi($data['template_id'], $data['mobiles'], $data['content']);
        // 记录日志
        if ($result !== true) {
            $msg = '短信发送失败:' . $result;
            file_put_contents('/path/to/log.txt', $msg . PHP_EOL, FILE_APPEND);
        }
        // 继续处理下一条短信
        exec('nohup php -f ' . BASEPATH . 'index.php sms/send >/dev/null 2>&1 &');
    }

此方案确保了用户体验的流畅性,并提升了短信发送的效率和稳定性。 实际应用中,可根据需求添加更完善的错误处理和日志记录机制。

以上就是如何在Web应用中通过异步处理高效实现批量发送短信?的详细内容,更多请关注知识资源分享宝库其它相关文章!

标签:  高效 发送短信 批量 

发表评论:

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。