本篇文章是给新手学习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人同时发送验证码也不担心会阻塞导致网络带宽资源耗尽。
项目需要使用websocket推送最新订单,客户服务器非linux不支持swoole,因此使用原生,直接上代码(1).PHP服务端<?php ini_set('error_reporting', E_ALL ^ E_NOTICE); ini_set...
if($_SERVER['REQUEST_METHOD'] == 'POST') { echo('This is post '); } elseif ($_SERVER['...
001源码:/* * $xml_str是xml字符串 */ function xmltoarray($xml_str) { //禁止XML实体扩展攻击 libxml_disable_entity_loader(true); //拒绝包含...
PHP不像net支持多继承,自身只支持单继承,为了解决这个问题,php出了Trait这个特性,减少单继承语言的限制。并且能让代码复用率更高。说白了就是一个对象的属性和方法扩展工具一样。例如:trait exts { public f...
面试中PHP面试官会问调用一个不存在的方法,如何知道是哪个文件哪行调用的?假设方法是getWorkLoad()回答1:开启PHP错误输出,PHP会输出Fatal error: Call to undefined function getWorkLoad() in D:\wwwroot\thinkpa...
(1)swoole启动的主进程是master进程负责全局管理,然后master进程会再fork一个manager进程。(2)manager进程开始统一管理进程创建回收管理。(3)manager进程根据设置的worker_num和task_worker_num来创建work进程和task进程因此启动s...