异步批量短信发送：提升效率，优化用户体验
批量发送短信是许多应用的常见需求，例如用户注册、活动通知等。如何既保证效率，又不影响用户体验呢？本文介绍一种基于前台触发、后台异步处理的方案。用户点击发送按钮后，系统立即返回确认信息，后台则异步执行数据库查询、缓存写入以及短信发送等操作。
实现步骤详解
-
前台AJAX请求: 用户点击发送按钮，前台使用AJAX向后台发送请求，避免页面刷新，提升用户体验。
$.ajax({ url: '/send-sms', type: 'POST', data: {template_id: 123, mobiles: ['13800138000', '13800138001'], content: '测试短信'}, success: function(result) { alert('短信发送请求已提交'); } });登录后复制 -
后台快速响应: 后台收到请求后，立即返回成功响应，无需等待耗时操作完成。
public function sendSms() { $templateId = $_POST['template_id']; $mobiles = $_POST['mobiles']; $content = $_POST['content']; // 返回JSON响应 echo json_encode(['success' => true, 'message' => '请求已提交']); // 异步处理短信发送 $this->asyncSendSms($templateId, $mobiles, $content); }登录后复制 -
异步任务处理: 后台异步任务首先从数据库获取短信数据，写入Redis缓存。
private function asyncSendSms($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队列获取数据，调用短信服务商API发送短信。错误信息会被记录到日志中，方便后续排查。
public function processSmsQueue() { $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $redis->auth('redis_password'); // 从Redis队列获取数据 $dataStr = $redis->rPop('sms_queue'); if ($dataStr) { $data = json_decode($dataStr, true); // 调用短信服务商API $result = $this->sendSmsApi($data['template_id'], $data['mobiles'], $data['content']); // 记录日志 if ($result !== true) { error_log("短信发送失败: " . $result); } // 继续处理队列中的下一条消息 // ... } }登录后复制
此方案通过前台AJAX和后台异步任务，有效地将短信发送与用户交互分离，提高了系统效率和用户体验。 请根据实际情况选择合适的异步任务处理机制，例如使用消息队列服务（如RabbitMQ、Kafka）或进程管理工具（如Supervisor）。
以上就是如何通过前台按钮触发和后台异步处理实现高效的批量发送短信？的详细内容，更多请关注php中文网其它相关文章！