如何使用phpredis提高消息队列的实时性？

 $redis->lpush($queenkey, json_encode($array));
  $redis->lpush($listkey, json_encode($array));

public function insertinfo()
 {
  $infos = array('info1' => mt_rand(10,100), 'info2' => mt_rand(10,100));
  $this->insertinfos($infos, 'tutorial-list','tutoriallist');
 }



 public function insertinfos($array, $queenkey,$listkey)
 {
  //连接本地的 Redis 服务
  $redis = new \Redis();
  $redis->connect('127.0.0.1', 6379);
  //存储数据到列表中
  $redis->lpush($queenkey, json_encode($array));
  $redis->lpush($listkey, json_encode($array));

 }

 /*读取实例*/

 public function getinfo()
 {
  $sql = 'select * from mobantestinfo';
  $result = $this->getinfos('tutoriallist', $sql);

  //redis key不为空 直接读取redis
  if(empty($result)){
   //连接本地的 Redis 服务
   $redis = new \Redis();
   $redis->connect('127.0.0.1', 6379);
   // 获取存储的数据并输出
   $result = $redis->lrange('tutoriallist', 0, -1);
   foreach ($result as $k=>$v){
    $result[$k]=json_decode($v,true);
   }
   print_r($result);
   exit();
  }
 }
 
 function getinfos($key, $sql)
 {
  //连接本地的 Redis 服务
  $redis = new \Redis();
  $redis->connect('127.0.0.1', 6379);

  // 获取存储的数据
  $result = $redis->lrange($key, 0, 1);

  if (empty($result)) {
   $VModel = new HuanShanVoteModel();
   $result = $VModel->query($sql);

   //重新将缓存队列的形式放入数据库
    foreach ($result as $k=>$v){
   //这个地方要从右边插入 来保证跟数据库顺序一样
    $redis->rpush($key,json_encode($v));
    }
  } else {
   $result=0;

  }


  return $result;
 }