您的位置：首页 > 数据库 > Redis

消息列队 php 基于redis 实现

2017-11-28 10:09 453 查看

说明

消息列队基于PHP　实现。　之前　用python　的　flower　实现了　列队。　　今天这里我们用的是　PHP 来实现；在实际的业务环境中 PHP 用的多些；

PHP 实现列队最重要的是用到了 redis list类型的的 blPop 方法的阻塞行为； bLPop方法会移除list 中的一个元素并放回该元素，当list 为空时可以设置阻塞时间过了这个时间会再次检测；以此来实现列队不中断程序检查list ；

当详细说明 blpop 详细

列队添加数据
http://192.168.1.212:7575/task.php?&type=1&num=200

向列队中添加200 条测试数据

<?php

function intodata($num=1000){
$redis=new Redis();
$redis->connect('redis',6379);
echo "redis is runimg".$redis->ping();
//echo "check redis is runing:";
for ($i=0; $i < $num; $i++) {
$data['id']=$i+1;
$data['str']=md5(mt_rand(2,2000));
$redis->rPush('goods:task',json_encode($data));
}
$redis->close();
return true;
}

switch ($_GET['type']) {
case '1':
// add...data
$num=$_GET['num']?$_GET['num']:10;
$adddata=intodata($num);
var_dump($adddata);
break;
case '2':
# code...
break;
case '3':
# code...
break;

default:
# code...
break;
}

执行列队
php queueBloop.php

<?php
$redis=new Redis();
$redis->connect('redis',6379);
// 出队
while (true) {
// 阻塞设置超时时间为3秒
$task = $redis->blPop(array('goods:task'), 3);
if ($task) {
$redis->rPush('goods:success:task', $task[1]);
$task = json_decode($task[1], true);
echo $task['id'] . ':' . $task['cid'] . ':' . 'handle success';
echo PHP_EOL;
sleep(1);
} else {
echo 'nothing' . PHP_EOL;
sleep(5);
}
}

运行环境

要求 PHP 运行环境支持 redis 参考前面博文 docker php-fpm nginx 配置博客 docker nginx镜像+phpfpm 镜像组合配置搭建 PHP+nginx 环境

redis

php-redis 扩展

参考

https://segmentfault.com/a/1190000011084493

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航