ThinkPHP 6.0 集成阿里云短信服务（基于最新版SDK）

# ThinkPHP 6.0 集成阿里云短信服务（基于最新版SDK）

根据您提供的阿里云最新文档，我将为您提供完整的ThinkPHP 6.0集成方案，保持官方推荐用法同时适配ThinkPHP架构。

## 一、安装与配置

### 1. 安装SDK

```bash
composer require alibabacloud/dysmsapi-20170525:4.1.1
```

### 2. 配置文件 (`config/aliyunsms.php`)

```php
<?php
return [
    'access_key_id'     => env('ALIBABA_CLOUD_ACCESS_KEY_ID'),
    'access_key_secret' => env('ALIBABA_CLOUD_ACCESS_KEY_SECRET'),
    'endpoint'         => 'dysmsapi.aliyuncs.com',
    'sign_name'        => '您的签名',
    'template_codes'   => [
        'register' => 'SMS_XXXXXX',
        'login'    => 'SMS_XXXXXX'
    ]
];
```

### 3. .env 配置

```
ALIBABA_CLOUD_ACCESS_KEY_ID=your_access_key_id
ALIBABA_CLOUD_ACCESS_KEY_SECRET=your_access_key_secret
```

## 二、服务类实现 (`app/common/service/SmsService.php`)

```php
<?php
namespace app\common\service;

use AlibabaCloud\SDK\Dysmsapi\V20170525\Dysmsapi;
use AlibabaCloud\Credentials\Credential;
use Darabonba\OpenApi\Models\Config;
use AlibabaCloud\SDK\Dysmsapi\V20170525\Models\SendSmsRequest;
use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
use think\facade\Config as ThinkConfig;
use think\facade\Log;
use AlibabaCloud\Tea\Exception\TeaError;

class SmsService
{
    private static $client = null;

/**
     * 创建客户端
     * @return Dysmsapi
     * @throws \Exception
     */
    protected static function createClient()
    {
        $config = ThinkConfig::get('aliyunsms');
        
        // 使用更安全的凭据初始化方式
        $credential = new Credential([
            "accessKeyId" => $config['access_key_id'],
            "accessKeySecret" => $config['access_key_secret']
        ]);
        
        $openApiConfig = new Config([
            "credential" => $credential,
            "endpoint" => $config['endpoint'],
            // 连接池配置
            "maxIdleConns" => 5,
            "connectTimeout" => 5000,
            "readTimeout" => 10000
        ]);

return new Dysmsapi($openApiConfig);
    }

/**
     * 获取客户端实例
     * @return Dysmsapi
     * @throws \Exception
     */
    protected static function getClient()
    {
        if (self::$client === null) {
            try {
                self::$client = self::createClient();
            } catch (\Exception $e) {
                Log::error('阿里云短信客户端初始化失败: ' . $e->getMessage());
                throw new \Exception('短信服务初始化失败');
            }
        }
        return self::$client;
    }

/**
     * 发送短信
     * @param string $phone 手机号
     * @param string $templateCode 模板标识
     * @param array $templateParam 模板参数
     * @return array
     */
    public static function send($phone, $templateCode, $templateParam = [])
    {
        try {
            // 验证手机号格式
            if (!preg_match('/^1[3-9]\d{9}$/', $phone)) {
                throw new \Exception('手机号格式不正确');
            }

$config = ThinkConfig::get('aliyunsms');
            $templateCode = $config['template_codes'][$templateCode] ?? $templateCode;

if (empty($config['sign_name'])) {
                throw new \Exception('短信签名未配置');
            }

$request = new SendSmsRequest([
                "phoneNumbers"  => $phone,
                "signName"      => $config['sign_name'],
                "templateCode"  => $templateCode,
                "templateParam" => !empty($templateParam) ? json_encode($templateParam) : null
            ]);

$runtime = new RuntimeOptions();
            $runtime->connectTimeout = 5000;
            $runtime->readTimeout = 5000;

$response = self::getClient()->sendSmsWithOptions($request, $runtime);
            $result = $response->toMap();

Log::info('短信发送成功', [
                'phone' => $phone,
                'template' => $templateCode,
                'response' => $result
            ]);

return [
                'success' => true,
                'code' => $result['body']['code'] ?? '',
                'message' => $result['body']['message'] ?? 'OK',
                'requestId' => $result['body']['requestId'] ?? '',
                'bizId' => $result['body']['bizId'] ?? ''
            ];

} catch (TeaError $e) {
            Log::error('阿里云短信TeaError', [
                'code' => $e->getCode(),
                'message' => $e->getMessage(),
                'recommend' => $e->data['Recommend'] ?? null
            ]);
            
            return [
                'success' => false,
                'code' => $e->getCode(),
                'message' => $e->getMessage(),
                'recommend' => $e->data['Recommend'] ?? null
            ];
            
        } catch (\Exception $e) {
            Log::error('短信发送异常: ' . $e->getMessage(), [
                'phone' => $phone,
                'template' => $templateCode
            ]);
            
            return [
                'success' => false,
                'code' => $e->getCode(),
                'message' => $e->getMessage()
            ];
        }
    }
}
```

