如何通过策略模式实现多通道OTP发送（短信+WhatsApp）-php教程-PHP中文网

如何通过策略模式实现多通道OTP发送（短信+WhatsApp）

本文介绍在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');