高效异步批量发送短信：提升用户体验与后台处理效率
在应用开发中，批量发送短信是常见需求。为了提升用户体验，避免用户长时间等待，同时确保后台任务顺利执行，异步处理是最佳方案。本文将详细阐述如何实现异步批量发送短信，并提供代码示例。
异步处理流程
该方案采用异步处理机制，确保前台快速响应，后台则独立处理短信发送任务。具体步骤如下：
- 前台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。
