php中使用redis队列操作实例代码

<?php

/* 入队 */

$redis = new Redis();

$redis->connect(‘192.168.1.211‘,6379);

while(True){

try{

$value = ‘value_‘.date(‘Y-m-d H:i:s‘);

$redis->LPUSH(‘key1‘,$value);

sleep(rand()%3);

echo $value."\n";

}catch(Exception $e){

echo $e->getMessage()."\n";

}

}

/* 出对 */

$redis = new Redis();

$redis->pconnect(‘192.168.1.211‘,6379);

while(True){

try{

echo $redis->LPOP(‘key1‘)."\n";

}catch(Exception $e){

echo $e->getMessage()."\n";

}

sleep(rand()%3);

}

?>