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

EasyTask使用redis队列教程

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

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

(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非对称加密

php非对称加密

先在centos安装openssl,然后开始://生成私钥openssl genrsa -out rsa_private_key.pem 1024//生成公钥openssl rsa -in rsa_private_key.pem&...

 php 判断是否post,php判断是否post提交,php 判断是否为post,php 判断get 还是post

php 判断是否post,php判断是否post提交,php 判断是否为post,php 判断get 还是post

if($_SERVER['REQUEST_METHOD'] == 'POST') { echo('This is  post '); } elseif ($_SERVER['...

PHP异常处理,PHP自定义错误,PHP记录错误日志

PHP异常处理,PHP自定义错误,PHP记录错误日志

面试中PHP面试官会问调用一个不存在的方法,如何知道是哪个文件哪行调用的?假设方法是getWorkLoad()回答1:开启PHP错误输出,PHP会输出Fatal error: Call to undefined function getWorkLoad() in D:\wwwroot\thinkpa...

全方位认识PHP的SESSION

全方位认识PHP的SESSION

【一】.介绍session由于HTTP是无状态的请求,创建一个会话需要保持必须需要身份标识。当用户第一次访问,PHP会为用户创建一个唯一的sessionid,并将sessionid通过cookie发送给浏览器,并在服务器的临时文件创建一个以sessionid为名的文件用来保存这个sessionid保...

php  while  true  cpu占用100%

php while true cpu占用100%

在编写多进程的实例中我在每个进程中使用如下代码://调用等待信号的处理器 while (true) {     pcntl_signal_dispatch(); }开启5个进程,cpu直接100%修正之后的代码://调用等待信号的处理器 while&...

 php命令行中文乱码,php cli中文乱码

php命令行中文乱码,php cli中文乱码

<?php //如果支持exec函数,可以使用的方式 exec('chcp 65001'); //如果exec函数因安全问题禁用,可以使用的方式 pclose(popen('chcp 65001', 'r'));...