本文介绍如何通过策略模式与队列重试机制，优雅扩展 otp 发送逻辑，支持短信 api 和 whatsapp api 双通道兜底，提升 otp 到达率与系统容错能力。
本文介绍如何通过策略模式与队列重试机制，优雅扩展 otp 发送逻辑，支持短信 api 和 whatsapp api 双通道兜底，提升 otp 到达率与系统容错能力。
在实际业务中，仅依赖单一 SMS 通道发送 OTP 存在明显风险：网络抖动、运营商限流、API 临时不可用等都可能导致延迟甚至失败。为保障用户体验与认证成功率，推荐采用「多通道+自动降级」架构——即优先调用主通道（如 Jazz 短信网关），失败时自动切换至备用通道（如 WhatsApp Business API 或 Twilio WhatsApp）。
✅ 推荐实现方式：策略模式 + 队列化重试
避免在业务逻辑中硬编码多个 curl 调用，而是将不同通道抽象为独立策略类，再通过统一接口调度：
// 策略接口
interface OtpSender
{
public function send(string $phone, string $message): bool;
}
// 短信通道实现（Jazz）
class JazzSmsSender implements OtpSender
{
public function send(string $phone, string $message): bool
{
$phone = preg_replace('/[^0-9]/', '', $phone);
$params = [
'Username' => '030XXXXXX',
'Password' => 'XXXXXX',
'From' => 'XXXXXX',
'To' => $phone,
'Message' => $message,
];
$url = 'https://connect.jazz.com/sendsms_url.html?' . http_build_query($params);
$ch = curl_init();
curl_setopt_array($ch, [
CURLOPT_URL => $url,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_TIMEOUT => 15,
CURLOPT_SSL_VERIFYPEER => false,
]);
$result = curl_exec($ch);
$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$error = curl_errno($ch);
curl_close($ch);
return $error === 0 && $code >= 200 && $code < 300;
}
}
// WhatsApp 通道示例（使用 Twilio WhatsApp API）
class TwilioWhatsAppSender implements OtpSender
{
private string $sid = 'ACxxxxxxxx';
private string $token = 'yyyyyyyy';
private string $from = 'whatsapp:+14155238886'; // Twilio Sandbox number
public function send(string $phone, string $message): bool
{
// 标准化为 E.164 格式（如 +923001234567）
$e164 = preg_replace('/[^0-9]/', '', $phone);
$e164 = ltrim($e164, '0');
$e164 = '+92' . $e164; // 根据实际国家码调整
$url = 'https://api.twilio.com/2010-04-01/Accounts/' . $this->sid . '/Messages.json';
$data = http_build_query([
'From' => $this->from,
'To' => 'whatsapp:' . $e164,
'Body' => $message,
]);
$ch = curl_init();
curl_setopt_array($ch, [
CURLOPT_URL => $url,
CURLOPT_POST => true,
CURLOPT_POSTFIELDS => $data,
CURLOPT_RETURNTRANSFER => true,
CURLOPT_TIMEOUT => 15,
CURLOPT_USERPWD => $this->sid . ':' . $this->token,
CURLOPT_SSL_VERIFYPEER => false,
]);
$response = json_decode(curl_exec($ch), true);
$code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$error = curl_errno($ch);
curl_close($ch);
return $error === 0 && $code === 201 && !empty($response['sid']);
}
}? 异步执行与自动降级：Laravel 队列 Job 示例
将发送逻辑封装为可重试队列任务，在失败时自动切换通道：
// app/Jobs/SendOtpJob.php
class SendOtpJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
public function __construct(
private string $phone,
private string $message,
private array $strategies = ['JazzSmsSender', 'TwilioWhatsAppSender']
) {}
public function handle()
{
foreach ($this->strategies as $strategyClass) {
if (class_exists($strategyClass)) {
$sender = new $strategyClass();
if ($sender->send($this->phone, $this->message)) {
\Log::info("OTP sent successfully via {$strategyClass}", ['phone' => $this->phone]);
return;
}
}
}
throw new Exception('All OTP channels failed');
}
public function failed(Throwable $exception)
{
\Log::error('OTP delivery exhausted all fallbacks', [
'phone' => $this->phone,
'error' => $exception->getMessage()
]);
// 可选：触发告警、写入失败表、通知运维
}
}调用方式简洁安全：
立即学习“PHP免费学习笔记（深入）”；
SendOtpJob::dispatch($phone, $otpMessage)
->onQueue('notifications')
->delay(now()->addSeconds(2)); // 可选延迟，避免瞬时压测⚠️ 注意事项与最佳实践
- 手机号格式统一：务必标准化为国际格式（E.164），尤其 WhatsApp 对号码格式敏感；
- 错误分类处理：区分网络超时（可重试）、认证失败（需修复配置）、频控拒绝（需退避）等，避免盲目重试；
- 幂等性保障：OTP 本身具备时效性（如 5 分钟），但建议在 Job 层加 Redis 锁或唯一 job ID 防止重复发送；
- 监控与可观测性：记录各通道成功率、平均耗时、失败原因，用于持续优化通道权重；
- 合规性提醒：WhatsApp Business API 需用户主动 opt-in，短信需符合当地法规（如 Pakistan PTA 合规要求）。
通过策略模式解耦通道逻辑，配合队列自动降级，你不仅能快速接入新通道（如 Email、Telegram Bot），还能构建高可用、可观测、易维护的 OTP 发送体系。
