本文介绍在php中使用策略模式优雅集成多个otp发送通道（如短信api和whatsapp api），提升消息送达率，并通过队列任务自动降级重试，确保关键验证码可靠触达用户。
本文介绍在php中使用策略模式优雅集成多个otp发送通道（如短信api和whatsapp api），提升消息送达率，并通过队列任务自动降级重试，确保关键验证码可靠触达用户。
在高可用OTP系统中，依赖单一短信通道存在明显风险：网络延迟、运营商拦截、API限流或临时故障都可能导致验证码无法及时送达。简单地“同时调用两个API”不仅增加耦合度，还可能引发重复发送、计费浪费和状态混乱。更专业的做法是采用策略模式（Strategy Pattern）——将不同通道（Jazz SMS、WhatsApp Business API等）抽象为可互换的发送策略，并结合异步队列与失败回调机制，实现智能降级。
✅ 核心设计思路
- 统一接口：定义 OtpSender 接口，约束所有通道必须实现 send(string $phone, string $message): bool 方法；
- 独立策略类：为每个通道编写具体实现（如 JazzSmsSender、WhatsAppSender）；
- 可配置的发送器工厂：根据配置或运行时条件动态选择主通道与备用通道；
- 队列保障可靠性：使用 Laravel 队列（或其他PHP队列方案）封装发送逻辑，利用 failed() 方法自动触发备用通道重试。
? 示例实现（Laravel 风格）
// app/Contracts/OtpSender.php
interface OtpSender
{
public function send(string $phone, string $message): bool;
}
// app/Senders/JazzSmsSender.php
class JazzSmsSender implements OtpSender
{
public function send(string $phone, string $message): bool
{
$phone = preg_replace('/[^0-9]/', '', $phone);
$params = [
'Username' => config('otp.jazz.username'),
'Password' => config('otp.jazz.password'),
'From' => config('otp.jazz.sender_id'),
'To' => $phone,
'Message' => $message,
];
$url = 'https://connect.jazz.com/sendsms_url.html?' . http_build_query($params);
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_TIMEOUT, 15);
$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
$error = curl_error($ch);
curl_close($ch);
return $httpCode === 200 && !empty($response) && strpos($response, 'success') !== false;
}
}
// app/Senders/WhatsAppSender.php （以 Meta Graph API 为例）
class WhatsAppSender implements OtpSender
{
public function send(string $phone, string $message): bool
{
// 注意：需提前将手机号转为国际格式（如 923012345678 → 923012345678@whatsapp.net）
$phoneNumber = preg_replace('/[^0-9]/', '', $phone);
$waPhone = '92' . ltrim($phoneNumber, '0'); // 示例：适配巴基斯坦号码
$url = 'https://graph.facebook.com/v19.0/' . config('otp.whatsapp.phone_number_id') . '/messages';
$accessToken = config('otp.whatsapp.access_token');
$payload = [
'messaging_product' => 'whatsapp',
'to' => $waPhone,
'type' => 'template',
'template' => [
'name' => 'otp_template', // 需提前在 Meta Developer Portal 审核通过
'language' => ['code' => 'en_US'],
'components' => [
['type' => 'body', 'parameters' => [['type' => 'text', 'text' => $message]]]
]
]
];
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
curl_setopt($ch, CURLOPT_HTTPHEADER, [
'Authorization: Bearer ' . $accessToken,
'Content-Type: application/json'
]);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
return $httpCode === 200;
}
}? 异步发送与自动降级（队列任务）
// app/Jobs/SendOtpJob.php
class SendOtpJob implements ShouldQueue
{
use InteractsWithQueue, Queueable, SerializesModels;
public function __construct(
private string $phone,
private string $message,
private string $primaryChannel = 'jazz',
private string $fallbackChannel = 'whatsapp'
) {}
public function handle()
{
$sender = app('otp.sender.factory')->make($this->primaryChannel);
if (!$sender->send($this->phone, $this->message)) {
throw new Exception("Primary OTP channel ({$this->primaryChannel}) failed.");
}
}
public function failed(Throwable $exception)
{
// 自动降级：尝试 WhatsApp 备用通道
$fallbackSender = app('otp.sender.factory')->make($this->fallbackChannel);
$fallbackSender->send($this->phone, $this->message);
\Log::warning('OTP fallback triggered', [
'phone' => $this->phone,
'primary_failed' => $exception->getMessage(),
'fallback_used' => $this->fallbackChannel
]);
}
}
// 调用方式（控制器中）
SendOtpJob::dispatch($phone, $otpMessage)->onQueue('otp');⚠️ 关键注意事项
- 号码格式统一：短信与WhatsApp对号码格式要求不同（如WhatsApp需国际格式+国家码，无前导+或0），务必预处理；
- 模板合规性：WhatsApp 必须使用审核通过的模板消息，且首次发送需用户主动发起会话（可结合登录页点击“同意接收通知”获取初始授权）；
- 幂等与防重放：OTP应带唯一请求ID与时间戳，避免因重试导致用户收到多条相同验证码；
- 监控与告警：记录每次发送结果、耗时及降级次数，当 fallback 触发率 > 5% 时自动告警；
- 配置分离：将各通道密钥、URL、模板名等提取至 .env 与配置文件，禁止硬编码。
通过策略模式 + 队列降级，您不再需要“手动修改原始脚本添加第二个API”，而是构建出可扩展、可测试、可监控的OTP通信基础设施——一次设计，长期受益。
