当前位置：首页 > 文章列表 > 文章 > php教程 > 异步批量发短信不卡顿的实用技巧

异步批量发短信不卡顿的实用技巧

2025-04-10 20:18:39 0浏览收藏

本文介绍如何高效实现异步批量发送短信，避免因短信发送导致应用卡顿，提升用户体验。通过AJAX请求将短信发送任务提交到后台，后台利用Redis缓存存储任务，再由独立的异步任务进程从Redis队列中读取并发送短信。此方案有效解耦前后台，利用Redis的高效性保证任务可靠存储和有序处理，最终实现短信批量发送不卡顿。文中包含PHP和Redis的代码示例，并讲解了异步任务调度机制的选择，例如使用命令行工具或消息队列。关键词：异步批量发短信，Redis，AJAX，PHP，短信发送，异步任务，高并发。

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

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

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

异步处理流程

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

前台AJAX请求: 用户点击发送按钮，触发AJAX请求，向后台提交短信发送任务。后台立即返回成功响应，告知请求已接收。
后台任务接收与缓存: 后台接收请求后，立即返回成功信息。然后，异步地从数据库获取手机号码和短信内容，并将这些数据写入Redis缓存。Redis作为高效的缓存数据库，能够快速存储和读取数据。
异步任务执行: 后台启动一个独立的异步任务，从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)
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。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《异步批量发短信不卡顿的实用技巧》文章吧，也可关注golang学习网公众号了解相关技术文章。