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

  例1,入队操作:

  

复制代码 代码如下:

  <?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";

  }

  }

  ?>

  例2,出队操作:

  

复制代码 代码如下:

  <?php

  $redis = new Redis();

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

  while(True){

  try{

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

  }catch(Exception $e){

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

  }

  sleep(rand()%3);

  }

  ?>