laravel框架使用阿里云短信发送消息操作示例
程序员文章站
2022-06-14 13:43:24
本文实例讲述了laravel框架使用阿里云短信发送消息操作。分享给大家供大家参考,具体如下:最新需要用到发送短信的功能,所以就在网上搜索一些写好的扩展。扩展地址:https://github.com/...
本文实例讲述了laravel框架使用阿里云短信发送消息操作。分享给大家供大家参考,具体如下:
最新需要用到发送短信的功能,所以就在网上搜索一些写好的扩展。
扩展地址:
https://github.com/missmycat/aliyun-sms
通过composer安装:
composer require mrgoon/aliyun-sms dev-master
在 config/app.php 中 providers 加入:
mrgoon\alisms\serviceprovider::class,
有需求的可以自行添加 aliases。
然后在控制台运行 :
php artisan vendor:publish
默认会在 config 目录下创建一个 aliyunsms.php 文件:
<?php return [ 'access_key' => env('aliyun_sms_ak'), // accesskey 'access_secret' => env('aliyun_sms_as'), // accesssecret 'sign_name' => env('aliyun_sms_sign_name'), // 签名 ];
然后在 .env 中配置相应参数:
aliyun_sms_ak= aliyun_sms_as= aliyun_sms_sign_name=
为了能够方便的发送短信,我们可以在 app 目录下,创建一个services目录,并添加 aliyunsms.php 文件。
<?php namespace app\services; use mrgoon\alisms\alisms; /** * 阿里云短信类 */ class aliyunsms { //验证码 const verification_code = 'verification_code'; //模板code public static $templatecodes = [ self::verification_code => 'sms_xxxxxxxxxx', ]; /** * 发送短信 */ public static function sendsms($mobile, $scene, $params = []) { if (empty($mobile)) { throw new \exception('手机号不能为空'); } if (empty($scene)) { throw new \exception('场景不能为空'); } if (!isset(self::$templatecodes[$scene])) { throw new \exception('请配置场景的模板code'); } $template_code = self::$templatecodes[$scene]; try { $ali_sms = new alisms(); $response = $ali_sms->sendsms($mobile, $template_code, $params); if ($response->code == 'ok') { return true; } throw new \exception($response->message); } catch (\throwable $e) { throw new \exception($e->getmessage()); } } }
为了能够记录每次短信发送的状态,我们可以创建一个 sms_logs 表。
create table `sms_logs` ( `id` int(11) unsigned not null auto_increment comment 'id', `type` tinyint(1) not null default '0' comment '类型(0:短信验证码,1:语音验证码,2:短信消息通知)', `mobile` varchar(16) not null default '' comment '手机号', `code` varchar(12) not null default '' comment '验证码', `checked` tinyint(1) not null default '0' comment '是否验证(0:未验证,1:已验证)', `status` tinyint(1) not null default '0' comment '状态(0:未发送,1:已发送,2:发送失败)', `reason` varchar(255) not null default '' comment '失败原因', `remark` varchar(255) not null default '' comment '备注', `operator_id` int(11) not null default '0' comment '操作人id', `ip` varchar(16) not null default '' comment '操作ip', `created` int(11) not null default '0' comment '创建时间', `updated` int(11) not null default '0' comment '更新时间', primary key (`id`) ) engine=innodb default charset=utf8mb4 comment='短信表';
然后针对该表,我们创建一个 smslog 模型来管理。
<?php namespace app\models; use app\services\aliyunsms; class smslog extends model { protected $fillable = [ 'type', 'mobile', 'code', 'checked', 'status', 'reason', 'remark', 'operator_id', 'ip', ]; //类型(0:短信验证码,1:语音验证码,2:短信消息通知) const type_code = 0; const type_voice = 1; const type_message = 2; //是否验证(0:未验证,1:已验证) const checked_unverified = 0; const checked_verified = 1; //状态(0:未发送,1:已发送,2:发送失败) const status_no_send = 0; const status_send = 1; const status_fail = 2; //短信发送间隔时间,默认60秒 const send_interval_time = 60; /** * 检测短信验证码 */ protected function checkcode($mobile, $code) { if (!$mobile) { throw new \exception('手机号不能为空'); } if (!checkmobile($mobile)) { throw new \exception('手机号不正确'); } if (!$code) { throw new \exception('验证码不能为空'); } $sms_log = $this->where([ ['type', self::type_code], ['mobile', $mobile], ['status', self::status_send], ['checked', self::checked_unverified], ])->orderby('created', 'desc')->first(); if (!$sms_log) { throw new \exception('验证码不存在,请重新获取'); } if ($code != $sms_log->code) { throw new \exception('验证码错误'); } $sms_log->checked = self::checked_verified; $sms_log->save(); return true; } /** * 检测短信频率 */ protected function checkrate($mobile) { if (!$mobile) { throw new \exception('手机号不能为空'); } $sms_log = $this->where([ ['mobile', $mobile], ['status', self::status_send], ])->orderby('created', 'desc')->first(); $now = time(); if ($sms_log) { if (($now - strtotime($sms_log->created)) < self::send_interval_time) { throw new \exception('短信发送太频繁,请稍后再试'); } } return true; } /** * 发送短信验证码 */ protected function sendverifycode($mobile) { self::checkrate($mobile); $code = mt_rand(1000, 9999); $sms_log = $this->create([ 'type' => self::type_code, 'mobile' => $mobile, 'code' => $code, 'checked' => self::checked_unverified, 'status' => self::status_no_send, 'ip' => getrealip(), ]); try { aliyunsms::sendsms($mobile, aliyunsms::verification_code, ['code' => $code]); $sms_log->status = self::status_send; $sms_log->save(); return true; } catch (\exception $e) { $sms_log->status = self::status_fail; $sms_log->reason = $e->getmessage(); $sms_log->save(); throw new \exception($e->getmessage()); } } }
这样,我们就可以在项目中通过 smslog::sendverifycode() 发送短信了。
getrealip() 和 checkmobile() 方法为公共方法,存放在 app/helpers 的 functions.php 中。
/** * 获取真实ip地址 */ function getrealip() { $ip = false; if (getenv("http_client_ip") && strcasecmp(getenv("http_client_ip"), "unknown")) { $ip = getenv("http_client_ip"); } else if (getenv("http_x_forwarded_for") && strcasecmp(getenv("http_x_forwarded_for"), "unknown")) { $ips = explode(", ", getenv("http_x_forwarded_for")); if ($ip) { array_unshift($ips, $ip); $ip = false; } $ipscount = count($ips); for ($i = 0; $i < $ipscount; $i++) { if (!preg_match("/^(10|172\.16|192\.168)\./i", $ips[$i])) { $ip = $ips[$i]; break; } } } else if (getenv("remote_addr") && strcasecmp(getenv("remote_addr"), "unknown")) { $ip = getenv("remote_addr"); } else if (isset($_server['remote_addr']) && $_server['remote_addr'] && strcasecmp($_server['remote_addr'], "unknown")) { $ip = $_server['remote_addr']; } else { $ip = "unknown"; } return isip($ip) ? $ip : "unknown"; } /** * 检查是否是合法的ip */ function isip($ip) { if (preg_match('/^((\d|[1-9]\d|2[0-4]\d|25[0-5]|1\d\d)(?:\.(\d|[1-9]\d|2[0-4]\d|25[0-5]|1\d\d)){3})$/', $ip)) { return true; } else { return false; } } /** * 验证手机号 */ function checkmobile($mobile) { return preg_match('/^((13[0-9])|(14[5,7])|(15[0-3,5-9])|(17[0,3,5-8])|(18[0-9])|166|198|199|(147))\d{8}$/i', $mobile); }