php redis提高消息队列的实时性方法(推荐)

 $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;  }