phpredis提高消息隊列的實時性方法(推薦)

數據庫存貯都用list形式 要存2個隊列 1個用作消息隊列保存到數據 還有個 就是用來實時讀取數據在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));

  }

讀取 邏輯當redis key沒有了 就讀取數據庫 然後重新寫入list 有的話就讀取redis數據

 /*讀取實例*/

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

以上就是小編為大家帶來的phpredis提高消息隊列的實時性方法(推薦)全部內容了，希望大家多多支持~