EasyTask使用redis队列教程

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

(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并向接口提交手机号进行测试。