如何在不影响响应速度的情况下实现异步批量发送短信?

DDD
发布: 2025-03-25 08:40:01
原创
877人浏览过

如何在不影响响应速度的情况下实现异步批量发送短信?

高效异步批量发送短信:提升用户体验与后台处理效率

在应用开发中,批量发送短信是常见需求。为了提升用户体验,避免用户长时间等待,同时确保后台任务顺利执行,异步处理是最佳方案。本文将详细阐述如何实现异步批量发送短信,并提供代码示例。

异步处理流程

该方案采用异步处理机制,确保前台快速响应,后台则独立处理短信发送任务。具体步骤如下:

  1. 前台AJAX请求: 用户点击发送按钮,触发AJAX请求,向后台提交短信发送任务。后台立即返回成功响应,告知请求已接收。
  2. 后台任务接收与缓存: 后台接收请求后,立即返回成功信息。然后,异步地从数据库获取手机号码和短信内容,并将这些数据写入Redis缓存。Redis作为高效的缓存数据库,能够快速存储和读取数据。
  3. 异步任务执行: 后台启动一个独立的异步任务,从Redis队列中读取数据,并调用短信发送API发送短信。任何异常都会被记录到日志中,方便后续排查。

代码示例 (PHP + Redis)

以下代码示例展示了如何使用PHP和Redis实现上述流程:

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

// 后台处理 (PHP)
public function sendSms() {
  $templateId = $_POST['template_id'];
  $mobiles = $_POST['mobiles'];
  $content = $_POST['content'];

  // 立即返回成功响应
  echo json_encode(['success' => true, 'message' => '请求已接收']);

  // 异步任务处理
  $this->dispatchSmsSendingTask($templateId, $mobiles, $content);
}

// 分发短信发送任务 (PHP)
private function dispatchSmsSendingTask($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)); // 将任务添加到Redis队列

  // 使用合适的异步任务调度机制启动任务,例如:
  // 使用命令行工具:exec('php ' . __DIR__ . '/send_sms_worker.php > /dev/null 2>&1 &');
  // 使用消息队列:例如RabbitMQ, Kafka等
}

// 短信发送工作进程 (PHP - send_sms_worker.php)
<?php
while (true) {
  $redis = new Redis();
  $redis->connect('127.0.0.1', 6379);
  $redis->auth('redis_password');

  $dataStr = $redis->rPop('sms_queue');
  if ($dataStr) {
    $data = json_decode($dataStr, true);
    // 调用短信发送API
    $result = sendSmsViaAPI($data['template_id'], $data['mobiles'], $data['content']);
    // 记录日志
    if ($result !== true) {
      error_log("短信发送失败: " . $result);
    }
  }
  sleep(1); // 避免CPU占用过高
}

// 模拟短信发送API调用 (PHP)
function sendSmsViaAPI($templateId, $mobiles, $content) {
    //  此处替换为实际的短信发送API调用
    //  ...
    return true; // 发送成功
}
登录后复制

此方案利用AJAX实现前后台解耦,Redis队列保证任务可靠存储和有序处理,提高了系统效率和用户体验。 请根据实际环境选择合适的异步任务调度机制,例如使用消息队列或进程管理工具。 记得替换代码中的Redis密码和短信发送API。

以上就是如何在不影响响应速度的情况下实现异步批量发送短信?的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号