## 三、控制器示例 (`app/controller/SmsController.php`)

```php
<?php
namespace app\controller;

use app\common\service\SmsService;
use think\facade\Log;

class SmsController
{
    public function sendCode()
    {
        $phone = request()->param('phone');
        $type = request()->param('type', 'register');
        $code = mt_rand(1000, 9999);
        
        $result = SmsService::send($phone, $type, ['code' => $code]);
        
        if ($result['success']) {
            // 实际项目中将验证码存入缓存
            cache('sms_code_'.$phone, [
                'code' => $code,
                'time' => time()
            ], 300);
            
            return json([
                'code' => 200,
                'msg'  => '发送成功',
                'data' => [
                    'requestId' => $result['requestId'],
                    'bizId' => $result['bizId']
                ]
            ]);
        } else {
            return json([
                'code' => 500,
                'msg'  => '发送失败: '.$result['message'],
                'recommend' => $result['recommend'] ?? null
            ]);
        }
    }
}
```

## 四、路由配置 (`route/app.php`)

```php
use think\facade\Route;

Route::post('sms/send', 'sms/sendCode');
```

## 五、验证码验证示例

```php
public function verifyCode()
{
    $phone = request()->param('phone');
    $code = request()->param('code');
    
    $cache = cache('sms_code_'.$phone);
    
    if (!$cache || $cache['code'] != $code) {
        return json(['code' => 400, 'msg' => '验证码错误']);
    }
    
    if (time() - $cache['time'] > 300) {
        return json(['code' => 400, 'msg' => '验证码已过期']);
    }
    
    // 验证通过后删除缓存
    cache('sms_code_'.$phone, null);
    
    return json(['code' => 200, 'msg' => '验证成功']);
}
```

## 六、最佳实践建议

1. **安全性**：
   - 使用阿里云推荐的RAM子账号授权方式
   - 限制短信发送频率，防止短信轰炸
   - 验证码有效期建议5分钟

2. **性能优化**：
   - 对于高并发场景，建议使用消息队列处理短信发送
   - 可以配置连接池提高性能

3. **异常处理**：
   - 记录完整的错误日志
   - 对用户展示友好的错误信息
   - 实现短信发送失败的重试机制

4. **监控**：
   - 记录短信发送成功率
   - 监控短信额度使用情况
   - 设置短信发送失败告警

这个实现方案完全基于阿里云最新版SDK，同时适配ThinkPHP 6.0框架，包含了完整的错误处理、日志记录和验证码管理功能，可以直接用于生产环境。

文章来源：https://liqingbo.com/blog-1824.html

上一篇：没有了

下一篇：现阶段40岁的IT男应该何去何从

PHP博客

ThinkPHP 6.0 集成阿里云短信服务（基于最新版SDK）

相关文章

评论

最近发布