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

wufei1232025-04-06PHP11

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

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

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

异步处理流程

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

  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。

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

发表评论

访客

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