很多站长朋友们都不太清楚phpredis做队列，今天小编就来给大家整理phpredis做队列，希望对各位有所帮助，具体内容如下：
本文目录一览： 1、 请教PHP+Redis实现任务队列的思路 2、 如何使用Redis 做队列操作 3、 php 用 redis做队列 运行过程是什么样的 4、 php使用redis的有序集合zset实现延迟队列 请教PHP+Redis实现任务队列的思路// 创建请求ID标志, uniqid 无法保证唯一, 自己去搜索生成唯一的方法
$uuid = uniqid();
$tsk_name = "mytask";
$time_out = 30000; // 超时策略: 30秒
$time_start = time();
$redis->rPush($tsk_name, $uuid); // 右(后)插入队列
// 堵塞等待队列中第一个和$uuid匹配的(到我了)
while($uuid != $redis->lGet($tsk_name, 0)){
if((time()-$time_start)> $time_out) {
break; // 超时跳出(某些原因队列异常了, 可能永远取不到)
}
usleep(10); // sleep 10ms, 再次尝试
}
// 这里执行任务的处理代码....
// $response 已拼装好要返回的内容
// 处理完成后(数据库等已入库更新), 需要:
if($redis->lGet($tsk_name, 0) == $uuid){ // 再次确认第一个是本请求
$redis->lPop($tsk_name); // 完成任务了, 从队列中移除
}else{
// 出现这种情况, 是因为超时了, 或前面的$uuid没有被消费
// 若不清除, 后续的请求, 都将无法正常进入队列执行
// 取队列中的所有$uuid
$queues = $redis->lRange($tsk_name, 0, -1);
foreach($queues as $i=>$uid){
if($uid==$uuid){
如何使用Redis 做队列操作redis设计用来做缓存的，但是由于它自身的某种特性使得它可以用来做消息队列，它有几个阻塞式的API可以使用，正是这些阻塞式的API让其有能力做消息队列；
另外，做消息队列的其他特性例如FIFO（先入先出）也很容易实现，只需要一个list对象从头取数据，从尾部塞数据即可；
redis能做消息队列还得益于其list对象blpop brpop接口以及Pub/Sub（发布/订阅）的某些接口，它们都是阻塞版的，所以可以用来做消息队列。
php 用 redis做队列 运行过程是什么样的redis实现消息队列很简单：
$this->redis->rPush($key, $val); // 右边入
$this->redis->lPop($key); // 左边出
php使用redis的有序集合zset实现延迟队列延迟队列就是个带延迟功能的消息队列，相对于普通队列，它可以在指定时间消费掉消息。
我们通过redis的有序集合zset来实现简单的延迟队列，将消息数据序列化，作为zset的value，把消息处理时间作为score，每次通过zRangeByScore获取一条消息进行处理。
然后，我们写一个php脚本，用来处理队列中的任务。
关于phpredis做队列的介绍到此就结束了，不知道本篇文章是否对您有帮助呢？如果你还想了解更多此类信息，记得收藏关注本站，我们会不定期更新哦。
查看更多关于phpredis做队列 php redis 队列处理的详细内容...