时间:2021-05-26
本文实例讲述了php+redis实现消息队列功能。分享给大家供大家参考,具体如下:
个人理解在项目中使用消息队列一般是有如下几个原因:
把瞬间服务器的请求处理换成异步处理,缓解服务器的压力
实现数据顺序排列获取
redis实现消息队列步骤如下:
1).redis函数rpush,lpop
2).建议定时任务入队列
3)创建定时任务出队列
文件:demo.php插入数据到redis队列
<?php$redis = new Redis();$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($arr as $k=>$v){ $redis->rpush("mylist",$v);}执行后结果如下
文件:index.php定时扫描出队列
<?php$redis = new Redis();$redis->connect('127.0.0.1',6379);$password = '123456';$redis->auth($password);//list类型出队操作$value = $redis->lpop('mylist');if($value){ echo "出队的值".$value;}else{ echo "出队完成";}?>建立定时任务
*/1 * * * * root php /wwwroot/workplace/redis/index.php
*/3 * * * * root php /wwwroot/workplace/redis/demo.php
tail -f /var/log/cron 查看定时任务执行情况
Nov 7 00:30:01 dongzi CROND[6888]: (root) CMD (php /wwwroot/workplace/redis/demo.php)
Nov 7 00:30:01 dongzi CROND[6890]: (root) CMD (php /wwwroot/workplace/redis/index.php )
定时任务执行队列写入结果如下
127.0.0.1:6379> lrange mylist 0 -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> lrange mylist 0 -1
1) "e"
2) "l"
3) "l"
4) "o"
5) "w"
6) "o"
7) "r"
8) "l"
9) "d"
更多关于PHP相关内容感兴趣的读者可查看本站专题:《php+redis数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《PHP基本语法入门教程》、《PHP数组(Array)操作技巧大全》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例为大家分享了php+redis消息队列实现抢购的具体代码,供大家参考,具体内容如下实现功能:1.基于redis队列,防止高并发的超卖2.基于mysql的
本文实例讲述了php使用redis的有序集合zset实现延迟队列。分享给大家供大家参考,具体如下:延迟队列就是个带延迟功能的消息队列,相对于普通队列,它可以在指
本文实例讲述了PHP+redis实现的购物车单例类。分享给大家供大家参考,具体如下:redis=newRedis();$this->redis->connect
本文实例讲述了php+redis实现注册、删除、编辑、分页、登录、关注等功能。分享给大家供大家参考,具体如下:主要界面连接redisredis.phpconne
本文实例讲述了php实现的redis缓存类定义与使用方法。分享给大家供大家参考,具体如下:php+redis缓存类host="127.0.0.1";$this-