当前位置:首页 > PHP > 正文内容

EasyTask使用redis队列教程

高老师5年前 (2020-07-07)PHP3469

场景:模拟验证码发送。仅做代码演示。

(1).创建一个验证码发送接口sendCaptcha

/**
 * 发送验证码
 */
public function sendCaptcha()
{
    //外部参数(获取手机号)
    $mobile = $_REQUEST['mobile'] ?? 0;
    if (!$mobile)
    {
        exit(json_encode(['code' => -1, 'msg' => '手机号码不得为空'], 256));
    }

    //生成短信验证码(随机数4位)
    $captcha = rand(1111, 9999);

    //组装队列数据Json
    $send_data = [
        'mobile' => $mobile,
        'captcha' => $captcha,
    ];

    //连接本地的Redis 服务
    $redis = new \Redis();
    $redis->connect('127.0.0.1', 6379);

    //向Redis的send_captcha队列投递数据
    $isPush = $redis->lPush('send_captcha', json_encode($send_data));
    if (!$isPush)
    {
        exit(json_encode(['code' => -1, 'msg' => '验证码发送失败'], 256));
    }

    //输出发送成功
    exit(json_encode(['code' => 0, 'msg' => '验证码发送成功'], 256));
}

(2).EasyTask中的代码如下

// 添加执行定时器
$time = 1;
$task->addFunc(function () {

    //连接本地的Redis 服务
    $redis = new \Redis();
    $redis->connect('127.0.0.1', 6379);

    //提取队列中的数据
    $data = $redis->rPop('send_captcha');
    if ($data)
    {
        //提取数据中的手机号和验证码
        $data = json_decode($data, true);
        $mobile = $data['mobile'];
        $captcha = $data['captcha'];

        //进行发送,此处为伪代码
        //sendCode($mobile,$captcha);

        //输出日志
        echo "向{$mobile}发送验证码{$captcha}成功" . PHP_EOL;
    }
}, 'send_captcha_timer', $time, 1);

(3).启动EasyTask并向接口提交手机号进行测试。

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/141.html

分享给朋友:

“EasyTask使用redis队列教程” 的相关文章

PHP批量插入的2种方法速度对比

PHP批量插入的2种方法速度对比

代码1:for循环批量插入100W数据<?php set_time_limit(0); $servername = "localhost"; $username = "root"; $password ...

php经纬度计算距离

php经纬度计算距离

/**  * 计算两点地理坐标之间的距离  * @param  Decimal $longitude1 起点经度  * @param  Decimal $lati...

 php max input vars,max input vars限制,max input vars 设置

php max input vars,max input vars限制,max input vars 设置

在一个正式项目中操作人员提交239个产品信息进行保存,但是系统却提示没有提交239个产品,于是开启错误信息,显示如下:Warning: Unknown: Input variables exceeded 1000. To incr...

【二】PHP多进程学习-进程信号管理

【二】PHP多进程学习-进程信号管理

(1).学习目标:    了解常见信号类型(百度PHP支持的信号类型),(2).相关函数学习:    (2.1).pcntl_signal函数用于设置一个信号管理器接收进程信号,参数1:信号类型,参数2:回调函数,用于在接收到参数1类型的信...

cookie跨域,cookie p3p跨域

cookie跨域,cookie p3p跨域

最近在公司开发一个新的项目假设项目域名是a.com,需要接入b.com的单点登陆系统。(1).首先我们会在a.com的登陆页面用iframe引入b.com来显示登陆界面,实际上登陆验证操作都是在b.com上面(2).当b.com验证通过,会在前端ajax请求a.com的回调地址,这个回调地址目的就是...

php下载远程文件(支持断点续传,支持超大文件)

php下载远程文件(支持断点续传,支持超大文件)

断点下载的原理:http请求头添加Range参数告诉文件服务器端需要的字节范围例如1个文本文件的字节为1000,第一次请求Range: bytes=0-500第二次请求Range: bytes=501-1000通过每次的请求将返回的流追加写入到文件。注意的项目:断点下载服务器端的每次只返回字节传输的...