php+redis实现消息队列

本文内容纲要：

个人理解在项目中使用消息队列一般是有如下几个原因：

把瞬间服务器的请求处理换成异步处理，缓解服务器的压力 实现数据顺序排列获取

redis实现消息队列步骤如下：

1）.redis函数rpush,lpop

2）.建议定时任务入队列

3）创建定时任务出队列

文件：demo.php插入数据到redis队列

<?php $redis=newRedis(); $redis->connect(127.0.0.1,6379); $password=123456; $redis->auth($password); $arr=array(h,e,l,l,o,w,o,r,l,d); foreach($arras$k=>$v){ $redis->rpush("mylist",$v); }

执行后结果如下

?>

文件：index.php定时扫描出队列

<?php $redis=newRedis(); $redis->connect(127.0.0.1,6379); $password=123456; $redis->auth($password); //list类型出队操作 $value=$redis->lpop(mylist); if($value){ echo"出队的值".$value; }else{ echo"出队完成"; } ?>

建立定时任务

*/1****rootphp/wwwroot/workplace/redis/index.php

*/3****rootphp/wwwroot/workplace/redis/demo.php

tail-f/var/log/cron查看定时任务执行情况

Nov700:30:01dongziCROND[6888]:(root)CMD(php/wwwroot/workplace/redis/demo.php)

Nov700:30:01dongziCROND[6890]:(root)CMD(php/wwwroot/workplace/redis/index.php)

定时任务执行队列写入结果如下

127.0.0.1:6379>lrangemylist0-1 1)"h" 2)"e" 3)"l" 4)"l" 5)"o" 6)"w" 7)"o" 8)"r" 9)"l" 10)"d"

定时任务执行出队列后：

127.0.0.1:6379>lrangemylist0-1 1)"e" 2)"l" 3)"l" 4)"o" 5)"w" 6)"o" 7)"r" 8)"l" 9)"d"

本文内容总结：

原文链接：https://www.cnblogs.com/lisqiong/p/6039460.html