Redis消息队列示例

 入队操作

 <?php

 $redis = new Redis();

 $redis->connect('127.0.0.1',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";

     }

 }

 ?>

出队操作

 <?php

 $redis = new Redis();

 $redis->pconnect('127.0.0.1',6379);

 while(True){

     try{

         echo $redis->RPOP('key1')."\n";

     }catch(Exception $e){

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

     }

     sleep(rand()%3);

 }?>