php+redis消息队列

$redis=new Redis();
$redis->connect(‘127.0.0.1‘);
$ret=$redis->lRange(‘test‘,1,1000);
var_dump($ret);

$redis=new Redis();
$redis->connect(‘127.0.0.1‘);
for($i=0;$i<50;$i++){
    $redis->lPush(‘test‘,$i);
}
echo ‘<script>window.setTimeout(function(){location.href="http://localhost/mq/";},2000);</script>‘;
ob_flush();flush(); //不缓冲
file_get_contents(‘http://localhost/mq/pop.php‘);

set_time_limit(0); 
$redis=new Redis(); 
$redis->connect(‘127.0.0.1‘); 
while(true){ 
    $ret=$redis->lPop(‘test‘); 
    if($ret!==false){ 
        echo $ret.‘<br>‘; 
        ob_flush();flush(); //不缓冲 
        sleep(1); 
    } 
    else{ 
        exit(‘--------end--------‘); 
    } 
}