本篇文章是给新手学习php redis队列怎么玩的。我们模拟验证码发送,通过队列完成。
(1).创建一个验证码发送接口
/** * 发送验证码 */ 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).创建一个命令行队列处理脚本console.php
<?php //连接本地的Redis 服务 $redis = new \Redis(); $redis->connect('127.0.0.1', 6379); //循环从Redis的send_captcha队列提取数据 while (true) { //从队列提取数据,超时时间5秒 //$content正常返回第一个元素是队列名称,第二个元素是你保存的值 $content = $redis->brPop('send_captcha', 5); if ($content) { //提取数据中的手机号和验证码 $data = json_decode($content['1'], true); $mobile = $data['mobile']; $captcha = $data['captcha']; //进行发送,此处为伪代码 //sendCode($mobile,$captcha); //输出日志 echo "向{$mobile}发送验证码{$captcha}成功" . PHP_EOL; } }
(3).模拟请求验证码接口
curl http://xxxx.com/sendCaptcha //输出 {"code":0,"msg":"验证码发送成功"}
(4).启动命令行脚本php console.php,脚本输出如下
向13380793145发送验证码6188成功
解析:通过向接口提交手机号,接口会把要发送的手机号和验证码保存到队列,而另外1个命令行脚本会监听队列并及时发送验证码。假如同时来100人同时发送验证码也不担心会阻塞导致网络带宽资源耗尽。
【一】.介绍session由于HTTP是无状态的请求,创建一个会话需要保持必须需要身份标识。当用户第一次访问,PHP会为用户创建一个唯一的sessionid,并将sessionid通过cookie发送给浏览器,并在服务器的临时文件创建一个以sessionid为名的文件用来保存这个sessionid保...
<?php /** * daemonize让当前脚本为守护进程执行 * @param string $callback 匿名函数 */ function daemonize($callback) {...
<?php /** * @throws Exception */ function curl() { throw new \Exception('err...
【一】.迭代器迭代是指反复执行一个过程,每执行一次叫做一次迭代。比如下面的代码就叫做迭代:1. <?php 2. $data = ['1', '2', &...
概念请参考w3school文章: redis watch ,redis exec (看完基本秒懂)(1)基本事务://连接本地的 Redis 服务 $redis = new Redis(); $redis->con...
php生成器的方法getReturn获取生成器迭代完成后的返回值,当生成器迭代完成会将生成器的返回值返回,因此如果迭代器未进行迭代是获取不到值的,如果你没有return值则返回null,参考代码:<?php function G1() { &nbs...