PHP操作Redis队列的方法

时间:2020-12-17 03:44:44

入队:

<?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->LPOP('key1')."\n";
        }catch(Exception $e){
          echo $e->getMessage()."\n";
    }
    sleep(rand()%3);
}
?>